dal

Documentation

Index

• type DAL
  • func New(conn sql.ConnI) *DAL
  • func (d *DAL) Begin(ctx context.Context) (*Tx, error)
  • 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
• type Tx
  • func (t *Tx) Commit(ctx context.Context) error
  • func (t *Tx) CommitOrRollback(ctx context.Context, err *error)
  • func (t *Tx) Rollback(ctx context.Context) error

Types

type DAL

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

func New

func New(conn sql.ConnI) *DAL

func (*DAL) Begin

func (d *DAL) Begin(ctx context.Context) (*Tx, error)

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

type Tx

type Tx struct {
	*DAL
}

func (*Tx) Commit

func (t *Tx) Commit(ctx context.Context) error

func (*Tx) CommitOrRollback

func (t *Tx) CommitOrRollback(ctx context.Context, err *error)

func (*Tx) Rollback

func (t *Tx) Rollback(ctx context.Context) error