sock

Documentation

Index

• Variables
• func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
• func NewSock(ctx context.Context, config interface{}, output chan<- *event.ProcessorEvent) (input.Input, error)
• type Config
  • func (c *Config) ConfigValidate() error
• type Sock
  • func (s *Sock) Ctx() context.Context
  • func (s *Sock) Run() (err error)
  • func (s *Sock) Stop()

Variables

var (
	// ErrInvalidAddr invalid address.
	ErrInvalidAddr = errors.New("invalid address")
)

Functions

func DecodeConfig

func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)

func NewSock

func NewSock(ctx context.Context, config interface{}, output chan<- *event.ProcessorEvent) (input.Input, error)

Types

type Config

type Config struct {
	TcpAddr          string         `toml:"tcpAddr"`
	UdpAddr          string         `toml:"udpAddr"`
	ReadChanSize     int            `toml:"readChanSize"`
	TcpBatchMaxBytes int            `toml:"tcpBatchMaxBytes"`
	UdpPacketMaxSize int            `toml:"udpPacketMaxSize"`
	LogMaxBytes      int            `toml:"logMaxBytes"`
	UdpReadTimeout   xtime.Duration `toml:"udpReadTimeout"`
	TcpReadTimeout   xtime.Duration `toml:"tcpReadTimeout"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type Sock

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

func (*Sock) Ctx

func (s *Sock) Ctx() context.Context

func (*Sock) Run

func (s *Sock) Run() (err error)

func (*Sock) Stop

func (s *Sock) Stop()