Versions in this module Expand all Collapse all v3 v3.2.0 Jan 14, 2025 Changes in this version + var AddLogicLockScript = redis.NewScript(addLogicLockLua) + var HashDuplicateIdScript = redis.NewScript(hashDuplicateIdLua) + var SaveHSetScript = redis.NewScript(saveHsetLua) + func NewRdb(host, port string, password string, database, maxRetries int, ...) redis.UniversalClient + func NewReadGroupArgs(group, consumer string, streams []string, count int64, block time.Duration) *redis.XReadGroupArgs + func NewZAddArgs(stream, minId, Id string, maxLen, Limit int64, vals any) *redis.XAddArgs + type Base struct + func (t *Base) Consumer(ctx context.Context, stream *public.Stream, handler public.CallBack) error + func (t *Base) DeadLetter(ctx context.Context, channel, topic string) + func (t *Base) Dequeue(ctx context.Context, channel, topic string, do public.CallBack) + func (t *Base) Enqueue(ctx context.Context, data map[string]any) error + type BlockDuration func() time.Duration + var DefaultBlockDuration BlockDuration = func() time.Duration { ... } + type Log struct + func NewLog(client redis.UniversalClient, prefix string, log public.IMigrateLog) *Log + func (t *Log) Migrate(ctx context.Context, data []map[string]any) error + type Normal struct + func NewNormal(client redis.UniversalClient, prefix string, maxLen int64, consumerCount int64, ...) *Normal + func (t *Normal) Dequeue(ctx context.Context, channel, topic string, do public.CallBack) + func (t *Normal) Enqueue(ctx context.Context, data map[string]any) error + type PreWork func(ctx context.Context, prefix string, channel, topic string) + type ProcessLog struct + func NewProcessLog(client redis.UniversalClient, prefix string) *ProcessLog + func (t *ProcessLog) AddLog(ctx context.Context, data map[string]any) error + type RdbBroker struct + func NewBroker(client redis.UniversalClient, prefix string, maxLen, consumers int64, ...) *RdbBroker + func (t *RdbBroker) Mood(moodType btype.MoodType) public.IBroker + type Schedule struct + func NewSchedule(client redis.UniversalClient, prefix string, consumerCount int64, ...) *Schedule + func (t *Schedule) Dequeue(ctx context.Context, channel, topic string, do public.CallBack) + func (t *Schedule) Enqueue(ctx context.Context, data map[string]any) error + func (t *Schedule) PreWork(ctx context.Context, prefix string, channel, topic string) + func (t *Schedule) Watcher(ctx context.Context, zsetMax string, zsetKey, streamKey string) func(tx *redis.Tx) error + type Sequential struct + func NewSequential(client redis.UniversalClient, prefix string, consumerCount int64, ...) *Sequential + func (t *Sequential) Dequeue(ctx context.Context, channel, topic string, do public.CallBack) + func (t *Sequential) Enqueue(ctx context.Context, data map[string]any) error + type Status struct + func NewStatus(client redis.UniversalClient, prefix string) *Status + func (t *Status) Status(ctx context.Context, channel, topic, id string) (map[string]string, error) + type UITool struct + func NewUITool(client redis.UniversalClient, prefix string) *UITool + func (t *UITool) QueueMessage(ctx context.Context) error + type Watcher func(ctx context.Context, zsetMax string, zsetKey, streamKey string) func(tx *redis.Tx) error