sqlcgen

type ActivateStreamResourceForCheckpointParams struct {
	LastRunID   sql.NullString
	ActivatedAt sql.NullInt64
	UpdatedAt   int64
	ResourceID  string
	TenantID    string
}

type AdvanceDedupSeenParams struct {
	TenantID  string
	RunID     string
	Seq       int64
	CreatedAt int64
	UpdatedAt 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         sql.NullInt64
	LeaseCutoff sql.NullInt64
	Lim         int64
}

type ClaimDueRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          sql.NullString
	CronExpr      string
	Timezone      string
	OverlapPolicy int64
	Enabled       int64
	LastFiredAt   sql.NullInt64
	NextFireAt    sql.NullInt64
	CreatedAt     int64
}

type Connection struct {
	ID              string
	TenantID        string
	Kind            string
	Name            string
	Connector       string
	Config          string
	SecretRefs      string
	Version         int64
	IsDeleted       int64
	DeletedAt       sql.NullInt64
	CreatedByUserID sql.NullString
	UpdatedByUserID sql.NullString
	DeletedByUserID sql.NullString
	CreatedAt       int64
	UpdatedAt       int64
}

type CountConnectionsParams struct {
	TenantID        string
	Kind            string
	KindFilter      string
	IncludeDeleted  bool
	Search          string
	NameSearch      string
	ConnectorSearch string
}

type CountPipelineVersionsParams struct {
	TenantID   string
	PipelineID string
}

type CountPipelinesParams struct {
	TenantID          string
	IncludeDeleted    bool
	Search            string
	NameSearch        string
	DescriptionSearch string
}

type CreateConnectionParams struct {
	ConnectionID string
	TenantID     string
	Kind         string
	Name         string
	Connector    string
	Config       string
	SecretRefs   string
	CreatedAt    int64
	UpdatedAt    int64
}

type CreateNotifierParams struct {
	NotifierID       string
	TenantID         string
	PipelineID       string
	Name             string
	NotificationType string
	IsEnabled        int64
	Events           string
	Resources        string
	Config           string
	SecretRefs       string
	CreatedByUserID  sql.NullString
	UpdatedByUserID  sql.NullString
	CreatedAt        int64
	UpdatedAt        int64
}

type CreatePipelineParams struct {
	PipelineID          string
	TenantID            string
	Name                string
	Description         string
	ExecutionMode       interface{}
	WorkerConfiguration interface{}
	CreatedAt           int64
	UpdatedAt           int64
}

type CreateReplicationStreamParams struct {
	ReplicationStreamID          string
	TenantID                     string
	PipelineID                   string
	RouteKey                     string
	Generation                   int64
	SourceConnectionID           string
	SinkConnectionID             string
	ConsumerName                 string
	ConsumerConfig               string
	ContinuityFingerprint        string
	CreatedFromPipelineVersionID string
	CreatedAt                    int64
	UpdatedAt                    int64
}

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    string
}

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteConflictingStreamResourceCheckpointParams struct {
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	ResourceName      string
	ResourceID        sql.NullString
}

type DeleteConnectionParams struct {
	DeleteStamp  string
	DeletedAt    sql.NullInt64
	UpdatedAt    int64
	TenantID     string
	ConnectionID string
}

type DeleteNotifierParams struct {
	DeletedAt  sql.NullInt64
	UpdatedAt  int64
	TenantID   string
	PipelineID string
	NotifierID string
}

type DeletePipelineNotifiersParams struct {
	DeletedAt  sql.NullInt64
	UpdatedAt  int64
	TenantID   string
	PipelineID string
}

type DeletePipelineParams struct {
	DeletedAt   sql.NullInt64
	DeleteStamp string
	UpdatedAt   int64
	TenantID    string
	PipelineID  string
}

type DeletePipelineScheduledRunsParams struct {
	TenantID   string
	PipelineID sql.NullString
	Status     int64
}

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 sql.NullString
	Status     int64
}

type DeleteStreamResourceCheckpointParams struct {
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
}

type EndStreamAttemptParams struct {
	Termination sql.NullString
	Reason      string
	Token       int64
	TenantID    string
	RequireLive bool
}

type EnsureTenantParams struct {
	TenantID  string
	Name      interface{}
	CreatedAt int64
	UpdatedAt int64
}

type EnsureUserParams struct {
	UserID     string
	TenantID   string
	ExternalID string
	CreatedAt  int64
	UpdatedAt  int64
}

