Help us shape the future of Go! Take the 2026 Go Developer Survey

sqlcgen

package
v0.31.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 28, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivateStreamResourceParams added in v0.6.0

type ActivateStreamResourceParams struct {
	StreamID     string
	TenantID     string
	ResourceName string
}

type AddResourceProgressParams added in v0.31.0

type AddResourceProgressParams struct {
	RunID        string
	ResourceName string
	TenantID     string
	Status       int16
	Records      int64
	Bytes        int64
}

type AdvanceDedupSeenParams

type AdvanceDedupSeenParams struct {
	TenantID string
	RunID    string
	Seq      int64
}

type AdvanceStreamEpochParams added in v0.6.0

type AdvanceStreamEpochParams struct {
	Epoch         int64
	StreamID      string
	TenantID      string
	PreviousEpoch int64
}

type BumpReplicationStreamMembershipRevisionParams added in v0.6.0

type BumpReplicationStreamMembershipRevisionParams struct {
	ReplicationStreamID string
	TenantID            string
}

type ChangeStreamDesiredStateParams added in v0.6.0

type ChangeStreamDesiredStateParams struct {
	DesiredState string
	StreamID     string
	TenantID     string
	Revision     int64
}

type ClaimDueParams

type ClaimDueParams struct {
	Now         pgtype.Timestamptz
	LeaseCutoff pgtype.Timestamptz
	Lim         int32
}

type ClaimDueRow

type ClaimDueRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          pgtype.Text
	CronExpr      string
	Timezone      string
	OverlapPolicy int16
	Enabled       bool
	LastFiredAt   pgtype.Timestamptz
	NextFireAt    pgtype.Timestamptz
	CreatedAt     pgtype.Timestamptz
}

type ClaimStreamAttemptParams added in v0.6.0

type ClaimStreamAttemptParams struct {
	Token       int64
	TenantID    string
	ExecutionID string
	RunID       pgtype.Text
}

type Connection

