cluster

Documentation

Index

• Variables
• type Cluster
  • func (c *Cluster) Close() error
  • func (c *Cluster) Publish(ctx context.Context, topic string, message []byte) error
  • func (c *Cluster) Size() int
  • func (c *Cluster) Start(ctx context.Context) error
  • func (c *Cluster) Stop() error
  • func (c *Cluster) Subscribe(topic string, callback func([]byte))

Variables

var (
	ErrTopicTooLong = errors.New("topic name is too long, maximum length is 255")
	ErrReadTooShort = errors.New("read is too short")
)

errors about topic name.

Types

type Cluster

type Cluster struct {
	ID             uuid.UUID
	RedisOptions   config.Redis
	MetricRegistry prometheus.Registerer
	Keyspace       string
	Logger         zerolog.Logger
	// contains filtered or unexported fields
}

Cluster implement types.Cluster using Redis pub/sub.

func (*Cluster) Close

func (c *Cluster) Close() error

func (*Cluster) Publish

func (c *Cluster) Publish(ctx context.Context, topic string, message []byte) error

Publish send a message to given topic. Publish must not be called before Start() (or after Stop()).

func (*Cluster) Size

func (c *Cluster) Size() int

func (*Cluster) Start

func (c *Cluster) Start(ctx context.Context) error

func (*Cluster) Stop

func (c *Cluster) Stop() error

func (*Cluster) Subscribe

func (c *Cluster) Subscribe(topic string, callback func([]byte))

Subscribe to message on given topic. The callback should be quick or it may cause message lost.