cluster

Aug 9, 2022

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() zLogger.GormLoggerInterface

+ 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() zLogger.GormLoggerInterface

+ func (r *RedisPubSub) Publish(channel Channel, data string) error

+ func (r *RedisPubSub) Subscribe(channel Channel, callback func(data string)) (func() error, error)