sqlcgen

type ActivateStreamResourceParams struct {
	StreamID     string
	TenantID     string
	ResourceName string
}

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

type AdvanceDedupSeenParams struct {
	TenantID string
	RunID    string
	Seq      int64
}

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

type BumpReplicationStreamMembershipRevisionParams struct {
	ReplicationStreamID string
	TenantID            string
}

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

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

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 struct {
	Token       int64
	TenantID    string
	ExecutionID string
	RunID       pgtype.Text
}

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 string

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

type CountPipelineVersionsParams struct {
	TenantID   string
	PipelineID string
}

type CountPipelinesParams struct {
	TenantID       string
	IncludeDeleted bool
	Search         string
}

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

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 struct {
	PipelineID          string
	TenantID            string
	Name                string
	Description         string
	ExecutionMode       int32
	WorkerConfiguration []byte
}

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

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

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 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 struct {
	StreamID        string
	TenantID        string
	ExecutionID     string
	DesiredRevision int64
	TtlUs           int64
}

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

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

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 struct {
	TenantID     string
	ConnectionID string
}

type DeleteNotifierParams struct {
	TenantID   string
	PipelineID string
	NotifierID string
}

type DeletePipelineNotifiersParams struct {
	TenantID   string
	PipelineID string
}

type DeletePipelineParams struct {
	TenantID   string
	PipelineID string
}

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

type DeletePipelineSchedulesParams struct {
	TenantID   string
	PipelineID string
}

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

type DeleteRunParams struct {
	TenantID string
	RunID    string
}

type DeleteScheduleParams struct {
	TenantID   string
	ScheduleID string
}

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

type DeleteStreamResourceCheckpointParams struct {
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
}

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

type EnsureTenantParams struct {
	TenantID string
	Name     string
}

type EnsureUserParams struct {
	TenantID   string
	ExternalID string
}

type FinishStoppedContinuousRunParams struct {
	StreamID string
	TenantID string
}

type GetActiveReplicationStreamParams struct {
	PipelineID string
	RouteKey   string
}

type GetConnectionParams struct {
	TenantID     string
	ConnectionID string
}

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 struct {
	PipelineID string
	Route      string
	TenantID   string
}

type GetLatestStreamAttemptParams struct {
	StreamID string
	TenantID string
}

type GetNotifierParams struct {
	TenantID   string
	PipelineID string
	NotifierID string
}

type GetPipelineParams struct {
	TenantID   string
	PipelineID string
}

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 struct {
	PipelineID string
	TenantID   string
	Version    int64
}

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 struct {
	StreamID   string
	TenantID   string
	Generation int64
}

type GetStreamAttemptByExecutionIDParams struct {
	TenantID    string
	ExecutionID string
}

type GetStreamEpochParams struct {
	StreamID string
	TenantID string
	Epoch    int64
}

type GetStreamExecutionParams struct {
	StreamID string
	TenantID string
}

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

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

type LatestStreamPositionsParams struct {
	StreamID string
	TenantID string
}

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

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

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 struct {
	TenantID       string
	PipelineID     string
	IncludeDeleted bool
}

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

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 struct {
	TenantID       string
	IncludeDeleted bool
	Search         string
	SortBy         string
	SortDesc       bool
	OffsetRows     int32
	Lim            int32
}

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 struct {
	TenantID  string
	AfterID   string
	PageLimit int32
}

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

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

type ListResourcesParams struct {
	TenantID string
	RunID    string
}

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

type ListRetiredReplicationStreamsForRouteParams struct {
	PipelineID string
	RouteKey   string
}

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

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 struct {
	ResourceName string
	Cursor       []byte
	LastRunID    string
	UpdatedAt    pgtype.Timestamptz
}

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

type LoadCheckpointParams struct {
	TenantID     string
	RunID        string
	ResourceName string
}

type LoadPipelineScheduleParams struct {
	TenantID   string
	PipelineID string
}

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 struct {
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	ResourceName      string
}

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

type LoadRunParams struct {
	TenantID string
	RunID    string
}

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

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 struct {
	TenantID   string
	ScheduleID string
}

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 struct {
	ReplicationStreamID string
	ResourceName        string
}

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

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

type LockNotifierPipelineParams struct {
	TenantID   string
	PipelineID string
}

type LockPipelineForReplicationStreamParams struct {
	PipelineID string
	TenantID   string
}

type LockReplicationStreamGenerationParams struct {
	StreamID   string
	TenantID   string
	Generation int64
}

type LockReplicationStreamParams struct {
	ReplicationStreamID string
	TenantID            string
}

type LockRunStatusParams struct {
	TenantID string
	RunID    string
}

type MarkContinuousRunStartedParams struct {
	RunID    string
	TenantID string
}

type NextReplicationStreamGenerationParams struct {
	PipelineID string
	RouteKey   string
}

type NotificationType string

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 struct {
	ConnectorKind ConnectorKind
	Valid         bool // Valid is true if ConnectorKind is not NULL
}

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

type PendingContinuousRunsParams struct {
	AfterID   string
	PageLimit int32
}

type PendingContinuousRunsRow struct {
	ID       string
	TenantID string
}

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 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 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 struct {
	// contains filtered or unexported fields
}

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

type ReleaseScheduleClaimParams struct {
	TenantID   string
	ScheduleID string
}

type RenewStreamAttemptParams struct {
	TtlUs    int64
	Token    int64
	TenantID string
}

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

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 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 struct {
	Status           int16
	PreserveProgress bool
	TenantID         string
	RunID            string
}

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

type ResolveTenantParams struct {
	ExternalID string
	Name       string
}

type RetireReplicationStreamResourcesParams struct {
	ReplicationStreamID string
	ResourceNames       []string
}

type RetireUnclaimedAttemptParams struct {
	Token    int64
	TenantID string
}

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

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 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 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 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 struct {
	RunID        string
	ResourceName string
	Cursor       []byte
	TenantID     string
}

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

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 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 struct {
	PipelineID          string
	PipelineVersionID   string
	RouteKey            string
	ResourceName        string
	Cursor              []byte
	LastRunID           string
	ReplicationStreamID string
	TenantID            string
}

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 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 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 struct {
	StreamID     string
	TenantID     string
	Epoch        int64
	AttemptToken int64
	Certificate  []byte
	Positions    []byte
	CommittedAt  pgtype.Timestamptz
}

type SyncContinuousRunPhaseParams struct {
	StreamID string
	TenantID string
}

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 struct {
	Status     int16
	StampEnded bool
	TenantID   string
	RunID      string
}

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

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 struct {
	Name                string
	Description         string
	ExecutionMode       int32
	WorkerConfiguration []byte
	TenantID            string
	PipelineID          string
}

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

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

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 struct {
	TenantID   string
	Ref        string
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	Metadata   []byte
}