redispub

Jun 2, 2021

Changes in this version

type RedisMessageBus

+ func (r *RedisMessageBus) SendForReply(tm time.Duration, fromTopic sabuhp.Topic, replyGroup string, ...) *nthen.Future

May 22, 2021

Changes in this version

+ const GroupExistErrorMsg

+ const SubscriptionExistsAlready

+ var DefaultMessageBatchCount = 200

+ var DefaultMessageBatchWait = 700 * time.Millisecond

+ type Channel struct

+ func (r *Channel) Close()

+ type Config struct

+ Codec sabuhp.Codec

+ Ctx context.Context

+ Logger sabuhp.Logger

+ MaxMessageBatch int

+ MaxMessageBatchWait time.Duration

+ MaxWaitForSubConfirmation time.Duration

+ MaxWaitForSubRetry int

+ Redis redis.Options

+ StreamMessageInterval time.Duration

+ type MessageChannel int

+ const RedisPubSub

+ const RedisStreams

+ type RedisMessageBus struct

+ func NewRedisMessageBus(config Config, client *redis.Client, channel MessageChannel) *RedisMessageBus

+ func PubSub(config Config) (*RedisMessageBus, error)

+ func Stream(config Config) (*RedisMessageBus, error)

+ func (r *RedisMessageBus) Listen(topic string, grp string, handler sabuhp.TransportResponse) sabuhp.Channel

+ func (r *RedisMessageBus) ListenPubSub(topic string, grp string, handler sabuhp.TransportResponse) sabuhp.Channel

+ func (r *RedisMessageBus) ListenStream(streamTopic string, grp string, handler sabuhp.TransportResponse) sabuhp.Channel

+ func (r *RedisMessageBus) Send(data ...sabuhp.Message)

+ func (r *RedisMessageBus) Start()

+ func (r *RedisMessageBus) Stop()

+ func (r *RedisMessageBus) Wait()