Versions in this module Expand all Collapse all v1 v1.0.0 Dec 30, 2025 Changes in this version + var MaxRetry = maxRetry + type BoundedQueue interface + Cap func() uint64 + func NewBoundedQueue(rc Client, key string, cap uint64) BoundedQueue + func NewBoundedUniqueQueue(rc Client, key string, cap uint64) BoundedQueue + type Client interface + type Lock struct + func NewLock(store redis.Cmdable, key string, expireSec uint32) *Lock + func (rl *Lock) Acquire() (bool, error) + func (rl *Lock) AcquireCtx(ctx context.Context) (bool, error) + func (rl *Lock) AcquireWait() error + func (rl *Lock) AcquireWaitCtx(ctx context.Context) error + func (rl *Lock) Release() (bool, error) + func (rl *Lock) ReleaseCtx(ctx context.Context) (bool, error) + func (rl *Lock) SetExpire(seconds int) + type Queue interface + BPop func() (string, error) + Len func() uint64 + Pop func() (string, error) + PopN func(n int) ([]string, error) + Push func(v ...any) error + func NewQueue(rc Client, key string) Queue + func NewUniqueQueue(rc Client, key string) Queue + type Redis interface + Keys func(partern string) ([]string, error) + type Set interface + Add func(vs ...any) error + IsMember func(v any) bool + IsMembers func(vs ...any) []bool + Len func() int64 + Rem func(vs ...any) error + func NewSet(rc Client, key string) Set + type UniqueQueue struct + func NewExportUniqueQueue(rc Client, key string) UniqueQueue + func (uq UniqueQueue) BPop() (string, error) + func (uq UniqueQueue) Pop() (string, error) + func (uq UniqueQueue) PopN(n int) ([]string, error) + func (uq UniqueQueue) Push(vs ...any) error
Go to main page