type GetActiveReplicationStreamParams struct {
	PipelineID string
	RouteKey   string
}

type GetConnectionParams struct {
	TenantID     string
	ConnectionID string
}

type GetConnectionRow struct {
	ID              string
	TenantID        string
	Kind            string
	Name            string
	Connector       string
	Config          string
	SecretRefs      string
	Version         int64
	CreatedAt       int64
	UpdatedAt       int64
	DeletedAt       sql.NullInt64
	CreatedByUserID string
	UpdatedByUserID string
	DeletedByUserID string
}

type GetCurrentPipelineVersionIDParams struct {
	TenantID   string
	PipelineID string
}

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    sql.NullString
	ExecutionMode       int64
	WorkerConfiguration string
	CreatedAt           int64
	UpdatedAt           int64
	DeletedAt           sql.NullInt64
	CreatedByUserID     string
	UpdatedByUserID     string
	DeletedByUserID     string
}

type GetPipelineVersionByIDParams struct {
	TenantID   string
	PipelineID string
	VersionID  string
}

type GetPipelineVersionByIDRow struct {
	ID              string
	PipelineID      string
	Version         int64
	Graph           string
	CreatedAt       int64
	UpdatedAt       int64
	CreatedByUserID string
	UpdatedByUserID string
	DeletedByUserID string
}

type GetPipelineVersionByNumberParams struct {
	TenantID   string
	PipelineID string
	Version    int64
}

type GetPipelineVersionByNumberRow struct {
	ID              string
	PipelineID      string
	Version         int64
	Graph           string
	CreatedAt       int64
	UpdatedAt       int64
	CreatedByUserID string
	UpdatedByUserID string
	DeletedByUserID string
}

type GetReplicationStreamPipelineIDParams struct {
	StreamID   string
	TenantID   string
	Generation int64
}

type GetRunStatusParams struct {
	TenantID string
	RunID    string
}

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           sql.NullString
	LastEpoch         int64
}

type GetStreamResourceForCheckpointParams struct {
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
}

type InitializeStreamExecutionParams struct {
	RunID    sql.NullString
	RunSpec  sql.NullString
	StreamID string
	TenantID string
}

type InsertPipelineVersionParams struct {
	VersionID         string
	PipelineID        string
	Version           int64
	Graph             string
	CreatedAt         int64
	UpdatedAt         int64
	TenantID          string
	VersionPipelineID string
}

type InsertPipelineVersionRow struct {
	ID        string
	Version   int64
	CreatedAt int64
}

type InsertRunParams struct {
	RunID             string
	TenantID          string
	PipelineID        interface{}
	PipelineVersionID interface{}
	ScheduleID        interface{}
	Status            int64
	Request           string
	Records           int64
	Bytes             int64
	ScheduledAt       sql.NullInt64
	RequestedAt       sql.NullInt64
	StartedAt         sql.NullInt64
	EndedAt           sql.NullInt64
	Error             interface{}
	CpuSeconds        float64
	MemoryPeakBytes   int64
	CreatedAt         int64
	UpdatedAt         int64
}

type LatestStreamPositionsParams struct {
	StreamID string
	TenantID string
}

type LeaseScheduleParams struct {
	ClaimedAt  sql.NullInt64
	ScheduleID string
}

type ListNotifiersParams struct {
	TenantID       string
	PipelineID     string
	IncludeDeleted bool
}

type ListReconcilableStreamIDsParams struct {
	TenantID  string
	AfterID   string
	PageLimit int64
}

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

type ListResourceCheckpointsRow struct {
	ResourceName string
	Cursor       string
	LastRunID    string
	UpdatedAt    int64
}

type ListResourcesParams struct {
	TenantID string
	RunID    string
}

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

type ListRetiredReplicationStreamsForRouteParams struct {
	PipelineID string
	RouteKey   string
}

type ListSchedulesParams struct {
	TenantID      string
	FilterEnabled int64
	Enabled       int64
	Lim           int64
}

type ListSchedulesRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          sql.NullString
	CronExpr      string
	Timezone      string
	OverlapPolicy int64
	Enabled       int64
	LastFiredAt   sql.NullInt64
	NextFireAt    sql.NullInt64
	CreatedAt     int64
}

type ListStreamResourceCheckpointsRow struct {
	ResourceName string
	Cursor       string
	LastRunID    string
	UpdatedAt    int64
}