type Connection struct {
	ID              string
	TenantID        string
	Kind            ConnectorKind
	Name            string
	Connector       string
	Config          []byte
	SecretRefs      []byte
	Version         int64
	IsDeleted       bool
	DeletedAt       pgtype.Timestamptz
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type ConnectorKind

type ConnectorKind string
const (
	ConnectorKindSource ConnectorKind = "source"
	ConnectorKindSink   ConnectorKind = "sink"
)

func (*ConnectorKind) Scan

func (e *ConnectorKind) Scan(src interface{}) error

type CountConnectionsParams

type CountConnectionsParams struct {
	TenantID       string
	Kind           NullConnectorKind
	IncludeDeleted bool
	Search         string
}

type CountPipelineVersionsParams added in v0.0.27

type CountPipelineVersionsParams struct {
	TenantID   string
	PipelineID string
}

type CountPipelinesParams

type CountPipelinesParams struct {
	TenantID       string
	IncludeDeleted bool
	Search         string
}

type CreateConnectionParams

type CreateConnectionParams struct {
	ConnectionID string
	TenantID     string
	Kind         ConnectorKind
	Name         string
	Connector    string
	Config       []byte
	SecretRefs   []byte
}

type CreateNotifierParams added in v0.3.1

type CreateNotifierParams struct {
	NotifierID       string
	TenantID         string
	PipelineID       string
	Name             string
	NotificationType NotificationType
	IsEnabled        bool
	Events           []byte
	Resources        []byte
	Config           []byte
	SecretRefs       []byte
	CreatedByUserID  pgtype.Text
	UpdatedByUserID  pgtype.Text
}

type CreatePipelineParams

type CreatePipelineParams struct {
	PipelineID          string
	TenantID            string
	Name                string
	Description         string
	ExecutionMode       int32
	WorkerConfiguration []byte
}

type CreatePipelineVersionParams

type CreatePipelineVersionParams struct {
	TenantID   string
	PipelineID string
	ID         string
	Graph      []byte
}

type CreatePipelineVersionRow

type CreatePipelineVersionRow struct {
	ID        string
	Version   int64
	CreatedAt pgtype.Timestamptz
}

type CreateReplicationStreamParams added in v0.0.27

type CreateReplicationStreamParams struct {
	ReplicationStreamID          string
	TenantID                     string
	PipelineID                   string
	RouteKey                     string
	Generation                   int64
	SourceConnectionID           string
	SinkConnectionID             string
	ConsumerName                 string
	ConsumerConfig               []byte
	ContinuityFingerprint        string
	CreatedFromPipelineVersionID string
}

type CreateRunParams

type CreateRunParams struct {
	RunID             string
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	ScheduleID        string
	Status            int16
	Request           []byte
	Records           int64
	Bytes             int64
	ScheduledAt       pgtype.Timestamptz
	RequestedAt       pgtype.Timestamptz
	StartedAt         pgtype.Timestamptz
	EndedAt           pgtype.Timestamptz
	Error             string
	CpuSeconds        float64
	MemoryPeakBytes   int64
	FromStatus        int16
}

type CreateStreamAttemptParams added in v0.6.0

type CreateStreamAttemptParams struct {
	StreamID        string
	TenantID        string
	ExecutionID     string
	DesiredRevision int64
	TtlUs           int64
}

type CreateStreamEpochParams added in v0.6.0

type CreateStreamEpochParams struct {
	StreamID     string
	TenantID     string
	Epoch        int64
	AttemptToken int64
	Certificate  []byte
	Positions    []byte
	Records      int64
	Bytes        int64
	RunID        string
}

type CreateStreamEpochRow added in v0.6.0

type CreateStreamEpochRow struct {
	StreamID     string
	TenantID     string
	Epoch        int64
	AttemptToken int64
	Certificate  []byte
	Positions    []byte
	CommittedAt  pgtype.Timestamptz
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteConnectionParams added in v0.0.27

type DeleteConnectionParams struct {
	TenantID     string
	ConnectionID string
}

type DeleteNotifierParams added in v0.3.1

type DeleteNotifierParams struct {
	TenantID   string
	PipelineID string
	NotifierID string
}

type DeletePipelineNotifiersParams added in v0.3.1

type DeletePipelineNotifiersParams struct {
	TenantID   string
	PipelineID string
}

type DeletePipelineParams added in v0.0.27

type DeletePipelineParams struct {
	TenantID   string
	PipelineID string
}

type DeletePipelineScheduledRunsParams

type DeletePipelineScheduledRunsParams struct {
	TenantID   string
	PipelineID pgtype.Text
	Status     int16
}

type DeletePipelineSchedulesParams added in v0.0.27

type DeletePipelineSchedulesParams struct {
	TenantID   string
	PipelineID string
}

type DeleteResourceCheckpointParams

type DeleteResourceCheckpointParams struct {
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	ResourceName      string
}

type DeleteRunParams added in v0.0.27

type DeleteRunParams struct {
	TenantID string
	RunID    string
}

type DeleteScheduleParams added in v0.0.27

type DeleteScheduleParams struct {
	TenantID   string
	ScheduleID string
}

type DeleteScheduleScheduledRunsParams

type DeleteScheduleScheduledRunsParams struct {
	TenantID   string
	ScheduleID pgtype.Text
	Status     int16
}

type DeleteStreamResourceCheckpointParams added in v0.0.27

type DeleteStreamResourceCheckpointParams struct {
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
}

type EndStreamAttemptParams added in v0.6.0

type EndStreamAttemptParams struct {
	Termination pgtype.Text
	Reason      string
	Token       int64
	TenantID    string
	RequireLive bool
}

type EnsureTenantParams

type EnsureTenantParams struct {
	TenantID string
	Name     string
}

type EnsureUserParams added in v0.0.27

type EnsureUserParams struct {
	TenantID   string
	ExternalID string
}

type FinishStoppedContinuousRunParams added in v0.6.0

type FinishStoppedContinuousRunParams struct {
	StreamID string
	TenantID string
}

type GetActiveReplicationStreamParams added in v0.0.27

type GetActiveReplicationStreamParams struct {
	PipelineID string
	RouteKey   string
}

type GetConnectionParams added in v0.0.27

type GetConnectionParams struct {
	TenantID     string
	ConnectionID string
}

type GetConnectionRow

type GetConnectionRow struct {
	ID              string
	TenantID        string
	Kind            ConnectorKind
	Name            string
	Connector       string
	Config          []byte
	SecretRefs      []byte
	Version         int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	DeletedAt       pgtype.Timestamptz
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
}

type GetLatestRouteAttemptParams added in v0.6.0

type GetLatestRouteAttemptParams struct {
	PipelineID string
	Route      string
	TenantID   string
}

type GetLatestStreamAttemptParams added in v0.6.0

type GetLatestStreamAttemptParams struct {
	StreamID string
	TenantID string
}

type GetNotifierParams added in v0.3.1

type GetNotifierParams struct {
	TenantID   string
	PipelineID string
	NotifierID string
}

type GetPipelineParams added in v0.0.27

type GetPipelineParams struct {
	TenantID   string
	PipelineID string
}

type GetPipelineRow

type GetPipelineRow struct {
	ID                  string
	TenantID            string
	Name                string
	Description         string
	CurrentVersionID    pgtype.Text
	ExecutionMode       int32
	WorkerConfiguration []byte
	CreatedAt           pgtype.Timestamptz
	UpdatedAt           pgtype.Timestamptz
	DeletedAt           pgtype.Timestamptz
	CreatedByUserID     pgtype.Text
	UpdatedByUserID     pgtype.Text
	DeletedByUserID     pgtype.Text
}

type GetPipelineVersionParams

type GetPipelineVersionParams struct {
	PipelineID string
	TenantID   string
	Version    int64
}

type GetPipelineVersionRow

type GetPipelineVersionRow struct {
	ID              string
	PipelineID      string
	Version         int64
	Graph           []byte
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
}

type GetReplicationStreamPipelineIDParams added in v0.6.0

type GetReplicationStreamPipelineIDParams struct {
	StreamID   string
	TenantID   string
	Generation int64
}

type GetStreamAttemptByExecutionIDParams added in v0.6.0

type GetStreamAttemptByExecutionIDParams struct {
	TenantID    string
	ExecutionID string
}

type GetStreamEpochParams added in v0.6.0

type GetStreamEpochParams struct {
	StreamID string
	TenantID string
	Epoch    int64
}

type GetStreamExecutionParams added in v0.6.0

type GetStreamExecutionParams struct {
	StreamID string
	TenantID string
}

type GetStreamExecutionRow added in v0.6.0

type GetStreamExecutionRow struct {
	RunID             string
	PipelineVersionID string
	DesiredState      string
	Revision          int64
	RunSpec           []byte
	LastEpoch         int64
}

type InitializeStreamExecutionParams added in v0.6.0

type InitializeStreamExecutionParams struct {
	RunID    pgtype.Text
	RunSpec  []byte
	StreamID string
	TenantID string
}

type LatestStreamPositionsParams added in v0.6.0

type LatestStreamPositionsParams struct {
	StreamID string
	TenantID string
}

type LeaseSchedulesParams

type LeaseSchedulesParams struct {
	ClaimedAt   pgtype.Timestamptz
	ScheduleIds []string
}

type ListConnectionsParams

type ListConnectionsParams struct {
	TenantID       string
	Kind           NullConnectorKind
	IncludeDeleted bool
	Search         string
	SortBy         string
	SortDesc       bool
	OffsetRows     int32
	Lim            int32
}

type ListConnectionsRow

type ListConnectionsRow struct {
	ID              string
	TenantID        string
	Kind            ConnectorKind
	Name            string
	Connector       string
	Config          []byte
	SecretRefs      []byte
	Version         int64
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	DeletedAt       pgtype.Timestamptz
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
}

type ListNotifiersParams added in v0.3.1

type ListNotifiersParams struct {
	TenantID       string
	PipelineID     string
	IncludeDeleted bool
}

type ListPipelineVersionsParams

type ListPipelineVersionsParams struct {
	TenantID   string
	PipelineID string
	SortBy     string
	SortDesc   bool
	OffsetRows int32
	Lim        int32
}

type ListPipelineVersionsRow

type ListPipelineVersionsRow struct {
	ID              string
	PipelineID      string
	Version         int64
	Graph           []byte
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
}

type ListPipelinesParams

type ListPipelinesParams struct {
	TenantID       string
	IncludeDeleted bool
	Search         string
	SortBy         string
	SortDesc       bool
	OffsetRows     int32
	Lim            int32
}

type ListPipelinesRow

type ListPipelinesRow struct {
	ID                  string
	TenantID            string
	Name                string
	Description         string
	CurrentVersionID    pgtype.Text
	ExecutionMode       int32
	WorkerConfiguration []byte
	CreatedAt           pgtype.Timestamptz
	UpdatedAt           pgtype.Timestamptz
	DeletedAt           pgtype.Timestamptz
	CreatedByUserID     pgtype.Text
	UpdatedByUserID     pgtype.Text
	DeletedByUserID     pgtype.Text
}

type ListReconcilableStreamIDsParams added in v0.6.0

type ListReconcilableStreamIDsParams struct {
	TenantID  string
	AfterID   string
	PageLimit int32
}

type ListResourceCheckpointsParams

type ListResourceCheckpointsParams struct {
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
}

type ListResourceCheckpointsRow

type ListResourceCheckpointsRow struct {
	ResourceName string
	Cursor       []byte
	LastRunID    string
	UpdatedAt    pgtype.Timestamptz
}

type ListResourcesParams added in v0.0.27

type ListResourcesParams struct {
	TenantID string
	RunID    string
}

type ListResourcesRow

type ListResourcesRow struct {
	RunID        string
	ResourceName string
	TenantID     string
	Status       int16
	Records      int64
	Bytes        int64
	Error        string
}

type ListRetiredReplicationStreamsForRouteParams added in v0.0.27

type ListRetiredReplicationStreamsForRouteParams struct {
	PipelineID string
	RouteKey   string
}

type ListSchedulesParams

type ListSchedulesParams struct {
	TenantID      string
	FilterEnabled pgtype.Bool
	Lim           int32
}

type ListSchedulesRow

type ListSchedulesRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          pgtype.Text
	CronExpr      string
	Timezone      string
	OverlapPolicy int16
	Enabled       bool
	LastFiredAt   pgtype.Timestamptz
	NextFireAt    pgtype.Timestamptz
	CreatedAt     pgtype.Timestamptz
}

type ListStreamResourceCheckpointsRow added in v0.0.27

type ListStreamResourceCheckpointsRow struct {
	ResourceName string
	Cursor       []byte
	LastRunID    string
	UpdatedAt    pgtype.Timestamptz
}

type ListTenantsRow

type ListTenantsRow struct {
	ID        string
	Name      string
	CreatedAt pgtype.Timestamptz
	UpdatedAt pgtype.Timestamptz
}

type LoadCheckpointParams

type LoadCheckpointParams struct {
	TenantID     string
	RunID        string
	ResourceName string
}

type LoadPipelineScheduleParams added in v0.0.27

type LoadPipelineScheduleParams struct {
	TenantID   string
	PipelineID string
}

type LoadPipelineScheduleRow

type LoadPipelineScheduleRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          pgtype.Text
	CronExpr      string
	Timezone      string
	OverlapPolicy int16
	Enabled       bool
	LastFiredAt   pgtype.Timestamptz
	NextFireAt    pgtype.Timestamptz
	CreatedAt     pgtype.Timestamptz
}

