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 JobCountByQueueAndStateRow struct {
	Queue          string
	CountAvailable int64
	CountRunning   int64
}

type JobCountByStateRow struct {
	State RiverJobState
	Count int64
}

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 Queries struct {
}

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

type RiverJobState string

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

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
}