tcp

Documentation

Index

• func NewTCPProvider() provider.EventProvider
• type TCPConfig
• type TCPProvider
  • func (t *TCPProvider) ConfigStruct() interface{}
  • func (t *TCPProvider) Init(i interface{}) error
  • func (t *TCPProvider) Start(dst chan *event.Event)

Functions

func NewTCPProvider

func NewTCPProvider() provider.EventProvider

Types

type TCPConfig

type TCPConfig struct {
	Encoding    string `json:"encoding"`
	Listen      string `json:"listen"`
	MaxDecoders int    `json:"max_decoders"`
}

the config struct for the tcp provider

type TCPProvider

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

provides events from tcp connections

func (*TCPProvider) ConfigStruct

func (t *TCPProvider) ConfigStruct() interface{}

func (*TCPProvider) Init

func (t *TCPProvider) Init(i interface{}) error

func (*TCPProvider) Start

func (t *TCPProvider) Start(dst chan *event.Event)

start accepting connections and consume each of them as they come in