type ListTenantsRow struct {
	ID        string
	Name      string
	CreatedAt int64
	UpdatedAt int64
}

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          sql.NullString
	CronExpr      string
	Timezone      string
	OverlapPolicy int64
	Enabled       int64
	LastFiredAt   sql.NullInt64
	NextFireAt    sql.NullInt64
	CreatedAt     int64
}

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

type LoadResourceCheckpointRow struct {
	Cursor    string
	LastRunID string
	UpdatedAt int64
}

type LoadRunParams struct {
	TenantID string
	RunID    string
}

type LoadRunRequestParams struct {
	RunID             string
	TenantID          string
	PipelineID        sql.NullString
	PipelineVersionID sql.NullString
}

type LoadRunRow struct {
	ID              string
	TenantID        string
	ScheduleID      string
	Status          int64
	Request         string
	Records         int64
	Bytes           int64
	CreatedAt       int64
	ScheduledAt     sql.NullInt64
	RequestedAt     sql.NullInt64
	StartedAt       sql.NullInt64
	EndedAt         sql.NullInt64
	UpdatedAt       int64
	Error           string
	CpuSeconds      float64
	MemoryPeakBytes int64
}

type LoadScheduleParams struct {
	TenantID   string
	ScheduleID string
}

type LoadScheduleRow struct {
	ID            string
	TenantID      string
	PipelineID    string
	Name          sql.NullString
	CronExpr      string
	Timezone      string
	OverlapPolicy int64
	Enabled       int64
	LastFiredAt   sql.NullInt64
	NextFireAt    sql.NullInt64
	CreatedAt     int64
}

type LoadStreamResourceCheckpointParams struct {
	ReplicationStreamID string
	ResourceName        string
}

type LoadStreamResourceCheckpointRow struct {
	Cursor    string
	LastRunID string
	UpdatedAt int64
}

type LoadTenantRow struct {
	ID        string
	Name      string
	CreatedAt int64
	UpdatedAt int64
}

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 MarkReplicationStreamCleanedParams struct {
	UpdatedAt           int64
	ReplicationStreamID string
}

type NextPipelineVersionParams struct {
	TenantID   string
	PipelineID string
}

type NextReplicationStreamGenerationParams struct {
	PipelineID string
	RouteKey   string
}

type Notifier struct {
	ID               string
	TenantID         string
	PipelineID       string
	Name             string
	NotificationType string
	IsEnabled        int64
	Events           string
	Resources        string
	Config           string
	SecretRefs       string
	IsDeleted        int64
	DeletedAt        sql.NullInt64
	CreatedByUserID  sql.NullString
	UpdatedByUserID  sql.NullString
	DeletedByUserID  sql.NullString
	CreatedAt        int64
	UpdatedAt        int64
}

type Pipeline struct {
	ID                  string
	TenantID            string
	Name                string
	Description         string
	CurrentVersionID    sql.NullString
	WorkerConfiguration string
	IsDeleted           int64
	DeletedAt           sql.NullInt64
	CreatedByUserID     sql.NullString
	UpdatedByUserID     sql.NullString
	DeletedByUserID     sql.NullString
	CreatedAt           int64
	UpdatedAt           int64
	ExecutionMode       int64
}

type PipelineResourceCheckpoint struct {
	TenantID                    string
	PipelineID                  string
	PipelineVersionID           string
	RouteKey                    string
	ResourceName                string
	Cursor                      string
	LastRunID                   string
	CreatedAt                   int64
	UpdatedAt                   int64
	ReplicationStreamResourceID sql.NullString
}

type PipelineVersion struct {
	ID              string
	TenantID        string
	PipelineID      string
	Version         int64
	Graph           string
	CreatedByUserID sql.NullString
	UpdatedByUserID sql.NullString
	DeletedByUserID sql.NullString
	CreatedAt       int64
	UpdatedAt       int64
}

type PromoteScheduledRunParams struct {
	PipelineID        interface{}
	PipelineVersionID interface{}
	ScheduleID        interface{}
	Status            int64
	Request           string
	Records           int64
	Bytes             int64
	ScheduledAt       sql.NullInt64
	RequestedAt       sql.NullInt64
	StartedAt         sql.NullInt64
	EndedAt           sql.NullInt64
	Error             interface{}
	CpuSeconds        float64
	MemoryPeakBytes   int64
	UpdatedAt         int64
	TenantID          string
	RunID             string
	FromStatus        int64
}

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

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

