postgres

package module
v0.0.31 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 25, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.0.27

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

func (*Database) GetJob

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

func (*Database) GetProcessor added in v0.0.4

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 added in v0.0.26

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

func (*Database) RegisterProcessor added in v0.0.4

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

func (*Database) Type

func (e *Database) Type() string

func (*Database) UpdateJobPayloadAndStep added in v0.0.22

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

func (*Database) UpdateJobState

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL