redisqueue

Jan 14, 2024

Changes in this version

type QueueRunner

+ func (qr *QueueRunner) RunTrim(trimInfos ...*TrimInfo) error

+ type TrimInfo struct

+ Limit int64

+ MaxDuration time.Duration

+ MaxLen int64

+ Streams []string

+ Tick time.Duration

Jan 13, 2024

Changes in this version

+ type DeadQueueInfo struct

+ Stop bool

+ type HandleFunc func(stream, key, val, msgId string) error

+ type IQueue interface

+ Handle func(stream, key, val, msgId string) error

+ Info func() *QueueInfo

+ type QueueInfo struct

+ DeadQueueInfo *DeadQueueInfo

+ NotifyErr func(stream, key string, err error)

+ NotifyPanic func(pnc any, stack string)

+ RetryQueueInfo *RetryQueueInfo

+ UserQueueInfo *UserQueueInfo

+ type QueueRunner struct

+ func NewQueueRunner(redisClient *redis.Client) *QueueRunner

+ func (qr *QueueRunner) CleanDead(ctx context.Context, stream, group string, start, batchSize int64) error

+ func (qr *QueueRunner) Close() error

+ func (qr *QueueRunner) HandleDead(ctx context.Context, handler HandleFunc, stream, group string, ids ...string) []error

+ func (qr *QueueRunner) PageDead(ctx context.Context, stream, group string, cursor uint64, count int64) ([]string, uint64, error)

+ func (qr *QueueRunner) Run(userQueues ...IQueue) error

+ func (qr *QueueRunner) Send(ctx context.Context, stream, val string) (string, error)

+ func (qr *QueueRunner) SendWithKey(ctx context.Context, stream, key, val string) (string, error)

+ type RetryQueueInfo struct

+ BatchSize int64

+ MinIdleTime time.Duration

+ MinRetry int64

+ NotifyDead func(stream, key, val, msgId string)

+ Stop bool

+ Tick time.Duration

+ type UserQueueInfo struct

+ BatchSize int64

+ ConsumerSize int

+ Group string

+ NewGroupStart string

+ Streams []string