Versions in this module Expand all Collapse all v1 v1.0.2 Jan 3, 2025 v1.0.0 Jan 29, 2024 Changes in this version + type ConsumerCallback func(message *Payload) error + type ConsumerGroup struct + func (c *ConsumerGroup) Callback(callback ConsumerCallback) + func (c *ConsumerGroup) Listen() error + type ConsumerOption struct + ConsumerCount int + FetchCount int64 + IsDelay bool + StreamMaxLen int64 + type Payload struct + ID string + Payload any + Stream string + func (p *Payload) MarshalBinary() (data []byte, err error) + func (p *Payload) UnmarshalBinary(data []byte) error + type RedisStream struct + func New(client2 *redis.Client) (*RedisStream, error) + func (r *RedisStream) Add(stream string, payload any) error + func (r *RedisStream) CreateConsumerGroup(stream string, option *ConsumerOption) *ConsumerGroup + func (r *RedisStream) Delay(stream string, payload any, duration time.Duration) error
Go to main page