type ReleaseScheduleClaimParams struct {
	UpdatedAt  int64
	TenantID   string
	ScheduleID string
}

type RenewStreamAttemptParams struct {
	TtlUs    int64
	Token    int64
	TenantID string
}

type ReplicationStream struct {
	ID                           string
	TenantID                     string
	PipelineID                   string
	RouteKey                     string
	Generation                   int64
	SourceConnectionID           string
	SinkConnectionID             string
	ConsumerName                 string
	ConsumerConfig               string
	ContinuityFingerprint        string
	Status                       int64
	CreatedFromPipelineVersionID string
	Error                        sql.NullString
	RetiredAt                    sql.NullInt64
	CreatedByUserID              sql.NullString
	UpdatedByUserID              sql.NullString
	DeletedByUserID              sql.NullString
	CreatedAt                    int64
	UpdatedAt                    int64
	MembershipRevision           int64
	CurrentRunID                 sql.NullString
	DesiredState                 string
	DesiredRevision              int64
	RunSpec                      sql.NullString
	LastEpoch                    int64
}

type ReplicationStreamResource struct {
	ID                  string
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
	Status              int64
	BootstrapMode       string
	BootstrapConfig     string
	SchemaFingerprint   sql.NullString
	BootstrapRunID      sql.NullString
	BootstrapStartedAt  sql.NullInt64
	ActivatedAt         sql.NullInt64
	RetiredAt           sql.NullInt64
	Error               sql.NullString
	CreatedByUserID     sql.NullString
	UpdatedByUserID     sql.NullString
	DeletedByUserID     sql.NullString
	CreatedAt           int64
	UpdatedAt           int64
}

type ResetRunExecutionParams struct {
	Status           int64
	PreserveProgress bool
	RequestedAt      sql.NullInt64
	UpdatedAt        int64
	TenantID         string
	RunID            string
}

type ResetRunResourcesParams struct {
	Status           int64
	PreserveProgress bool
	UpdatedAt        int64
	TenantID         string
	RunID            string
}

type ResetStreamResourceForCheckpointParams struct {
	UpdatedAt  int64
	ResourceID string
	TenantID   string
}

type ResolveTenantParams struct {
	TenantID   string
	ExternalID sql.NullString
	Name       interface{}
	CreatedAt  int64
	UpdatedAt  int64
}

type RetireReplicationStreamParams struct {
	RetiredAt           sql.NullInt64
	UpdatedAt           int64
	ReplicationStreamID string
}

type RetireReplicationStreamResourcesParams struct {
	RetiredAt           sql.NullInt64
	UpdatedAt           int64
	ReplicationStreamID string
	ResourceNames       string
}

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

type Run struct {
	ID                string
	TenantID          string
	PipelineID        sql.NullString
	PipelineVersionID sql.NullString
	ScheduleID        sql.NullString
	Status            int64
	Request           string
	Records           int64
	Bytes             int64
	CpuSeconds        float64
	MemoryPeakBytes   int64
	ScheduledAt       sql.NullInt64
	RequestedAt       sql.NullInt64
	StartedAt         sql.NullInt64
	EndedAt           sql.NullInt64
	Error             sql.NullString
	CreatedByUserID   sql.NullString
	UpdatedByUserID   sql.NullString
	DeletedByUserID   sql.NullString
	CreatedAt         int64
	UpdatedAt         int64
}

type RunDedupSeen struct {
	TenantID  string
	RunID     string
	LastSeq   int64
	CreatedAt int64
	UpdatedAt int64
}

type RunResourceCheckpoint struct {
	TenantID     string
	RunID        string
	ResourceName string
	Cursor       string
	CreatedAt    int64
	UpdatedAt    int64
}

type RunResourceState struct {
	RunID        string
	ResourceName string
	TenantID     string
	Status       int64
	Records      int64
	Bytes        int64
	Error        sql.NullString
	CreatedAt    int64
	UpdatedAt    int64
}

type SaveCheckpointParams struct {
	RunID           string
	ResourceName    string
	Cursor          string
	CreatedAt       int64
	UpdatedAt       int64
	TenantID        string
	CheckpointRunID string
}

type SaveResourceCheckpointParams struct {
	TenantID          string
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	ResourceName      string
	Cursor            string
	LastRunID         string
	CreatedAt         int64
	UpdatedAt         int64
}

