Documentation
¶
Index ¶
- func Client(ctx context.Context, config ewm.WatermillConfig) (messaging.MessageClient, error)
- func Publisher(config ewm.WatermillConfig) (message.Publisher, error)
- func Sender(config ewm.WatermillConfig, proceed bool) (ewm.WatermillSender, error)
- func Subscriber(config ewm.WatermillConfig) (message.Subscriber, error)
- func Trigger(wc *ewm.WatermillConfigWrapper, cfg interfaces.TriggerConfig) (interfaces.Trigger, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Client ¶
func Client(ctx context.Context, config ewm.WatermillConfig) (messaging.MessageClient, error)
func Sender ¶
func Sender(config ewm.WatermillConfig, proceed bool) (ewm.WatermillSender, error)
func Subscriber ¶
func Subscriber(config ewm.WatermillConfig) (message.Subscriber, error)
func Trigger ¶
func Trigger(wc *ewm.WatermillConfigWrapper, cfg interfaces.TriggerConfig) (interfaces.Trigger, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.