Versions in this module Expand all Collapse all v0 v0.1.1 Jul 8, 2022 Changes in this version type Queue + func (q *Queue) Close() error v0.1.0 Jul 7, 2022 Changes in this version + type Priority string + const LOW + const NORMAL + const UNKNOWN + const URGENT + type Queue struct + func NewQueue(redisAddr string) (*Queue, error) + func (q *Queue) Delete(ctx context.Context, namespace, queueName string, data []byte, ...) error + func (q *Queue) Pull(ctx context.Context, namespace, queueName string) (*Task, error) + func (q *Queue) Schedule(ctx context.Context, namespace, queueName string, data []byte, ...) error + type Task struct + Data []byte + Priority Priority
Go to main page