Versions in this module Expand all Collapse all v1 v1.0.0 Apr 12, 2022 Changes in this version + var Module = fx.Options(fx.Provide(NewPublisher, NewSubscriber, NewRouter)) + type Publisher struct + func NewPublisher(cfg *config.Config, logger *logger.Logger, health *health.Checks) (*Publisher, error) + func NewTestPublisher(logger *logger.Logger) *Publisher + func (p *Publisher) Check() health.Check + func (p *Publisher) MessagePublisher() message.Publisher + func (p *Publisher) Publish(ctx context.Context, topic string, messages ...*message.Message) error + type Router struct + func NewRouter(cfg *config.Config, publisher *Publisher, subscriber *Subscriber, ...) (*Router, error) + func (r *Router) AddHandler(handlerName, subscribeTopic, publishTopic string, ...) *message.Handler + func (r *Router) AddNoPublisherHandler(handlerName, subscribeTopic string, handlerFunc message.NoPublishHandlerFunc) *message.Handler + func (r *Router) Check() health.Check + func (r *Router) Publisher() *Publisher + func (r *Router) Subscriber() *Subscriber + type Subscriber struct + func NewSubscriber(cfg *config.Config, logger *logger.Logger, health *health.Checks) (*Subscriber, error) + func NewTestSubscriber(logger *logger.Logger) *Subscriber + func (s *Subscriber) Check() health.Check + func (s *Subscriber) MessageSubscriber() message.Subscriber + func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)