sqlc

type AdvanceScheduleParams struct {
	LastRun time.Time
	NextRun time.Time
	ID      uuid.UUID
}

type ClaimJobsOldestParams struct {
	Owner      string
	Ttl        pgtype.Interval
	QueueName  string
	BatchLimit int32
}

type ClaimJobsParams struct {
	Owner      string
	Ttl        pgtype.Interval
	QueueName  string
	BatchLimit int32
}

type CompleteJobParams struct {
	ID    uuid.UUID
	Owner string
	Token int64
}

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
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type DueSchedulesParams struct {
	Now        time.Time
	BatchLimit int32
}

type FailJobParams struct {
	Permanent bool
	RetryAt   time.Time
	Cause     *string
	ID        uuid.UUID
	Owner     string
	Token     int64
}

type GetJobByIdemParams struct {
	Queue          string
	IdempotencyKey string
}

type HeartbeatLeasesParams struct {
	Until  time.Time
	Owner  string
	Ids    []uuid.UUID
	Tokens []int64
}

type HeartbeatLeasesRow struct {
	ID              uuid.UUID
	LeaseToken      int64
	CancelRequested bool
}

type InsertJobEventParams struct {
	JobID      uuid.UUID
	Queue      string
	Type       string
	FromStatus string
	ToStatus   string
	Attempt    int32
	Error      *string
	At         *time.Time
}

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

type InsertJobEventsBatchParams struct {
	JobID      uuid.UUID
	Queue      string
	Type       string
	FromStatus string
	ToStatus   string
	Attempt    int32
	Error      *string
	At         *time.Time
}

type InsertJobParams struct {
	ID             uuid.UUID
	Queue          string
	Type           string
	Payload        []byte
	Priority       int16
	RunAt          *time.Time
	Delay          pgtype.Interval
	MaxAttempts    int32
	Backoff        []byte
	IdempotencyKey *string
	Traceparent    *string
}

type InsertJobsCopyParams struct {
	ID             uuid.UUID
	Queue          string
	Type           string
	Payload        []byte
	Priority       int16
	RunAt          time.Time
	MaxAttempts    int32
	Backoff        []byte
	IdempotencyKey *string
	Traceparent    *string
}

type InsertProcessedEffectParams struct {
	Scope string
	Key   string
	JobID uuid.UUID
}

type InsertScheduleParams struct {
	ID          uuid.UUID
	Name        string
	Cron        string
	Timezone    string
	Queue       string
	JobType     string
	Payload     []byte
	Priority    int16
	MaxAttempts int32
	Backoff     []byte
	Enabled     bool
	NextRun     time.Time
}

type Job struct {
	ID              uuid.UUID
	Queue           string
	Type            string
	Payload         []byte
	Status          JobStatus
	Priority        int16
	RunAt           time.Time
	Attempts        int32
	MaxAttempts     int32
	Backoff         []byte
	LeaseOwner      *string
	LeaseUntil      *time.Time
	LastError       *string
	IdempotencyKey  *string
	CancelRequested bool
	CreatedAt       time.Time
	UpdatedAt       time.Time
	StartedAt       *time.Time
	FinishedAt      *time.Time
	LeaseToken      int64
	Traceparent     *string
}

type JobEvent struct {
	ID         int64
	JobID      uuid.UUID
	Queue      string
	Type       string
	FromStatus *JobStatus
	ToStatus   JobStatus
	Attempt    int32
	Error      *string
	At         time.Time
}

type JobStatus string

type ListJobsParams struct {
	Queue          *string
	Status         *JobStatus
	Type           *string
	AfterCreatedAt *time.Time
	AfterID        uuid.NullUUID
	PageLimit      int32
}

type ListSchedulesParams struct {
	AfterName string
	PageLimit int32
}

type NotifyReadyParams struct {
	Channel string
	Queue   string
}

type NullJobStatus struct {
	JobStatus JobStatus
	Valid     bool // Valid is true if JobStatus is not NULL
}

type ProcessedEffect struct {
	Scope       string
	Key         string
	JobID       uuid.UUID
	ProcessedAt time.Time
}

type ProcessedEffectExistsParams struct {
	Scope string
	Key   string
}

type PurgeJobsParams struct {
	Statuses   []string
	Queue      *string
	OlderThan  pgtype.Interval
	BatchLimit int32
}

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

type QueueDepthRow struct {
	Queue       string
	Status      JobStatus
	N           int64
	OldestRunAt time.Time
}

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

type RequeueExpiredJobParams struct {
	Status string
	RunAt  time.Time
	Cause  string
	ID     uuid.UUID
}

type Schedule struct {
	ID          uuid.UUID
	Name        string
	Cron        string
	Timezone    string
	Queue       string
	JobType     string
	Payload     []byte
	Priority    int16
	MaxAttempts int32
	Backoff     []byte
	Enabled     bool
	NextRun     time.Time
	LastRun     *time.Time
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type SelectExpiredLeasesParams struct {
	Now        time.Time
	BatchLimit int32
}

type SelectExpiredLeasesRow struct {
	ID              uuid.UUID
	Queue           string
	Type            string
	Attempts        int32
	MaxAttempts     int32
	Backoff         []byte
	CancelRequested bool
}

type UpdateScheduleParams struct {
	ID          uuid.UUID
	Cron        string
	Timezone    string
	Queue       string
	JobType     string
	Payload     []byte
	Priority    int16
	MaxAttempts int32
	Backoff     []byte
	Enabled     bool
	NextRun     time.Time
}