postgres

Documentation

Index

• func RegisterDatabase(m map[string]string, logger *zap.Logger) rkasync.Database
• type Database
  • func (e *Database) AddJob(job *rkasync.Job) error
  • func (e *Database) CancelJobsOverdue(days int, filter *rkasync.JobFilter) error
  • func (e *Database) CleanJobs(days int, filter *rkasync.JobFilter) error
  • func (e *Database) DeleteJob(jobId string) error
  • func (e *Database) GetJob(id string) (*rkasync.Job, error)
  • func (e *Database) GetProcessor(jobType string) rkasync.Processor
  • func (e *Database) ListJobs(filter *rkasync.JobFilter) ([]*rkasync.Job, int, error)
  • func (e *Database) PickJobToWork() (*rkasync.Job, error)
  • func (e *Database) PickJobToWorkWithId(jobId string) (*rkasync.Job, error)
  • func (e *Database) RegisterProcessor(jobType string, processor rkasync.Processor)
  • func (e *Database) Type() string
  • func (e *Database) UpdateJobPayloadAndStep(job *rkasync.Job) error
  • func (e *Database) UpdateJobState(job *rkasync.Job) error

Functions

func RegisterDatabase

func RegisterDatabase(m map[string]string, logger *zap.Logger) rkasync.Database

Types

type Database

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

func (*Database) AddJob

func (e *Database) AddJob(job *rkasync.Job) error

func (*Database) CancelJobsOverdue

func (e *Database) CancelJobsOverdue(days int, filter *rkasync.JobFilter) error

func (*Database) CleanJobs

func (e *Database) CleanJobs(days int, filter *rkasync.JobFilter) error

func (*Database) DeleteJob

func (e *Database) DeleteJob(jobId string) error

func (*Database) GetJob

func (e *Database) GetJob(id string) (*rkasync.Job, error)

func (*Database) GetProcessor

func (e *Database) GetProcessor(jobType string) rkasync.Processor

func (*Database) ListJobs

func (e *Database) ListJobs(filter *rkasync.JobFilter) ([]*rkasync.Job, int, error)

func (*Database) PickJobToWork

func (e *Database) PickJobToWork() (*rkasync.Job, error)

func (*Database) PickJobToWorkWithId

func (e *Database) PickJobToWorkWithId(jobId string) (*rkasync.Job, error)

func (*Database) RegisterProcessor

func (e *Database) RegisterProcessor(jobType string, processor rkasync.Processor)

func (*Database) Type

func (e *Database) Type() string

func (*Database) UpdateJobPayloadAndStep

func (e *Database) UpdateJobPayloadAndStep(job *rkasync.Job) error

func (*Database) UpdateJobState

func (e *Database) UpdateJobState(job *rkasync.Job) error