workqueue

Sep 16, 2024

Changes in this version

type WorkQueue

+ func (workQueue *WorkQueue) AddUniqueItem(ctx context.Context, db *redis.Client, item Item) error

+ func (workQueue *WorkQueue) AddUniqueItemToPipeline(ctx context.Context, pipeline redis.Pipeliner, item Item)

+ func (workQueue *WorkQueue) DeepClean(ctx context.Context, db *redis.Client) error

+ func (workQueue *WorkQueue) LightClean(ctx context.Context, db *redis.Client) error

Mar 28, 2023

Changes in this version

+ func ItemDataJson(item *Item) (data T, err error)

+ type Item struct

+ Data []byte

+ ID string

+ func NewItem(data []byte) Item

+ func NewItemFromJSONData(data any) (Item, error)

+ func (item *Item) ParseJsonData(v any) error

+ type KeyPrefix string

+ func (prefix KeyPrefix) Concat(other string) KeyPrefix

+ func (prefix KeyPrefix) Of(name string) string

+ type WorkQueue struct

+ func NewWorkQueue(name KeyPrefix) WorkQueue

+ func (workQueue *WorkQueue) AddItem(ctx context.Context, db *redis.Client, item Item) error

+ func (workQueue *WorkQueue) AddItemToPipeline(ctx context.Context, pipeline redis.Pipeliner, item Item)

+ func (workQueue *WorkQueue) Complete(ctx context.Context, db *redis.Client, item *Item) (bool, error)

+ func (workQueue *WorkQueue) Lease(ctx context.Context, db *redis.Client, block bool, timeout time.Duration, ...) (*Item, error)

+ func (workQueue *WorkQueue) Processing(ctx context.Context, db *redis.Client) (int64, error)

+ func (workQueue *WorkQueue) QueueLen(ctx context.Context, db *redis.Client) (int64, error)