forwarder

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

type Forwarder interface {
	Run()
	Configure(map[string]interface{})
	InitListeners(config.Config)

	// InternalMetrics is to publish a set of values
	// that are relevant to the forwarder itself.
	InternalMetrics() InternalMetrics

	// taken care of by the base
	Name() string
	String() string

	ListenerChannels() map[string]chan []byte
	SetListenerChannels(map[string]chan []byte)

	MaxBufferSize() int
	SetMaxBufferSize(int)

	KeepAliveInterval() int
	SetKeepAliveInterval(int)
}

type InternalMetrics struct {
	Counters map[string]float64
	Gauges   map[string]float64
}

type Kafka struct {
	BaseForwarder
	// contains filtered or unexported fields
}

type TCP struct {
	BaseForwarder
	// contains filtered or unexported fields
}

type UDP struct {
	BaseForwarder
	// contains filtered or unexported fields
}