README
¶
socket input
Synopsis
{
"input": [
{
"type": "socket",
// Socket type. Must be one of ["tcp", "unix", "unixpacket"].
"socket": "tcp",
// For TCP, address must have the form `host:port`.
// For Unix networks, the address must be a file system path.
"address": "localhost:9999"
}
]
}
Note: at the moment, this input only works with connection-oriented sockets.
Datagram-oriented sockets like UDP or UNIXGRAM socket are not supported.
Documentation
¶
Index ¶
Constants ¶
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 ¶
func InitHandler ¶
InitHandler initialize the input plugin
Types ¶
type InputConfig ¶
type InputConfig struct {
config.InputConfig
Socket string `json:"socket"` // Type of socket, must be one of ["tcp", "unix", "unixpacket"].
Address string `json:"address"` // For TCP, address must have the form `host:port`. For Unix networks, the address must be a file system path.
}
InputConfig holds the configuration json fields and internal objects
func DefaultInputConfig ¶
func DefaultInputConfig() InputConfig
DefaultInputConfig returns an InputConfig struct with default values
Source Files
Click to show internal directories.
Click to hide internal directories.