socket

type CallbackConnection func(net.Addr, io.ReadCloser)

type CallbackData func(net.Addr, []byte)

type CallbackError func(error)

type Config struct {
	MaxConnections       int              `toml:"max_connections"`
	ReadBufferSize       config.Size      `toml:"read_buffer_size"`
	ReadTimeout          config.Duration  `toml:"read_timeout"`
	KeepAlivePeriod      *config.Duration `toml:"keep_alive_period"`
	SocketMode           string           `toml:"socket_mode"`
	ContentEncoding      string           `toml:"content_encoding"`
	MaxDecompressionSize config.Size      `toml:"max_decompression_size"`
	tlsint.ServerConfig
}

type Socket struct {
	Config
	// contains filtered or unexported fields
}

type SplitConfig struct {
	SplittingStrategy    string          `toml:"splitting_strategy"`
	SplittingDelimiter   string          `toml:"splitting_delimiter"`
	SplittingLength      int             `toml:"splitting_length"`
	SplittingLengthField lengthFieldSpec `toml:"splitting_length_field"`
}