dbsqlc

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 IndexesExistInCurrentSchemaRow struct {
	IndexNamesIndexName string
	Exists              bool
}

type JobCountByQueueAndStateRow struct {
	Queue          string
	CountAvailable int64
	CountRunning   int64
}

type JobCountByStateRow struct {
	State RiverJobState
	Count int64
}

type JobKindListByPrefixParams struct {
	Prefix  interface{}
	After   interface{}
	Exclude []string
	Max     int32
}

type JobListWorkflowParams struct {
	WorkflowID       string
	PaginationOffset int64
	PaginationLimit  int32
}

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

type ProducerListByQueueRow struct {
	RiverProducer RiverProducer
	Running       int32
}

type Queries struct {
}

type QueueNameListByPrefixParams struct {
	After   string
	Prefix  string
	Exclude []string
	Max     int32
}

type RiverClient struct {
	ID        string
	CreatedAt pgtype.Timestamptz
	Metadata  []byte
	PausedAt  pgtype.Timestamptz
	UpdatedAt pgtype.Timestamptz
}

type RiverClientQueue struct {
	RiverClientID    string
	Name             string
	CreatedAt        pgtype.Timestamptz
	MaxWorkers       int64
	Metadata         []byte
	NumJobsCompleted int64
	NumJobsRunning   int64
	UpdatedAt        pgtype.Timestamptz
}

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

type RiverJobState string

type RiverLeader struct {
	ElectedAt pgtype.Timestamptz
	ExpiresAt pgtype.Timestamptz
	LeaderID  string
	Name      string
}

type RiverMigration struct {
	Line      string
	Version   int64
	CreatedAt pgtype.Timestamptz
}

type RiverProducer struct {
	ID         int64
	ClientID   string
	QueueName  string
	MaxWorkers int32
	Metadata   []byte
	PausedAt   pgtype.Timestamptz
	CreatedAt  pgtype.Timestamptz
	UpdatedAt  pgtype.Timestamptz
}

type RiverQueue struct {
	Name      string
	CreatedAt pgtype.Timestamptz
	Metadata  []byte
	PausedAt  pgtype.Timestamptz
	UpdatedAt pgtype.Timestamptz
}

type WorkflowListActiveParams struct {
	After           string
	PaginationLimit int32
}

type WorkflowListActiveRow struct {
	WorkflowID        string
	WorkflowName      string
	EarliestCreatedAt pgtype.Timestamptz
	CountFailedDeps   int64
	CountAvailable    int64
	CountCancelled    int64
	CountCompleted    int64
	CountDiscarded    int64
	CountPending      int64
	CountRetryable    int64
	CountRunning      int64
	CountScheduled    int64
}

type WorkflowListAllParams struct {
	After           string
	PaginationLimit int32
}

type WorkflowListAllRow struct {
	WorkflowID        string
	WorkflowName      string
	EarliestCreatedAt pgtype.Timestamptz
	CountFailedDeps   int64
	CountAvailable    int64
	CountCancelled    int64
	CountCompleted    int64
	CountDiscarded    int64
	CountPending      int64
	CountRetryable    int64
	CountRunning      int64
	CountScheduled    int64
}

type WorkflowListInactiveParams struct {
	PaginationLimit int32
	After           string
}

type WorkflowListInactiveRow struct {
	WorkflowID        string
	WorkflowName      string
	EarliestCreatedAt pgtype.Timestamptz
	CountFailedDeps   int64
	CountAvailable    int64
	CountCancelled    int64
	CountCompleted    int64
	CountDiscarded    int64
	CountPending      int64
	CountRetryable    int64
	CountRunning      int64
	CountScheduled    int64
}