Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaSender ¶
type KafkaSender struct {
// contains filtered or unexported fields
}
func NewKafkaSender ¶
func NewKafkaSender( producer forwarder.Forwarder, logger logger.Logger, ) *KafkaSender
func (*KafkaSender) SendEvents ¶
SendEvents sends a batch of events to kafka
Click to show internal directories.
Click to hide internal directories.