Versions in this module Expand all Collapse all v0 v0.32.0 Mar 4, 2024 Changes in this version + type Channel string + var DestinationNew Channel = "new-destination" + type Client struct + func NewClient(ctx context.Context, opts ...ClientOps) (*Client, error) + func (c *Client) GetClusterPrefix() string + func (c *Client) IsDebug() bool + type ClientInterface interface + GetClusterPrefix func() string + IsDebug func() bool + type ClientOps func(c *clientOptions) + func WithDebugging() ClientOps + func WithKeyPrefix(prefix string) ClientOps + func WithNewRelic() ClientOps + func WithRedis(redisOptions *redis.Options) ClientOps + type Coordinator string + var CoordinatorMemory Coordinator = "memory" + var CoordinatorRedis Coordinator = "redis" + type MemoryPubSub struct + func NewMemoryPubSub(ctx context.Context) (*MemoryPubSub, error) + func (m *MemoryPubSub) Logger() *zerolog.Logger + func (m *MemoryPubSub) Publish(channel Channel, data string) error + func (m *MemoryPubSub) Subscribe(channel Channel, callback func(data string)) (func() error, error) + type RedisPubSub struct + func NewRedisPubSub(ctx context.Context, options *redis.Options) (*RedisPubSub, error) + func (r *RedisPubSub) Logger() *zerolog.Logger + func (r *RedisPubSub) Publish(channel Channel, data string) error + func (r *RedisPubSub) Subscribe(channel Channel, callback func(data string)) (func() error, error)