input

package

v1.10.13 Latest Latest Go to latest Published: Dec 16, 2024 License: MIT Imports: 20 Imported by: 1

Details

This section is empty.

This section is empty.

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

GetInput return topoloty.Input from builtin plugins or from a 3rd party plugin

func Register(inputType string, bf BuildInputFunc)

Register is used by input plugins to register themselves

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

type InputBox struct {
	// contains filtered or unexported fields
}

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

func (box *InputBox) Beat(worker int)

Beat starts the processors and wait until shutdown

func (box *InputBox) SetShutdownWhenNil(shutdownWhenNil bool)

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

func (box *InputBox) Shutdown()

Shutdown shutdowns the inputs and outputs

type KafkaInput struct {
	// contains filtered or unexported fields
}

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 (p *KafkaInput) Shutdown()

Shutdown implement method in topology.Input. It closes all consumers

type RandomInput struct {
	// contains filtered or unexported fields
}

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

func (p *RandomInput) Shutdown()

type StdinInput struct {
	// contains filtered or unexported fields
}

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

func (p *StdinInput) Shutdown()

type TCPInput struct {
	// contains filtered or unexported fields
}

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

func (p *TCPInput) Shutdown()

type UDPInput struct {
	// contains filtered or unexported fields
}

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

func (p *UDPInput) Shutdown()