Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Register ¶
func Register(inputType string, bf BuildInputFunc)
Register is used by input plugins to register themselves
Types ¶
type BuildInputFunc ¶
type InputBox ¶
type InputBox struct {
// contains filtered or unexported fields
}
func NewInputBox ¶
func (*InputBox) SetShutdownWhenNil ¶
SetShutdownWhenNil is used for benchmark. Gohangout main thread would exit when one input box receive a nil message, such as Ctrl-D in Stdin input
type KafkaInput ¶
type KafkaInput struct {
// contains filtered or unexported fields
}
func (*KafkaInput) ReadOneEvent ¶
func (p *KafkaInput) ReadOneEvent() map[string]interface{}
ReadOneEvent implement method in topology.Input. gohangout call this method to get one event and pass it to filter or output
func (*KafkaInput) Shutdown ¶
func (p *KafkaInput) Shutdown()
Shutdown implement method in topology.Input. It closes all consumers
type RandomInput ¶
type RandomInput struct {
// contains filtered or unexported fields
}
func (*RandomInput) ReadOneEvent ¶
func (p *RandomInput) ReadOneEvent() map[string]interface{}
func (*RandomInput) Shutdown ¶
func (p *RandomInput) Shutdown()
type StdinInput ¶
type StdinInput struct {
// contains filtered or unexported fields
}
func (*StdinInput) ReadOneEvent ¶
func (p *StdinInput) ReadOneEvent() map[string]interface{}
func (*StdinInput) Shutdown ¶
func (p *StdinInput) Shutdown()
type TCPInput ¶
type TCPInput struct {
// contains filtered or unexported fields
}
func (*TCPInput) ReadOneEvent ¶
Source Files
Click to show internal directories.
Click to hide internal directories.