Documentation
¶
Index ¶
- func NewSaramaClient(connectionURL string) (sarama.Client, error)
- func NewSaramaConfig(connectionURL string) ([]string, *sarama.Config, error)
- func NewWatermillPublisher(connection string, logger watermill.LoggerAdapter) (message.Publisher, error)
- func NewWatermillSubscriber(connection string, logger watermill.LoggerAdapter) (message.Subscriber, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSaramaClient ¶
NewSaramaConfig build new sarama client from URL string.
func NewSaramaConfig ¶
NewSaramaConfig build new sarama config from URL string.
func NewWatermillPublisher ¶
func NewWatermillPublisher(connection string, logger watermill.LoggerAdapter) (message.Publisher, error)
NewWatermillPublisher build watermill publisher from provided url.
func NewWatermillSubscriber ¶
func NewWatermillSubscriber(connection string, logger watermill.LoggerAdapter) (message.Subscriber, error)
NewWatermillSubscriber build watermill subscriber from provided url.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.