events

Nov 28, 2024

Changes in this version

type PublisherManager

+ func (s *PublisherManager) RegisterPublisher(topic string, sub message.Publisher)

Mar 28, 2024

Changes in this version

+ type EventRouter struct

+ Publisher message.Publisher

+ Subscriber message.Subscriber

+ func NewEventRouter(options ...EventRouterOption) (*EventRouter, error)

+ func (e *EventRouter) AddHandler(name string, topic string, f func(msg *message.Message) error)

+ func (e *EventRouter) Close() error

+ func (e *EventRouter) DumpRawEvents(msg *message.Message) error

+ func (e *EventRouter) Run(ctx context.Context) error

+ func (e *EventRouter) RunHandlers(ctx context.Context) error

+ type EventRouterOption func(*EventRouter)

+ func WithLogger(logger watermill.LoggerAdapter) EventRouterOption

+ func WithPublisher(publisher message.Publisher) EventRouterOption

+ func WithSubscriber(subscriber message.Subscriber) EventRouterOption

+ func WithVerbose(verbose bool) EventRouterOption

+ type PublisherManager struct

+ Publishers map[string][]message.Publisher

+ func NewPublisherManager() *PublisherManager

+ func (s *PublisherManager) Publish(payload interface{}) error

+ func (s *PublisherManager) PublishBlind(payload interface{})

+ func (s *PublisherManager) SubscribePublisher(topic string, sub message.Publisher)