streams

Jan 14, 2021

Changes in this version

+ const GoModMessagingNamespace

+ const GoModMessagingNamespaceFormat

+ const LatestStreamMessage

+ 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) Subscribe(topics []types.TopicChannel, messageErrors chan error) 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

+ AddToStream func(stream string, values map[string]interface{}) error

+ Close func() error

+ ReadFromStream func(stream string) ([]types.MessageEnvelope, error)

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

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