redis_cl

Documentation

Index

• type RedisAdapterEventClaimer
  • func NewEventFailureRecover(params RedisAdapterEventClaimer) RedisAdapterEventClaimer
  • func (adapter RedisAdapterEventClaimer) Recover(ctx context.Context)
• type RedisClaimerParams

Types

type RedisAdapterEventClaimer

type RedisAdapterEventClaimer struct {
	Client   *redis.Client
	Streams  []string
	Group    string
	Consumer string
	MinIdle  time.Duration
}

func NewEventFailureRecover

func NewEventFailureRecover(params RedisAdapterEventClaimer) RedisAdapterEventClaimer

func (RedisAdapterEventClaimer) Recover

func (adapter RedisAdapterEventClaimer) Recover(ctx context.Context)

type RedisClaimerParams

type RedisClaimerParams struct {
	Client   *redis.Client
	Streams  []string
	Group    string
	Consumer string
	MinIdle  time.Duration
}