Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaOutput ¶
type KafkaOutput struct {
// contains filtered or unexported fields
}
KafkaOutput is an Output plugin that send pack to a single specified kafka topic.
func (*KafkaOutput) CleanupForRestart ¶
func (this *KafkaOutput) CleanupForRestart() bool
func (*KafkaOutput) Init ¶
func (this *KafkaOutput) Init(config *conf.Conf)
Init setup KafkaOutput state according to config section. Default kafka delivery: async WaitForAll.
func (*KafkaOutput) Run ¶
func (this *KafkaOutput) Run(r engine.OutputRunner, h engine.PluginHelper) error
func (*KafkaOutput) SampleConfig ¶
func (*KafkaOutput) SampleConfig() string
Source Files
Click to show internal directories.
Click to hide internal directories.