Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Consumer ¶
type Consumer struct { consumer.ConsumerEntity Config consumerConfig RawConfig *common.Config // Raw config that can be unpacked to get Beat specific config data. // contains filtered or unexported fields }
Consumer provides the runnable and configurable instance of a consumer.
func NewConsumer ¶
func (*Consumer) ConsumerConfig ¶
ConsumerConfig returns config section for this consumer
func (*Consumer) InitWithSettings ¶
InitWithSettings does initialization of things common to all actions (read etcd config, flags)
Click to show internal directories.
Click to hide internal directories.