pool

Documentation

Index

• Variables
• type Pool
  • func New(s store.Store, l log.Logger) Pool

Variables

var (
	// ErrJobNotExist error job is not exists
	ErrJobNotExist = errors.New("job is not exists")
	// ErrVersionNotSame error job version is not same
	ErrVersionNotSame = errors.New("version is not same")
)

Types

type Pool

type Pool interface {
	CreateJob(topic job.Topic, id job.ID,
		delay job.Delay, ttr job.TTR, body job.Body, override bool) (*job.Job, error)
	LoadReadyJob(topic job.Topic, id job.ID, version job.Version) (*job.Job, error)
	DeleteJob(topic job.Topic, id job.ID) error
}

Pool is an interface for manage information of jobs.

func New

func New(s store.Store, l log.Logger) Pool

New a pool with logger and storage