Versions in this module Expand all Collapse all v0 v0.1.0 Mar 19, 2022 Changes in this version + var ErrJobNotExist = errors.New("job is not exists") + var ErrVersionNotSame = errors.New("version is not same") + type Pool interface + CreateJob func(topic job.Topic, id job.ID, delay job.Delay, ttr job.TTR, body job.Body, ...) (*job.Job, error) + DeleteJob func(topic job.Topic, id job.ID) error + LoadReadyJob func(topic job.Topic, id job.ID, version job.Version) (*job.Job, error) + func New(s store.Store, l log.Logger) Pool v0.1.0-beta Jul 14, 2021
Go to main page