Versions in this module Expand all Collapse all v1 v1.0.0 Mar 21, 2026 Changes in this version + func InitWatermillProvider(config *models.EventBusConfig, logger watermill.LoggerAdapter) (models.PubSub, error) + func NewEventBus(config *models.Config, logger watermill.LoggerAdapter, ps models.PubSub) models.EventBus + func NewWatermillPubSub(publisher message.Publisher, subscriber message.Subscriber) models.PubSub
Go to main page