type LoadResourceCheckpointParams

type LoadResourceCheckpointParams struct {
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	ResourceName      string
}

type LoadResourceCheckpointRow

type LoadResourceCheckpointRow struct {
	Cursor    []byte
	LastRunID string
	UpdatedAt pgtype.Timestamptz
}

type LoadRunParams added in v0.0.27

type LoadRunParams struct {
	TenantID string
	RunID    string
}

type LoadRunRequestParams added in v0.6.0

type LoadRunRequestParams struct {
	RunID             string
	TenantID          string
	PipelineID        pgtype.Text
	PipelineVersionID pgtype.Text
}

type LoadRunRow

type LoadRunRow struct {
	ID              string
	TenantID        string
	ScheduleID      string
	Status          int16
	Request         []byte
	Records         int64
	Bytes           int64
	CreatedAt       pgtype.Timestamptz
	ScheduledAt     pgtype.Timestamptz
	RequestedAt     pgtype.Timestamptz
	StartedAt       pgtype.Timestamptz
	EndedAt         pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	Error           string
	CpuSeconds      float64
	MemoryPeakBytes int64
}

type LoadScheduleParams added in v0.0.27

type LoadScheduleParams struct {
	TenantID   string
	ScheduleID string
}

type LoadScheduleRow

type LoadScheduleRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          pgtype.Text
	CronExpr      string
	Timezone      string
	OverlapPolicy int16
	Enabled       bool
	LastFiredAt   pgtype.Timestamptz
	NextFireAt    pgtype.Timestamptz
	CreatedAt     pgtype.Timestamptz
}

type LoadStreamResourceCheckpointParams added in v0.0.27

type LoadStreamResourceCheckpointParams struct {
	ReplicationStreamID string
	ResourceName        string
}

type LoadStreamResourceCheckpointRow added in v0.0.27

type LoadStreamResourceCheckpointRow struct {
	Cursor    []byte
	LastRunID string
	UpdatedAt pgtype.Timestamptz
}

type LoadTenantRow

type LoadTenantRow struct {
	ID        string
	Name      string
	CreatedAt pgtype.Timestamptz
	UpdatedAt pgtype.Timestamptz
}

type LockNotifierPipelineParams added in v0.3.1

type LockNotifierPipelineParams struct {
	TenantID   string
	PipelineID string
}

type LockPipelineForReplicationStreamParams added in v0.0.27

type LockPipelineForReplicationStreamParams struct {
	PipelineID string
	TenantID   string
}

type LockReplicationStreamGenerationParams added in v0.6.0

type LockReplicationStreamGenerationParams struct {
	StreamID   string
	TenantID   string
	Generation int64
}

type LockReplicationStreamParams added in v0.0.27

type LockReplicationStreamParams struct {
	ReplicationStreamID string
	TenantID            string
}

type LockRunStatusParams added in v0.0.27

type LockRunStatusParams struct {
	TenantID string
	RunID    string
}

type MarkContinuousRunStartedParams added in v0.6.0

type MarkContinuousRunStartedParams struct {
	RunID    string
	TenantID string
}

type NextReplicationStreamGenerationParams added in v0.0.27

type NextReplicationStreamGenerationParams struct {
	PipelineID string
	RouteKey   string
}

type NotificationType added in v0.3.1

