dbsqlc

type ClientCreateOrSetUpdatedAtParams struct {
	ID        string
	Metadata  string
	PausedAt  *time.Time
	UpdatedAt *time.Time
}

type ClientQueueCreateOrSetUpdatedAtManyParams struct {
	Metadata      string
	Name          []string
	PausedAt      *time.Time
	RiverClientID string
	UpdatedAt     *time.Time
}

type ColumnExistsParams struct {
	TableName  string
	ColumnName 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 IndexExistsParams struct {
	Index  string
	Schema sql.NullString
}

type IndexesExistParams struct {
	Schema     sql.NullString
	IndexNames []string
}

type IndexesExistRow struct {
	IndexName string
	Exists    bool
}

type JobCancelParams struct {
	ID                int64
	Schema            sql.NullString
	ControlTopic      string
	Now               *time.Time
	CancelAttemptedAt string
}

type JobCountByAllStatesRow struct {
	State RiverJobState
	Count int64
}

type JobCountByQueueAndStateRow struct {
	Queue          string
	CountAvailable int64
	CountRunning   int64
}

type JobDeleteBeforeParams struct {
	CancelledDoDelete           interface{}
	CancelledFinalizedAtHorizon time.Time
	CompletedDoDelete           interface{}
	CompletedFinalizedAtHorizon time.Time
	DiscardedDoDelete           interface{}
	DiscardedFinalizedAtHorizon time.Time
	QueuesExcluded              []string
	QueuesIncluded              []string
	Max                         int64
}

type JobGetAvailableParams struct {
	Now            *time.Time
	MaxAttemptedBy int32
	AttemptedBy    string
	Queue          string
	MaxToLock      int32
}

type JobGetStuckParams struct {
	StuckHorizon time.Time
	Max          int32
}

type JobInsertFastManyNoReturningParams struct {
	Args         []string
	CreatedAt    []time.Time
	Kind         []string
	MaxAttempts  []int16
	Metadata     []string
	Priority     []int16
	Queue        []string
	ScheduledAt  []time.Time
	State        []RiverJobState
	Tags         []string
	UniqueKey    [][]byte
	UniqueStates []int32
}

type JobInsertFastManyParams struct {
	ID           []int64
	Args         []string
	CreatedAt    []time.Time
	Kind         []string
	MaxAttempts  []int16
	Metadata     []string
	Priority     []int16
	Queue        []string
	ScheduledAt  []time.Time
	State        []string
	Tags         []string
	UniqueKey    [][]byte
	UniqueStates []int32
}

type JobInsertFastManyRow struct {
	RiverJob                 RiverJob
	UniqueSkippedAsDuplicate bool
}

type JobInsertFullManyParams struct {
	Args         []string
	Attempt      []int16
	AttemptedAt  []time.Time
	CreatedAt    []time.Time
	FinalizedAt  []time.Time
	Kind         []string
	MaxAttempts  []int16
	Metadata     []string
	Priority     []int16
	Queue        []string
	ScheduledAt  []time.Time
	State        []string
	Tags         []string
	UniqueKey    []string
	UniqueStates []int32
}

type JobInsertFullParams struct {
	Args         string
	Attempt      int16
	AttemptedAt  *time.Time
	AttemptedBy  []string
	CreatedAt    *time.Time
	Errors       []string
	FinalizedAt  *time.Time
	Kind         string
	MaxAttempts  int16
	Metadata     string
	Priority     int16
	Queue        string
	ScheduledAt  *time.Time
	State        RiverJobState
	Tags         []string
	UniqueKey    string
	UniqueStates int32
}

type JobKindListParams struct {
	Match   interface{}
	After   interface{}
	Exclude []string
	Max     int32
}

type JobRescueManyParams struct {
	ID          []int64
	Error       []string
	FinalizedAt []time.Time
	ScheduledAt []time.Time
	State       []string
}

type JobRetryParams struct {
	ID  int64
	Now *time.Time
}

type JobScheduleParams struct {
	Now *time.Time
	Max int64
}

type JobScheduleRow struct {
	RiverJob          RiverJob
	ConflictDiscarded bool
}

type JobSetStateIfRunningManyParams struct {
	IDs                 []int64
	AttemptDoUpdate     []bool
	Attempt             []int32
	ErrorsDoUpdate      []bool
	Errors              []string
	FinalizedAtDoUpdate []bool
	FinalizedAt         []time.Time
	MetadataDoMerge     []bool
	MetadataUpdates     []string
	ScheduledAtDoUpdate []bool
	ScheduledAt         []time.Time
	State               []string
	Now                 *time.Time
}

type JobUpdateFullParams struct {
	AttemptDoUpdate     bool
	Attempt             int16
	AttemptedAtDoUpdate bool
	AttemptedAt         *time.Time
	AttemptedByDoUpdate bool
	AttemptedBy         []string
	ErrorsDoUpdate      bool
	Errors              []string
	FinalizedAtDoUpdate bool
	FinalizedAt         *time.Time
	MaxAttemptsDoUpdate bool
	MaxAttempts         int16
	MetadataDoUpdate    bool
	Metadata            string
	StateDoUpdate       bool
	State               RiverJobState
	ID                  int64
}

type JobUpdateParams struct {
	MetadataDoMerge bool
	Metadata        string
	ID              int64
}

type LeaderAttemptElectParams struct {
	LeaderID string
	Now      *time.Time
	TTL      float64
}

type LeaderAttemptReelectParams struct {
	LeaderID string
	Now      *time.Time
	TTL      float64
}

type LeaderInsertParams struct {
	ElectedAt *time.Time
	Now       *time.Time
	ExpiresAt *time.Time
	TTL       float64
	LeaderID  string
}

type LeaderResignParams struct {
	LeaderID        string
	Schema          sql.NullString
	LeadershipTopic string
}

type NullRiverJobState struct {
	RiverJobState RiverJobState
	Valid         bool // Valid is true if RiverJobState is not NULL
}

type PGNotifyManyParams struct {
	Schema  sql.NullString
	Topic   string
	Payload []string
}

type Queries struct {
}

type QueueCreateOrSetUpdatedAtParams struct {
	Now       *time.Time
	Metadata  string
	Name      string
	PausedAt  *time.Time
	UpdatedAt *time.Time
}

type QueueDeleteExpiredParams struct {
	UpdatedAtHorizon time.Time
	Max              int64
}

type QueueNameListParams struct {
	After   string
	Match   string
	Exclude []string
	Max     int32
}

type QueuePauseParams struct {
	Now  *time.Time
	Name string
}

type QueueResumeParams struct {
	Now  *time.Time
	Name string
}

type QueueUpdateParams struct {
	MetadataDoUpdate bool
	Metadata         string
	Name             string
}

type RiverClient struct {
	ID        string
	CreatedAt time.Time
	Metadata  string
	PausedAt  *time.Time
	UpdatedAt time.Time
}

type RiverClientQueue struct {
	RiverClientID    string
	Name             string
	CreatedAt        time.Time
	MaxWorkers       int64
	Metadata         string
	NumJobsCompleted int64
	NumJobsRunning   int64
	UpdatedAt        time.Time
}

type RiverJob struct {
	ID           int64
	Args         string
	Attempt      int16
	AttemptedAt  *time.Time
	AttemptedBy  []string
	CreatedAt    time.Time
	Errors       []string
	FinalizedAt  *time.Time
	Kind         string
	MaxAttempts  int16
	Metadata     string
	Priority     int16
	Queue        string
	State        RiverJobState
	ScheduledAt  time.Time
	Tags         []string
	UniqueKey    []byte
	UniqueStates *int
}

type RiverJobState string

type RiverLeader struct {
	ElectedAt time.Time
	ExpiresAt time.Time
	LeaderID  string
	Name      string
}

type RiverMigration struct {
	Line      string
	Version   int64
	CreatedAt time.Time
}

type RiverMigrationDeleteAssumingMainManyRow struct {
	CreatedAt time.Time
	Version   int64
}

type RiverMigrationDeleteByLineAndVersionManyParams struct {
	Line    string
	Version []int64
}

type RiverMigrationGetAllAssumingMainRow struct {
	CreatedAt time.Time
	Version   int64
}

type RiverMigrationInsertManyAssumingMainRow struct {
	CreatedAt time.Time
	Version   int64
}

type RiverMigrationInsertManyParams struct {
	Line    string
	Version []int64
}

type RiverMigrationInsertParams struct {
	Line    string
	Version int64
}

type RiverQueue struct {
	Name      string
	CreatedAt time.Time
	Metadata  string
	PausedAt  *time.Time
	UpdatedAt time.Time
}

type SchemaGetExpiredParams struct {
	Prefix     interface{}
	BeforeName interface{}
}