cpubsub

Documentation

Index

• Variables
• type Handler
• type LocalPubSub
  • func NewLocalPubSub() *LocalPubSub
  • func (l *LocalPubSub) Publish(topic string, payload []byte) error
  • func (l *LocalPubSub) Subscribe(topic string, handler *Handler) error
• type PubSub
  • func NewRedisPubSub(config RedisConfig, lc fx.Lifecycle, logger clogger.Logger) PubSub
• type RedisConfig
• type RedisPubSub
  • func (r *RedisPubSub) Publish(topic string, payload []byte) error
  • func (r *RedisPubSub) Subscribe(topic string, handler *Handler) error

Variables

var LocalFx = fx.Provide(
	NewLocalPubSub,
)

var RedisFx = fx.Provide(
	NewRedisPubSub,
)

Types

type Handler

type Handler func(payload []byte)

type LocalPubSub

type LocalPubSub struct {
	// contains filtered or unexported fields
}

LocalPubSub is an implementation of PubSub that only allows publishing of payloads to 'local' subscribers i.e. subscribers on the same instance as the publisher.

func NewLocalPubSub

func NewLocalPubSub() *LocalPubSub

func (*LocalPubSub) Publish

func (l *LocalPubSub) Publish(topic string, payload []byte) error

func (*LocalPubSub) Subscribe

func (l *LocalPubSub) Subscribe(topic string, handler *Handler) error

type PubSub

type PubSub interface {
	Subscribe(topic string, handler *Handler) error
	Publish(topic string, payload []byte) error
}

func NewRedisPubSub

func NewRedisPubSub(config RedisConfig, lc fx.Lifecycle, logger clogger.Logger) PubSub

type RedisConfig

type RedisConfig struct {
	Addr string
}

type RedisPubSub

type RedisPubSub struct {
	// contains filtered or unexported fields
}

func (*RedisPubSub) Publish

func (r *RedisPubSub) Publish(topic string, payload []byte) error

func (*RedisPubSub) Subscribe

func (r *RedisPubSub) Subscribe(topic string, handler *Handler) error