Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2026 Changes in this version + type CallbackConnection func(net.Addr, io.ReadCloser) + type CallbackData func(net.Addr, []byte, time.Time) + type CallbackError func(error) + type Config struct + AllowedSources []net.IP + ContentEncoding string + KeepAlivePeriod *config.Duration + MaxConnections uint64 + MaxDecompressionSize config.Size + MaxParallelParsers int + ReadBufferSize config.Size + ReadTimeout config.Duration + SocketMode string + func (cfg *Config) NewSocket(address string, splitcfg *SplitConfig, logger telegraf.Logger) (*Socket, error) + type Socket struct + func (s *Socket) Address() net.Addr + func (s *Socket) Close() + func (s *Socket) Listen(onData CallbackData, onError CallbackError) + func (s *Socket) ListenConnection(onConnection CallbackConnection, onError CallbackError) + func (s *Socket) Setup() error + type SplitConfig struct + SplittingDelimiter string + SplittingLength int + SplittingLengthField lengthFieldSpec + SplittingStrategy string + func (cfg *SplitConfig) NewSplitter() (bufio.SplitFunc, error)
Go to main page