engine

Feb 23, 2023

Changes in this version

+ const KindRedisV2

+ type CreateJobReq struct

+ Attributes map[string]string

+ Body []byte

+ Delay uint32

+ ID string

+ Namespace string

+ Queue string

+ TTL uint32

+ Tries uint16

type Job

+ func NewJobFromReq(req *CreateJobReq) Job

+ Attributes func() map[string]string

Aug 31, 2021

Changes in this version

+ const KindMigration

+ const KindRedis

Sep 30, 2020

Changes in this version

+ func Shutdown()

type Engine

+ ConsumeMultiWithFrozenTries func(namespace string, queues []string, ttrSecond, timeoutSecond uint32) (job Job, err error)

Jun 4, 2020

Changes in this version

+ var ErrEmptyQueue = errors.New("the queue is empty")

+ var ErrNotFound = errors.New("job not found")

+ var ErrWrongQueue = errors.New("wrong queue for the job")

+ func ExistsPool(pool string) bool

+ func GetPools() []string

+ func GetPoolsByKind(kind string) []string

+ func Register(kind, pool string, e Engine)

+ type Engine interface

+ BatchConsume func(namespace, queue string, count, ttrSecond, timeoutSecond uint32) (jobs []Job, err error)

+ Consume func(namespace, queue string, ttrSecond, timeoutSecond uint32) (job Job, err error)

+ ConsumeMulti func(namespace string, queues []string, ttrSecond, timeoutSecond uint32) (job Job, err error)

+ Delete func(namespace, queue, jobID string) error

+ DeleteDeadLetter func(namespace, queue string, limit int64) (count int64, err error)

+ Destroy func(namespace, queue string) (count int64, err error)

+ DumpInfo func(output io.Writer)

+ Peek func(namespace, queue, optionalJobID string) (job Job, err error)

+ PeekDeadLetter func(namespace, queue string) (size int64, jobID string, err error)

+ Publish func(namespace, queue string, body []byte, ttlSecond, delaySecond uint32, ...) (jobID string, err error)

+ RespawnDeadLetter func(namespace, queue string, limit, ttlSecond int64) (count int64, err error)

+ Shutdown func()

+ Size func(namespace, queue string) (size int64, err error)

+ SizeOfDeadLetter func(namespace, queue string) (size int64, err error)

+ func GetEngine(pool string) Engine

+ func GetEngineByKind(kind, pool string) Engine

+ type EnginePool map[string]Engine

+ type Job interface

+ Body func() []byte

+ Delay func() uint32

+ ElapsedMS func() int64

+ ID func() string

+ Namespace func() string

+ Queue func() string

+ TTL func() uint32

+ Tries func() uint16

+ func NewJob(namespace, queue string, body []byte, ttl, delay uint32, tries uint16) Job

+ func NewJobWithID(namespace, queue string, body []byte, ttl uint32, tries uint16, jobID string) Job