redisq

Oct 28, 2021

Changes in this version

+ type RedisStreamClient interface

+ Del func(ctx context.Context, keys ...string) *redis.IntCmd

+ TxPipeline func() redis.Pipeliner

+ XAck func(ctx context.Context, stream, group string, ids ...string) *redis.IntCmd

+ XAdd func(ctx context.Context, a *redis.XAddArgs) *redis.StringCmd

+ XDel func(ctx context.Context, stream string, ids ...string) *redis.IntCmd

+ XGroupCreateMkStream func(ctx context.Context, stream, group, start string) *redis.StatusCmd

+ XGroupDelConsumer func(ctx context.Context, stream, group, consumer string) *redis.IntCmd

+ XInfoConsumers func(ctx context.Context, key string, group string) *redis.XInfoConsumersCmd

+ XLen func(ctx context.Context, stream string) *redis.IntCmd

+ XPendingExt func(ctx context.Context, a *redis.XPendingExtArgs) *redis.XPendingExtCmd

+ XRangeN func(ctx context.Context, stream, start, stop string, count int64) *redis.XMessageSliceCmd

+ XReadGroup func(ctx context.Context, a *redis.XReadGroupArgs) *redis.XStreamSliceCmd

+ XTrim func(ctx context.Context, key string, maxLen int64) *redis.IntCmd

+ ZAdd func(ctx context.Context, key string, members ...*redis.Z) *redis.IntCmd

+ ZRangeByScore func(ctx context.Context, key string, opt *redis.ZRangeBy) *redis.StringSliceCmd

+ ZRem func(ctx context.Context, key string, members ...interface{}) *redis.IntCmd

Sep 14, 2020

Changes in this version

+ func NewFactory() taskq.Factory

+ type Queue struct

+ func NewQueue(opt *taskq.QueueOptions) *Queue

+ func (q *Queue) Add(msg *taskq.Message) error

+ func (q *Queue) Close() error

+ func (q *Queue) CloseTimeout(timeout time.Duration) error

+ func (q *Queue) Consumer() *taskq.Consumer

+ func (q *Queue) Delete(msg *taskq.Message) error

+ func (q *Queue) Len() (int, error)

+ func (q *Queue) Name() string

+ func (q *Queue) Options() *taskq.QueueOptions

+ func (q *Queue) Purge() error

+ func (q *Queue) Release(msg *taskq.Message) error

+ func (q *Queue) ReserveN(ctx context.Context, n int, waitTimeout time.Duration) ([]taskq.Message, error)

+ func (q *Queue) String() string