type SaveRunParams struct {
	RunID             string
	TenantID          string
	PipelineID        interface{}
	PipelineVersionID interface{}
	ScheduleID        interface{}
	Status            int64
	Request           string
	Records           int64
	Bytes             int64
	ScheduledAt       sql.NullInt64
	RequestedAt       sql.NullInt64
	StartedAt         sql.NullInt64
	EndedAt           sql.NullInt64
	Error             interface{}
	CpuSeconds        float64
	MemoryPeakBytes   int64
	CreatedAt         int64
	UpdatedAt         int64
}

type SaveScheduleParams struct {
	ScheduleID         string
	TenantID           string
	PipelineID         string
	Name               sql.NullString
	CronExpr           string
	Timezone           string
	OverlapPolicy      int64
	Enabled            int64
	LastFiredAt        sql.NullInt64
	NextFireAt         sql.NullInt64
	CreatedAt          int64
	UpdatedAt          int64
	PipelineTenantID   string
	SchedulePipelineID string
}

type SaveStreamResourceCheckpointParams struct {
	PipelineID        string
	PipelineVersionID string
	RouteKey          string
	Cursor            string
	LastRunID         string
	CreatedAt         int64
	UpdatedAt         int64
	ResourceID        string
	TenantID          string
}

type Schedule struct {
	ID              string
	TenantID        string
	PipelineID      string
	Name            sql.NullString
	CronExpr        string
	Timezone        string
	OverlapPolicy   int64
	Enabled         int64
	LastFiredAt     sql.NullInt64
	NextFireAt      sql.NullInt64
	ClaimedAt       sql.NullInt64
	CreatedByUserID sql.NullString
	UpdatedByUserID sql.NullString
	DeletedByUserID sql.NullString
	CreatedAt       int64
	UpdatedAt       int64
}

type Secret struct {
	TenantID   string
	Ref        string
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	Metadata   string
	CreatedAt  int64
	UpdatedAt  int64
}

type SetCurrentPipelineVersionParams struct {
	VersionID  sql.NullString
	UpdatedAt  int64
	TenantID   string
	PipelineID string
}

type StreamAttempt struct {
	Token           int64
	StreamID        string
	TenantID        string
	ExecutionID     string
	DesiredRevision int64
	RequestTtlUs    int64
	StartedAt       int64
	ClaimedAt       sql.NullInt64
	RunSpec         string
	ExpiresAt       int64
	EndedAt         sql.NullInt64
	Termination     sql.NullString
	Reason          string
}

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

type Tenant struct {
	ID              string
	ExternalID      sql.NullString
	Name            sql.NullString
	CreatedByUserID sql.NullString
	UpdatedByUserID sql.NullString
	DeletedByUserID sql.NullString
	CreatedAt       int64
	UpdatedAt       int64
}

type TransitionRunParams struct {
	Status     int64
	StampEnded bool
	EndedNow   sql.NullInt64
	UpdatedAt  int64
	TenantID   string
	RunID      string
}

type UpdateConnectionParams struct {
	Name            string
	Connector       string
	Config          string
	SecretRefs      string
	UpdatedAt       int64
	TenantID        string
	ConnectionID    string
	ExpectedVersion int64
}

type UpdateNotifierParams struct {
	Name            string
	IsEnabled       int64
	Events          string
	Resources       string
	Config          string
	SecretRefs      string
	UpdatedAt       int64
	UpdatedByUserID sql.NullString
	TenantID        string
	PipelineID      string
	NotifierID      string
}

type UpdatePipelineParams struct {
	Name                string
	Description         string
	ExecutionMode       interface{}
	WorkerConfiguration interface{}
	UpdatedAt           int64
	TenantID            string
	PipelineID          string
}

type UpsertReplicationStreamResourceParams struct {
	ResourceID          string
	ReplicationStreamID string
	TenantID            string
	ResourceName        string
	BootstrapMode       string
	BootstrapConfig     string
	CreatedAt           int64
	UpdatedAt           int64
}

type UpsertResourceParams struct {
	RunID        string
	ResourceName string
	TenantID     string
	Status       int64
	Records      int64
	Bytes        int64
	Error        interface{}
	CreatedAt    int64
	UpdatedAt    int64
	RunTenantID  string
	StateRunID   string
}

type User struct {
	ID              string
	TenantID        string
	ExternalID      string
	CreatedByUserID sql.NullString
	UpdatedByUserID sql.NullString
	DeletedByUserID sql.NullString
	CreatedAt       int64
	UpdatedAt       int64
}

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