type NotificationType string
const (
	NotificationTypeWebhook NotificationType = "webhook"
	NotificationTypeSlack   NotificationType = "slack"
)

func (*NotificationType) Scan added in v0.3.1

func (e *NotificationType) Scan(src interface{}) error

type Notifier added in v0.3.1

type Notifier struct {
	ID               string
	TenantID         string
	PipelineID       string
	Name             string
	NotificationType NotificationType
	IsEnabled        bool
	Events           []byte
	Resources        []byte
	Config           []byte
	SecretRefs       []byte
	IsDeleted        bool
	DeletedAt        pgtype.Timestamptz
	CreatedByUserID  pgtype.Text
	UpdatedByUserID  pgtype.Text
	DeletedByUserID  pgtype.Text
	CreatedAt        pgtype.Timestamptz
	UpdatedAt        pgtype.Timestamptz
}

type NullConnectorKind

type NullConnectorKind struct {
	ConnectorKind ConnectorKind
	Valid         bool // Valid is true if ConnectorKind is not NULL
}

func (*NullConnectorKind) Scan

func (ns *NullConnectorKind) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullConnectorKind) Value

func (ns NullConnectorKind) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullNotificationType added in v0.3.1

type NullNotificationType struct {
	NotificationType NotificationType
	Valid            bool // Valid is true if NotificationType is not NULL
}

func (*NullNotificationType) Scan added in v0.3.1

func (ns *NullNotificationType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullNotificationType) Value added in v0.3.1

