Documentation ¶
Index ¶
Constants ¶
View Source
const ErrorTag = "gogstash_input_socket_error"
ErrorTag tag added to event when process module failed
View Source
const ModuleName = "socket"
ModuleName is the name used in config file
Variables ¶
View Source
var ( ErrorUnknownSocketType1 = errutil.NewFactory("%q is not a valid socket type") ErrorSocketAccept = errutil.NewFactory("socket accept error") )
errors
Functions ¶
Types ¶
type InputConfig ¶
type InputConfig struct { config.InputConfig Socket string `json:"socket"` // Type of socket, must be one of ["tcp", "udp", "unix", "unixpacket"]. // For TCP or UDP, address must have the form `host:port`. // For Unix networks, the address must be a file system path. Address string `json:"address"` ReusePort bool `json:"reuseport"` BufferSize int `json:"buffer_size" yaml:"buffer_size"` // packetmode is only valid for UDP sessions and handles each packet as a message on its own PacketMode bool `json:"packetmode"` }
InputConfig holds the configuration json fields and internal objects
func DefaultInputConfig ¶
func DefaultInputConfig() InputConfig
DefaultInputConfig returns an InputConfig struct with default values
Click to show internal directories.
Click to hide internal directories.