input

Apr 15, 2021

Changes in this version

+ func GetInput(inputType string, config map[interface{}]interface{}) topology.Input

+ func Register(inputType string, bf BuildInputFunc)

+ type BuildInputFunc func(map[interface{}]interface{}) topology.Input

+ type InputBox struct

+ func NewInputBox(input topology.Input, inputConfig map[interface{}]interface{}, ...) *InputBox

+ func (box *InputBox) Beat(worker int)

+ func (box *InputBox) SetShutdownWhenNil(shutdownWhenNil bool)

+ func (box *InputBox) Shutdown()

+ type KafkaInput struct

+ func (p *KafkaInput) ReadOneEvent() map[string]interface{}

+ func (p *KafkaInput) Shutdown()

+ type RandomInput struct

+ func (p *RandomInput) ReadOneEvent() map[string]interface{}

+ func (p *RandomInput) Shutdown()

+ type StdinInput struct

+ func (p *StdinInput) ReadOneEvent() map[string]interface{}

+ func (p *StdinInput) Shutdown()

+ type TCPInput struct

+ func (p *TCPInput) ReadOneEvent() map[string]interface{}

+ func (p *TCPInput) Shutdown()

+ type UDPInput struct

+ func (p *UDPInput) ReadOneEvent() map[string]interface{}

+ func (p *UDPInput) Shutdown()