redis

May 23, 2023

Changes in this version

+ const LatestStreamMessage

+ const RedisTopicSeparator

+ const RedisWildcard

+ const SingleLevelWildcard

+ const StandardTopicSeparator

+ const StandardWildcard

+ type Client struct

+ func NewClient(messageBusConfig types.MessageBusConfig) (Client, error)

+ func NewClientWithCreator(messageBusConfig types.MessageBusConfig, creator RedisClientCreator, ...) (Client, error)

+ func (c Client) Connect() error

+ func (c Client) Disconnect() error

+ func (c Client) Publish(message types.MessageEnvelope, topic string) error

+ func (c Client) Request(message types.MessageEnvelope, requestTopic string, responseTopicPrefix string, ...) (*types.MessageEnvelope, error)

+ func (c Client) Subscribe(topics []types.TopicChannel, messageErrors chan error) error

+ func (c Client) Unsubscribe(topics ...string) error

+ type DisconnectErr struct

+ func NewDisconnectErr(disconnectErrors []string) DisconnectErr

+ func (d DisconnectErr) Error() string

+ type OptionalClientConfiguration struct

+ Password string

+ func NewClientConfiguration(config types.MessageBusConfig) (OptionalClientConfiguration, error)

+ type RedisClient interface

+ Close func() error

+ Receive func(topic string) (*types.MessageEnvelope, error)

+ Send func(topic string, message types.MessageEnvelope) error

+ Subscribe func(topic string) error

+ Unsubscribe func(topic string)

+ func NewGoRedisClientWrapper(redisServerURL string, password string, tlsConfig *tls.Config) (RedisClient, error)

+ type RedisClientCreator func(redisServerURL string, password string, tlsConfig *tls.Config) (RedisClient, error)