events

func InitWatermillProvider ¶

func InitWatermillProvider(config *models.EventBusConfig, logger watermill.LoggerAdapter) (models.PubSub, error)

InitWatermillProvider initializes a Watermill PubSub based on the provider config

func NewEventBus ¶

func NewEventBus(config *models.Config, logger watermill.LoggerAdapter, ps models.PubSub) models.EventBus

func NewWatermillPubSub ¶

func NewWatermillPubSub(publisher message.Publisher, subscriber message.Subscriber) models.PubSub

NewWatermillPubSub creates a PubSub adapter for Watermill transports. Users can pass any Watermill-compatible publisher and subscriber.