Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(config *MessageProducerConfig) (*messageProducer, error)
New returns producer if infra is ok.
Types ¶
type MessageProducerConfig ¶
type MessageProducerConfig struct { Host string `mapstructure:"host"` Topic string `mapstructure:"topic"` }
MessageProducerConfig defines NSQ publish configuration
Click to show internal directories.
Click to hide internal directories.