postgres

type AcquireExpiredRunParams struct {
	WorkerID     sql.NullString
	LeaseToken   sql.NullString
	LeaseUntil   sql.NullTime
	ClaimedAt    sql.NullTime
	OccurrenceID string
}

type AdvanceJobNextRunParams struct {
	NextRunAt        sql.NullTime
	ScheduleCursorAt sql.NullTime
	UpdatedAt        time.Time
	JobName          string
}

type CandaceCronJob struct {
	JobName             string
	ScheduleKind        string
	LocalHour           sql.NullInt16
	LocalMinute         sql.NullInt16
	Weekday             sql.NullInt16
	MonthDay            sql.NullInt16
	IntervalNanoseconds sql.NullInt64
	RawExpression       sql.NullString
	Timezone            string
	IntervalAnchorAt    sql.NullTime
	ScheduleCursorAt    sql.NullTime
	NextRunAt           sql.NullTime
	CatchUpPolicy       string
	OverlapPolicy       string
	Enabled             bool
	CreatedAt           time.Time
	UpdatedAt           time.Time
}

type CandaceCronRun struct {
	OccurrenceID string
	JobName      string
	ScheduledAt  time.Time
	Status       string
	Attempt      int32
	WorkerID     sql.NullString
	LeaseToken   sql.NullString
	LeaseUntil   sql.NullTime
	StartedAt    sql.NullTime
	FinishedAt   sql.NullTime
	ErrorSummary sql.NullString
	SkipReason   sql.NullString
	CreatedAt    time.Time
	UpdatedAt    time.Time
}

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 FinishRunParams struct {
	Status       string
	FinishedAt   sql.NullTime
	ErrorSummary sql.NullString
	OccurrenceID string
	LeaseToken   sql.NullString
}

type HasLiveRunForJobParams struct {
	JobName              string
	ClaimedAt            sql.NullTime
	ExcludedOccurrenceID string
}

type InsertRunningRunParams struct {
	OccurrenceID string
	JobName      string
	ScheduledAt  time.Time
	WorkerID     sql.NullString
	LeaseToken   sql.NullString
	LeaseUntil   sql.NullTime
	ClaimedAt    sql.NullTime
}

type InsertSkippedRunParams struct {
	OccurrenceID string
	JobName      string
	ScheduledAt  time.Time
	SkippedAt    sql.NullTime
	SkipReason   sql.NullString
}

type ListExpiredRunningRunsParams struct {
	ExpiredAt sql.NullTime
	RowLimit  int32
}

type MarkExpiredRunSkippedParams struct {
	SkippedAt    sql.NullTime
	SkipReason   sql.NullString
	OccurrenceID string
}

type MigrationSource struct {
	Files     embed.FS
	Directory string
}

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

type RenewRunLeaseParams struct {
	LeaseUntil   sql.NullTime
	RenewedAt    time.Time
	OccurrenceID string
	LeaseToken   sql.NullString
}

type SetJobEnabledParams struct {
	Enabled bool
	JobName string
}

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

type UpsertJobParams struct {
	JobName             string
	ScheduleKind        string
	LocalHour           sql.NullInt16
	LocalMinute         sql.NullInt16
	Weekday             sql.NullInt16
	MonthDay            sql.NullInt16
	IntervalNanoseconds sql.NullInt64
	RawExpression       sql.NullString
	Timezone            string
	IntervalAnchorAt    sql.NullTime
	ScheduleCursorAt    sql.NullTime
	NextRunAt           sql.NullTime
	CatchUpPolicy       string
	OverlapPolicy       string
	Enabled             bool
}