udp

Documentation

Index

• Constants
• type UdpInput
  • func (self *UdpInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)
  • func (self *UdpInput) Run(runner plugins.InputRunner) error
• type UdpInputConfig
• type UdpOutput
  • func (self *UdpOutput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) error
  • func (self *UdpOutput) Run(runner plugins.OutputRunner) error
• type UdpOutputConfig
• type UdpPack

Constants

const UDP_PACKET_SIZE = 4096

Types

type UdpInput

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

func (*UdpInput) Init

func (self *UdpInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)

func (*UdpInput) Run

func (self *UdpInput) Run(runner plugins.InputRunner) error

type UdpInputConfig

type UdpInputConfig struct {
	// Network type (e.g. "tcp", "tcp4", "tcp6", "unix" or "unixpacket").
	// Needs to match the input type.
	Net string
	// String representation of the address of the network connection on which
	// the listener should be listening (e.g. "127.0.0.1:5565").
	Address string
}

type UdpOutput

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

func (*UdpOutput) Init

func (self *UdpOutput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) error

func (*UdpOutput) Run

func (self *UdpOutput) Run(runner plugins.OutputRunner) error

type UdpOutputConfig

type UdpOutputConfig struct {
	// Network type ("udp", "udp4", "udp6", or "unixgram"). Needs to match the
	// input type.
	Net string
	// String representation of the address of the network connection to which
	// we will be sending out packets (e.g. "192.168.64.48:3336").
	Address string
	// Optional address to use as the local address for the connection.
	LocalAddress string `toml:"local_address"`
	// Maximum size of message, plugin drops the data if it exceeds this limit.
	MaxMessageSize int `toml:"max_message_size"`
}

This is our plugin's config struct

type UdpPack

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