redis_cs

Documentation

Index

• type RedisAdaptersEventConsumer
  • func NewRedisAdapterEventConsumer(params RedisConsumerParams) (RedisAdaptersEventConsumer, error)
  • func (adapter *RedisAdaptersEventConsumer) Run(ctx context.Context)
• type RedisConsumerParams

Types

type RedisAdaptersEventConsumer

type RedisAdaptersEventConsumer struct {
	Client           *redis.Client
	HandlerConsumers map[string]consumer.EventConsumerHandler
	Streams          []string
	Group            string
	Consumer         string
}

func NewRedisAdapterEventConsumer

func NewRedisAdapterEventConsumer(params RedisConsumerParams) (RedisAdaptersEventConsumer, error)

func (*RedisAdaptersEventConsumer) Run

func (adapter *RedisAdaptersEventConsumer) Run(ctx context.Context)

type RedisConsumerParams

type RedisConsumerParams struct {
	Client           *redis.Client
	Group            string
	Consumer         string
	HandlerConsumers map[string]consumer.EventConsumerHandler
}