func (ns NullNotificationType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type PendingContinuousRunsParams added in v0.6.0

type PendingContinuousRunsParams struct {
	AfterID   string
	PageLimit int32
}

type PendingContinuousRunsRow added in v0.6.0

type PendingContinuousRunsRow struct {
	ID       string
	TenantID string
}

type Pipeline

type Pipeline struct {
	ID                  string
	TenantID            string
	Name                string
	Description         string
	CurrentVersionID    pgtype.Text
	WorkerConfiguration []byte
	IsDeleted           bool
	DeletedAt           pgtype.Timestamptz
	CreatedByUserID     pgtype.Text
	UpdatedByUserID     pgtype.Text
	DeletedByUserID     pgtype.Text
	CreatedAt           pgtype.Timestamptz
	UpdatedAt           pgtype.Timestamptz
	ExecutionMode       int32
}

type PipelineResourceCheckpoint

type PipelineResourceCheckpoint struct {
	ID                          string
	TenantID                    string
	PipelineID                  string
	PipelineVersionID           string
	RouteKey                    string
	ResourceName                string
	Cursor                      []byte
	LastRunID                   string
	CreatedByUserID             pgtype.Text
	UpdatedByUserID             pgtype.Text
	DeletedByUserID             pgtype.Text
	CreatedAt                   pgtype.Timestamptz
	UpdatedAt                   pgtype.Timestamptz
	ReplicationStreamResourceID pgtype.Text
}

type PipelineVersion

type PipelineVersion struct {
	ID              string
	TenantID        string
	PipelineID      string
	Version         int64
	Graph           []byte
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type Queries

type Queries struct {
	// contains filtered or unexported fields
}

func New

func New(db DBTX) *Queries

func (*Queries) ActivateStreamResource added in v0.6.0

func (q *Queries) ActivateStreamResource(ctx context.Context, arg ActivateStreamResourceParams) error

func (*Queries) AddResourceProgress added in v0.31.0

func (q *Queries) AddResourceProgress(ctx context.Context, arg AddResourceProgressParams) error

func (*Queries) AdvanceDedupSeen

func (q *Queries) AdvanceDedupSeen(ctx context.Context, arg AdvanceDedupSeenParams) (int64, error)

Advances the (tenant, run) high-water mark only when @seq increases.

func (*Queries) AdvanceStreamEpoch added in v0.6.0

func (q *Queries) AdvanceStreamEpoch(ctx context.Context, arg AdvanceStreamEpochParams) (int64, error)

func (*Queries) BumpReplicationStreamMembershipRevision added in v0.6.0

func (q *Queries) BumpReplicationStreamMembershipRevision(ctx context.Context, arg BumpReplicationStreamMembershipRevisionParams) error

func (*Queries) ChangeStreamDesiredState added in v0.6.0

func (q *Queries) ChangeStreamDesiredState(ctx context.Context, arg ChangeStreamDesiredStateParams) (int64, error)

func (*Queries) ClaimDue

func (q *Queries) ClaimDue(ctx context.Context, arg ClaimDueParams) ([]*ClaimDueRow, error)

lease_cutoff is now - leaseTTL, computed in Go: a claimed_at older than that is treated as an abandoned lease and eligible to be reclaimed.

func (*Queries) ClaimStreamAttempt added in v0.6.0

func (q *Queries) ClaimStreamAttempt(ctx context.Context, arg ClaimStreamAttemptParams) (int64, error)

func (*Queries) CountConnections

func (q *Queries) CountConnections(ctx context.Context, arg CountConnectionsParams) (int64, error)

func (*Queries) CountPipelineVersions

func (q *Queries) CountPipelineVersions(ctx context.Context, arg CountPipelineVersionsParams) (int64, error)

func (*Queries) CountPipelines

func (q *Queries) CountPipelines(ctx context.Context, arg CountPipelinesParams) (int64, error)

func (*Queries) CreateConnection

func (q *Queries) CreateConnection(ctx context.Context, arg CreateConnectionParams) error

func (*Queries) CreateNotifier added in v0.3.1

func (q *Queries) CreateNotifier(ctx context.Context, arg CreateNotifierParams) (*Notifier, error)

func (*Queries) CreatePipeline

func (q *Queries) CreatePipeline(ctx context.Context, arg CreatePipelineParams) (pgtype.Timestamptz, error)

func (*Queries) CreatePipelineVersion

func (q *Queries) CreatePipelineVersion(ctx context.Context, arg CreatePipelineVersionParams) (*CreatePipelineVersionRow, error)

func (*Queries) CreateReplicationStream added in v0.0.27

func (q *Queries) CreateReplicationStream(ctx context.Context, arg CreateReplicationStreamParams) (*ReplicationStream, error)

func (*Queries) CreateRun

func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) (int64, error)

CreateRun inserts a run or promotes a pre-created scheduled row. The update arm only fires while the existing row is still at @from_status, so a racing intake cannot roll a live run back; 0 rows reports the conflict.

func (*Queries) CreateStreamAttempt added in v0.6.0

func (q *Queries) CreateStreamAttempt(ctx context.Context, arg CreateStreamAttemptParams) (*StreamAttempt, error)

func (*Queries) CreateStreamEpoch added in v0.6.0

func (q *Queries) CreateStreamEpoch(ctx context.Context, arg CreateStreamEpochParams) (*CreateStreamEpochRow, error)

func (*Queries) DeleteConnection

func (q *Queries) DeleteConnection(ctx context.Context, arg DeleteConnectionParams) error

func (*Queries) DeleteNotifier added in v0.3.1

func (q *Queries) DeleteNotifier(ctx context.Context, arg DeleteNotifierParams) (*Notifier, error)

func (*Queries) DeletePipeline

func (q *Queries) DeletePipeline(ctx context.Context, arg DeletePipelineParams) error

func (*Queries) DeletePipelineNotifiers added in v0.3.1

func (q *Queries) DeletePipelineNotifiers(ctx context.Context, arg DeletePipelineNotifiersParams) error

func (*Queries) DeletePipelineScheduledRuns

func (q *Queries) DeletePipelineScheduledRuns(ctx context.Context, arg DeletePipelineScheduledRunsParams) error

Reaps a pipeline's pre-created scheduled runs by the pipeline_id column: deleting the schedules row SET-NULLs runs.schedule_id, so schedule-scoped lookups cannot find these rows once the delete tx is underway.

func (*Queries) DeletePipelineSchedules

func (q *Queries) DeletePipelineSchedules(ctx context.Context, arg DeletePipelineSchedulesParams) error

func (*Queries) DeleteResourceCheckpoint

func (q *Queries) DeleteResourceCheckpoint(ctx context.Context, arg DeleteResourceCheckpointParams) error

func (*Queries) DeleteRun

func (q *Queries) DeleteRun(ctx context.Context, arg DeleteRunParams) error

func (*Queries) DeleteSchedule

func (q *Queries) DeleteSchedule(ctx context.Context, arg DeleteScheduleParams) error

func (*Queries) DeleteScheduleScheduledRuns

func (q *Queries) DeleteScheduleScheduledRuns(ctx context.Context, arg DeleteScheduleScheduledRunsParams) error

Reaps a schedule's pre-created scheduled runs; must run before the schedules row is deleted, since that delete SET-NULLs runs.schedule_id.

func (*Queries) DeleteSecret

func (q *Queries) DeleteSecret(ctx context.Context, ref string) error

func (*Queries) DeleteStreamResourceCheckpoint added in v0.0.27

func (q *Queries) DeleteStreamResourceCheckpoint(ctx context.Context, arg DeleteStreamResourceCheckpointParams) error

func (*Queries) EndStreamAttempt added in v0.6.0

func (q *Queries) EndStreamAttempt(ctx context.Context, arg EndStreamAttemptParams) (int64, error)

func (*Queries) EnsureTenant

func (q *Queries) EnsureTenant(ctx context.Context, arg EnsureTenantParams) error

func (*Queries) EnsureUser added in v0.0.27

func (q *Queries) EnsureUser(ctx context.Context, arg EnsureUserParams) (string, error)

func (*Queries) FinishStoppedContinuousRun added in v0.6.0

func (q *Queries) FinishStoppedContinuousRun(ctx context.Context, arg FinishStoppedContinuousRunParams) error

func (*Queries) GetActiveReplicationStream added in v0.0.27

func (q *Queries) GetActiveReplicationStream(ctx context.Context, arg GetActiveReplicationStreamParams) (*ReplicationStream, error)

func (*Queries) GetConnection

func (q *Queries) GetConnection(ctx context.Context, arg GetConnectionParams) (*GetConnectionRow, error)

func (*Queries) GetLatestRouteAttempt added in v0.6.0

func (q *Queries) GetLatestRouteAttempt(ctx context.Context, arg GetLatestRouteAttemptParams) (*StreamAttempt, error)

func (*Queries) GetLatestStreamAttempt added in v0.6.0

func (q *Queries) GetLatestStreamAttempt(ctx context.Context, arg GetLatestStreamAttemptParams) (*StreamAttempt, error)

func (*Queries) GetNotifier added in v0.3.1

func (q *Queries) GetNotifier(ctx context.Context, arg GetNotifierParams) (*Notifier, error)

func (*Queries) GetPipeline

func (q *Queries) GetPipeline(ctx context.Context, arg GetPipelineParams) (*GetPipelineRow, error)

func (*Queries) GetPipelineVersion

func (q *Queries) GetPipelineVersion(ctx context.Context, arg GetPipelineVersionParams) (*GetPipelineVersionRow, error)

func (*Queries) GetReplicationStream added in v0.0.27

func (q *Queries) GetReplicationStream(ctx context.Context, replicationStreamID string) (*ReplicationStream, error)

func (*Queries) GetReplicationStreamPipelineID added in v0.6.0

func (q *Queries) GetReplicationStreamPipelineID(ctx context.Context, arg GetReplicationStreamPipelineIDParams) (string, error)

func (*Queries) GetStreamAttemptByExecutionID added in v0.6.0

func (q *Queries) GetStreamAttemptByExecutionID(ctx context.Context, arg GetStreamAttemptByExecutionIDParams) (*StreamAttempt, error)

func (*Queries) GetStreamEpoch added in v0.6.0

func (q *Queries) GetStreamEpoch(ctx context.Context, arg GetStreamEpochParams) (*StreamEpoch, error)

func (*Queries) GetStreamExecution added in v0.6.0

func (q *Queries) GetStreamExecution(ctx context.Context, arg GetStreamExecutionParams) (*GetStreamExecutionRow, error)

func (*Queries) InitializeStreamExecution added in v0.6.0

func (q *Queries) InitializeStreamExecution(ctx context.Context, arg InitializeStreamExecutionParams) error

func (*Queries) LatestStreamPositions added in v0.6.0

func (q *Queries) LatestStreamPositions(ctx context.Context, arg LatestStreamPositionsParams) ([]byte, error)

func (*Queries) LeaseSchedules

func (q *Queries) LeaseSchedules(ctx context.Context, arg LeaseSchedulesParams) error

func (*Queries) ListConnections

func (q *Queries) ListConnections(ctx context.Context, arg ListConnectionsParams) ([]*ListConnectionsRow, error)

func (*Queries) ListNotifiers added in v0.3.1

func (q *Queries) ListNotifiers(ctx context.Context, arg ListNotifiersParams) ([]*Notifier, error)

func (*Queries) ListPipelineVersions

func (q *Queries) ListPipelineVersions(ctx context.Context, arg ListPipelineVersionsParams) ([]*ListPipelineVersionsRow, error)

func (*Queries) ListPipelines

func (q *Queries) ListPipelines(ctx context.Context, arg ListPipelinesParams) ([]*ListPipelinesRow, error)

func (*Queries) ListReconcilableStreamIDs added in v0.6.0

func (q *Queries) ListReconcilableStreamIDs(ctx context.Context, arg ListReconcilableStreamIDsParams) ([]string, error)

func (*Queries) ListReplicationStreamResources added in v0.0.27

func (q *Queries) ListReplicationStreamResources(ctx context.Context, replicationStreamID string) ([]*ReplicationStreamResource, error)

func (*Queries) ListResourceCheckpoints

func (q *Queries) ListResourceCheckpoints(ctx context.Context, arg ListResourceCheckpointsParams) ([]*ListResourceCheckpointsRow, error)

func (*Queries) ListResources

func (q *Queries) ListResources(ctx context.Context, arg ListResourcesParams) ([]*ListResourcesRow, error)

func (*Queries) ListRetiredReplicationStreamsForRoute added in v0.0.27

func (q *Queries) ListRetiredReplicationStreamsForRoute(ctx context.Context, arg ListRetiredReplicationStreamsForRouteParams) ([]*ReplicationStream, error)

func (*Queries) ListSchedules

func (q *Queries) ListSchedules(ctx context.Context, arg ListSchedulesParams) ([]*ListSchedulesRow, error)

func (*Queries) ListStreamResourceCheckpoints added in v0.0.27

func (q *Queries) ListStreamResourceCheckpoints(ctx context.Context, replicationStreamID string) ([]*ListStreamResourceCheckpointsRow, error)

func (*Queries) ListTenants

func (q *Queries) ListTenants(ctx context.Context) ([]*ListTenantsRow, error)

func (*Queries) LoadCheckpoint

func (q *Queries) LoadCheckpoint(ctx context.Context, arg LoadCheckpointParams) ([]byte, error)

func (*Queries) LoadPipelineSchedule

func (q *Queries) LoadPipelineSchedule(ctx context.Context, arg LoadPipelineScheduleParams) (*LoadPipelineScheduleRow, error)

func (*Queries) LoadResourceCheckpoint

func (q *Queries) LoadResourceCheckpoint(ctx context.Context, arg LoadResourceCheckpointParams) (*LoadResourceCheckpointRow, error)

func (*Queries) LoadRun

func (q *Queries) LoadRun(ctx context.Context, arg LoadRunParams) (*LoadRunRow, error)

func (*Queries) LoadRunRequest added in v0.6.0

func (q *Queries) LoadRunRequest(ctx context.Context, arg LoadRunRequestParams) ([]byte, error)

func (*Queries) LoadSchedule

func (q *Queries) LoadSchedule(ctx context.Context, arg LoadScheduleParams) (*LoadScheduleRow, error)

func (*Queries) LoadStreamResourceCheckpoint added in v0.0.27

func (*Queries) LoadTenant

func (q *Queries) LoadTenant(ctx context.Context, tenantID string) (*LoadTenantRow, error)

func (*Queries) LockNotifierPipeline added in v0.3.1

func (q *Queries) LockNotifierPipeline(ctx context.Context, arg LockNotifierPipelineParams) (string, error)

func (*Queries) LockPipelineForReplicationStream added in v0.0.27

func (q *Queries) LockPipelineForReplicationStream(ctx context.Context, arg LockPipelineForReplicationStreamParams) (string, error)

func (*Queries) LockReplicationStream added in v0.0.27

func (q *Queries) LockReplicationStream(ctx context.Context, arg LockReplicationStreamParams) (string, error)

func (*Queries) LockReplicationStreamGeneration added in v0.6.0

func (q *Queries) LockReplicationStreamGeneration(ctx context.Context, arg LockReplicationStreamGenerationParams) (*ReplicationStream, error)

func (*Queries) LockRunStatus

func (q *Queries) LockRunStatus(ctx context.Context, arg LockRunStatusParams) (int16, error)

func (*Queries) MarkContinuousRunStarted added in v0.6.0

func (q *Queries) MarkContinuousRunStarted(ctx context.Context, arg MarkContinuousRunStartedParams) error

func (*Queries) MarkReplicationStreamCleaned added in v0.0.27

func (q *Queries) MarkReplicationStreamCleaned(ctx context.Context, replicationStreamID string) error

func (*Queries) NextReplicationStreamGeneration added in v0.0.27

func (q *Queries) NextReplicationStreamGeneration(ctx context.Context, arg NextReplicationStreamGenerationParams) (int64, error)

func (*Queries) Now added in v0.6.0

func (q *Queries) Now(ctx context.Context) (pgtype.Timestamptz, error)

func (*Queries) PendingContinuousRuns added in v0.6.0

func (q *Queries) PendingContinuousRuns(ctx context.Context, arg PendingContinuousRunsParams) ([]*PendingContinuousRunsRow, error)

func (*Queries) ReadSecret

func (q *Queries) ReadSecret(ctx context.Context, ref string) (*ReadSecretRow, error)

func (*Queries) ReleaseScheduleClaim

func (q *Queries) ReleaseScheduleClaim(ctx context.Context, arg ReleaseScheduleClaimParams) error

func (*Queries) RenewStreamAttempt added in v0.6.0

func (q *Queries) RenewStreamAttempt(ctx context.Context, arg RenewStreamAttemptParams) (int64, error)

func (*Queries) ReplaceStoppedActivation added in v0.6.0

func (q *Queries) ReplaceStoppedActivation(ctx context.Context, arg ReplaceStoppedActivationParams) (int64, error)

func (*Queries) ResetRunExecution

func (q *Queries) ResetRunExecution(ctx context.Context, arg ResetRunExecutionParams) error

func (*Queries) ResetRunResources

func (q *Queries) ResetRunResources(ctx context.Context, arg ResetRunResourcesParams) error

func (*Queries) ResolveTenant added in v0.0.27

func (q *Queries) ResolveTenant(ctx context.Context, arg ResolveTenantParams) (string, error)

func (*Queries) RetireReplicationStream added in v0.0.27

func (q *Queries) RetireReplicationStream(ctx context.Context, replicationStreamID string) error

func (*Queries) RetireReplicationStreamResources added in v0.0.27

func (q *Queries) RetireReplicationStreamResources(ctx context.Context, arg RetireReplicationStreamResourcesParams) error

func (*Queries) RetireUnclaimedAttempt added in v0.6.0

func (q *Queries) RetireUnclaimedAttempt(ctx context.Context, arg RetireUnclaimedAttemptParams) (int64, error)

func (*Queries) RotateSecret added in v0.26.0

func (q *Queries) RotateSecret(ctx context.Context, arg RotateSecretParams) (int64, error)

func (*Queries) SaveCheckpoint

func (q *Queries) SaveCheckpoint(ctx context.Context, arg SaveCheckpointParams) (int64, error)

func (*Queries) SaveResourceCheckpoint

func (q *Queries) SaveResourceCheckpoint(ctx context.Context, arg SaveResourceCheckpointParams) (int64, error)

func (*Queries) SaveRun

func (q *Queries) SaveRun(ctx context.Context, arg SaveRunParams) (int64, error)

func (*Queries) SaveSchedule

func (q *Queries) SaveSchedule(ctx context.Context, arg SaveScheduleParams) (int64, error)

The insert arm sources from pipelines so a save racing a pipeline delete cannot re-insert the schedule row the delete just removed; 0 rows means the pipeline is gone or deleted.

func (*Queries) SaveStreamResourceCheckpoint added in v0.0.27

func (q *Queries) SaveStreamResourceCheckpoint(ctx context.Context, arg SaveStreamResourceCheckpointParams) (int64, error)

func (*Queries) SyncContinuousRunPhase added in v0.6.0

func (q *Queries) SyncContinuousRunPhase(ctx context.Context, arg SyncContinuousRunPhaseParams) error

func (*Queries) TransitionRun

func (q *Queries) TransitionRun(ctx context.Context, arg TransitionRunParams) error

func (*Queries) UpdateConnection

func (q *Queries) UpdateConnection(ctx context.Context, arg UpdateConnectionParams) (int64, error)

func (*Queries) UpdateNotifier added in v0.3.1

func (q *Queries) UpdateNotifier(ctx context.Context, arg UpdateNotifierParams) (*Notifier, error)

func (*Queries) UpdatePipeline

func (q *Queries) UpdatePipeline(ctx context.Context, arg UpdatePipelineParams) (int64, error)

func (*Queries) UpsertReplicationStreamResource added in v0.0.27

func (q *Queries) UpsertReplicationStreamResource(ctx context.Context, arg UpsertReplicationStreamResourceParams) error

func (*Queries) UpsertResource

func (q *Queries) UpsertResource(ctx context.Context, arg UpsertResourceParams) (int64, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

func (*Queries) WriteSecret

func (q *Queries) WriteSecret(ctx context.Context, arg WriteSecretParams) error

type ReadSecretRow

type ReadSecretRow struct {
	Ciphertext []byte
	Nonce      []byte
	Metadata   []byte
}

type ReleaseScheduleClaimParams added in v0.0.27

type ReleaseScheduleClaimParams struct {
	TenantID   string
	ScheduleID string
}

type RenewStreamAttemptParams added in v0.6.0

type RenewStreamAttemptParams struct {
	TtlUs    int64
	Token    int64
	TenantID string
}

type ReplaceStoppedActivationParams added in v0.6.0

type ReplaceStoppedActivationParams struct {
	RunID    pgtype.Text
	RunSpec  []byte
	StreamID string
	TenantID string
}

type ReplicationStream added in v0.0.27

type ReplicationStream struct {
	ID                           string
	TenantID                     string
	PipelineID                   string
	RouteKey                     string
	Generation                   int64
	SourceConnectionID           string
	SinkConnectionID             string
	ConsumerName                 string
	ConsumerConfig               []byte
	ContinuityFingerprint        string
	Status                       int16
	CreatedFromPipelineVersionID string
	Error                        pgtype.Text
	RetiredAt                    pgtype.Timestamptz
	CreatedByUserID              pgtype.Text
	UpdatedByUserID              pgtype.Text
	DeletedByUserID              pgtype.Text
	CreatedAt                    pgtype.Timestamptz
	UpdatedAt                    pgtype.Timestamptz
	MembershipRevision           int64
	CurrentRunID                 pgtype.Text
	DesiredState                 string
	DesiredRevision              int64
	RunSpec                      []byte
	LastEpoch                    int64
}

type ReplicationStreamResource added in v0.0.27

type ReplicationStreamResource struct {
	ID                  string
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
	Status              int16
	BootstrapMode       string
	BootstrapConfig     []byte
	SchemaFingerprint   pgtype.Text
	BootstrapRunID      pgtype.Text
	BootstrapStartedAt  pgtype.Timestamptz
	ActivatedAt         pgtype.Timestamptz
	RetiredAt           pgtype.Timestamptz
	Error               pgtype.Text
	CreatedByUserID     pgtype.Text
	UpdatedByUserID     pgtype.Text
	DeletedByUserID     pgtype.Text
	CreatedAt           pgtype.Timestamptz
	UpdatedAt           pgtype.Timestamptz
}

type ResetRunExecutionParams

type ResetRunExecutionParams struct {
	Status           int16
	PreserveProgress bool
	TenantID         string
	RunID            string
}

type ResetRunResourcesParams

type ResetRunResourcesParams struct {
	Status           int16
	PreserveProgress bool
	TenantID         string
	RunID            string
}

type ResolveTenantParams added in v0.0.27

type ResolveTenantParams struct {
	ExternalID string
	Name       string
}

type RetireReplicationStreamResourcesParams added in v0.0.27

type RetireReplicationStreamResourcesParams struct {
	ReplicationStreamID string
	ResourceNames       []string
}

type RetireUnclaimedAttemptParams added in v0.6.0

type RetireUnclaimedAttemptParams struct {
	Token    int64
	TenantID string
}

type RotateSecretParams added in v0.26.0

type RotateSecretParams struct {
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	Metadata   []byte
	TenantID   string
	Ref        string
}

type Run

type Run struct {
	ID                string
	TenantID          string
	PipelineID        pgtype.Text
	PipelineVersionID pgtype.Text
	ScheduleID        pgtype.Text
	Status            int16
	Request           []byte
	Records           int64
	Bytes             int64
	CpuSeconds        float64
	MemoryPeakBytes   int64
	ScheduledAt       pgtype.Timestamptz
	RequestedAt       pgtype.Timestamptz
	StartedAt         pgtype.Timestamptz
	EndedAt           pgtype.Timestamptz
	Error             pgtype.Text
	CreatedByUserID   pgtype.Text
	UpdatedByUserID   pgtype.Text
	DeletedByUserID   pgtype.Text
	CreatedAt         pgtype.Timestamptz
	UpdatedAt         pgtype.Timestamptz
	LastCommittedAt   pgtype.Timestamptz
}

type RunDedupSeen

type RunDedupSeen struct {
	ID              string
	TenantID        string
	RunID           string
	LastSeq         int64
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type RunResourceCheckpoint

type RunResourceCheckpoint struct {
	ID              string
	TenantID        string
	RunID           string
	ResourceName    string
	Cursor          []byte
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type RunResourceState

type RunResourceState struct {
	ID              string
	RunID           string
	ResourceName    string
	TenantID        string
	Status          int16
	Records         int64
	Bytes           int64
	Error           pgtype.Text
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type SaveCheckpointParams

type SaveCheckpointParams struct {
	RunID        string
	ResourceName string
	Cursor       []byte
	TenantID     string
}

type SaveResourceCheckpointParams

type SaveResourceCheckpointParams struct {
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	ResourceName      string
	Cursor            []byte
	LastRunID         string
	TenantID          string
}

type SaveRunParams

type SaveRunParams struct {
	RunID             string
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	ScheduleID        string
	Status            int16
	Request           []byte
	Records           int64
	Bytes             int64
	ScheduledAt       pgtype.Timestamptz
	RequestedAt       pgtype.Timestamptz
	StartedAt         pgtype.Timestamptz
	EndedAt           pgtype.Timestamptz
	Error             string
	CpuSeconds        float64
	MemoryPeakBytes   int64
}

type SaveScheduleParams

type SaveScheduleParams struct {
	ScheduleID    string
	TenantID      string
	PipelineID    string
	Name          pgtype.Text
	CronExpr      string
	Timezone      string
	OverlapPolicy int16
	Enabled       bool
	LastFiredAt   pgtype.Timestamptz
	NextFireAt    pgtype.Timestamptz
	CreatedAt     pgtype.Timestamptz
}

type SaveStreamResourceCheckpointParams added in v0.0.27

type SaveStreamResourceCheckpointParams struct {
	PipelineID          string
	PipelineVersionID   string
	RouteKey            string
	ResourceName        string
	Cursor              []byte
	LastRunID           string
	ReplicationStreamID string
	TenantID            string
}

type Schedule

type Schedule struct {
	ID              string
	TenantID        string
	PipelineID      string
	Name            pgtype.Text
	CronExpr        string
	Timezone        string
	OverlapPolicy   int16
	Enabled         bool
	LastFiredAt     pgtype.Timestamptz
	NextFireAt      pgtype.Timestamptz
	ClaimedAt       pgtype.Timestamptz
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type Secret

type Secret struct {
	ID              string
	TenantID        string
	Ref             string
	Ciphertext      []byte
	Nonce           []byte
	KeyID           string
	Metadata        []byte
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type StreamAttempt added in v0.6.0

type StreamAttempt struct {
	Token           int64
	StreamID        string
	TenantID        string
	ExecutionID     string
	DesiredRevision int64
	RequestTtlUs    int64
	StartedAt       pgtype.Timestamptz
	ClaimedAt       pgtype.Timestamptz
	RunSpec         []byte
	ExpiresAt       pgtype.Timestamptz
	EndedAt         pgtype.Timestamptz
	Termination     pgtype.Text
	Reason          string
}

type StreamEpoch added in v0.6.0

type StreamEpoch struct {
	StreamID     string
	TenantID     string
	Epoch        int64
	AttemptToken int64
	Certificate  []byte
	Positions    []byte
	CommittedAt  pgtype.Timestamptz
}

type SyncContinuousRunPhaseParams added in v0.6.0

type SyncContinuousRunPhaseParams struct {
	StreamID string
	TenantID string
}

type Tenant

type Tenant struct {
	ID              string
	Name            pgtype.Text
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
	ExternalID      pgtype.Text
}

type TransitionRunParams

type TransitionRunParams struct {
	Status     int16
	StampEnded bool
	TenantID   string
	RunID      string
}

type UpdateConnectionParams

type UpdateConnectionParams struct {
	Name            string
	Connector       string
	Config          []byte
	SecretRefs      []byte
	TenantID        string
	ConnectionID    string
	ExpectedVersion int64
}

type UpdateNotifierParams added in v0.3.1

type UpdateNotifierParams struct {
	Name            string
	IsEnabled       bool
	Events          []byte
	Resources       []byte
	Config          []byte
	SecretRefs      []byte
	UpdatedByUserID pgtype.Text
	TenantID        string
	PipelineID      string
	NotifierID      string
}

type UpdatePipelineParams

type UpdatePipelineParams struct {
	Name                string
	Description         string
	ExecutionMode       int32
	WorkerConfiguration []byte
	TenantID            string
	PipelineID          string
}

type UpsertReplicationStreamResourceParams added in v0.0.27

type UpsertReplicationStreamResourceParams struct {
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
	BootstrapMode       string
	BootstrapConfig     []byte
}

type UpsertResourceParams

type UpsertResourceParams struct {
	RunID        string
	ResourceName string
	TenantID     string
	Status       int16
	Records      int64
	Bytes        int64
	Error        string
}

type User

type User struct {
	ID              string
	TenantID        string
	ExternalID      string
	CreatedByUserID pgtype.Text
	UpdatedByUserID pgtype.Text
	DeletedByUserID pgtype.Text
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type WriteSecretParams

type WriteSecretParams struct {
	TenantID   string
	Ref        string
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	Metadata   []byte
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL