dal

Documentation

Index

• type DAL
  • func New(conn dal.Connection) *DAL
  • func (d *DAL) CreateAsyncCall(ctx context.Context, params sql.CreateAsyncCallParams) (int64, error)
  • func (d *DAL) GetCronJobByKey(ctx context.Context, key model.CronJobKey) (model.CronJob, error)
  • func (d *DAL) GetUnscheduledCronJobs(ctx context.Context, startTime time.Time) ([]model.CronJob, error)
  • func (d *DAL) IsCronJobPending(ctx context.Context, key model.CronJobKey, startTime time.Time) (bool, error)
  • func (d *DAL) UpdateCronJobExecution(ctx context.Context, params sql.UpdateCronJobExecutionParams) error

Types

type DAL

type DAL struct {
	*dal.Handle[DAL]
	// contains filtered or unexported fields
}

func New

func New(conn dal.Connection) *DAL

func (*DAL) CreateAsyncCall

func (d *DAL) CreateAsyncCall(ctx context.Context, params sql.CreateAsyncCallParams) (int64, error)

CreateAsyncCall creates an async_call row and returns its id

func (*DAL) GetCronJobByKey

func (d *DAL) GetCronJobByKey(ctx context.Context, key model.CronJobKey) (model.CronJob, error)

GetCronJobByKey returns a cron_job row by its key

func (*DAL) GetUnscheduledCronJobs

func (d *DAL) GetUnscheduledCronJobs(ctx context.Context, startTime time.Time) ([]model.CronJob, error)

GetUnscheduledCronJobs returns all cron_jobs rows with start_time before provided startTime for deployments with min replicas > 0 with no pending corresponding async_calls after last_execution

func (*DAL) IsCronJobPending

func (d *DAL) IsCronJobPending(ctx context.Context, key model.CronJobKey, startTime time.Time) (bool, error)

IsCronJobPending returns whether this cron job is executing or scheduled in async_calls

func (*DAL) UpdateCronJobExecution

func (d *DAL) UpdateCronJobExecution(ctx context.Context, params sql.UpdateCronJobExecutionParams) error

UpdateCronJobExecution updates the last_async_call_id, last_execution, and next_execution of the cron job given by the provided key