Versions in this module Expand all Collapse all v3 v3.1.3 Dec 2, 2024 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)
Go to main page