Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProducer ¶ added in v0.1.10
func NewProducer(destination *backendconfig.DestinationT, opts common.Opts) (common.StreamProducer, error)
NewProducer delegates the call to the appropriate based on parameter destination for creating producer
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.