tcp_output

Documentation

Index

• type Config
• type TCPOutput
  • func (t *TCPOutput) Close() error
  • func (t *TCPOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error
  • func (t *TCPOutput) RegisterMetrics(reg *prometheus.Registry)
  • func (t *TCPOutput) SetClusterName(name string)
  • func (t *TCPOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, ...)
  • func (t *TCPOutput) SetLogger(logger *log.Logger)
  • func (t *TCPOutput) SetName(name string)
  • func (s *TCPOutput) SetTargetsConfig(map[string]*types.TargetConfig)
  • func (t *TCPOutput) String() string
  • func (t *TCPOutput) Write(ctx context.Context, m proto.Message, meta outputs.Meta)
  • func (t *TCPOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)

Types

type Config

type Config struct {
	Address            string        `mapstructure:"address,omitempty"` // ip:port
	Rate               time.Duration `mapstructure:"rate,omitempty"`
	BufferSize         uint          `mapstructure:"buffer-size,omitempty"`
	Format             string        `mapstructure:"format,omitempty"`
	AddTarget          string        `mapstructure:"add-target,omitempty"`
	TargetTemplate     string        `mapstructure:"target-template,omitempty"`
	OverrideTimestamps bool          `mapstructure:"override-timestamps,omitempty"`
	KeepAlive          time.Duration `mapstructure:"keep-alive,omitempty"`
	RetryInterval      time.Duration `mapstructure:"retry-interval,omitempty"`
	NumWorkers         int           `mapstructure:"num-workers,omitempty"`
	EnableMetrics      bool          `mapstructure:"enable-metrics,omitempty"`
	EventProcessors    []string      `mapstructure:"event-processors,omitempty"`
}

type TCPOutput

type TCPOutput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

func (*TCPOutput) Close

func (t *TCPOutput) Close() error

func (*TCPOutput) Init

func (t *TCPOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, opts ...outputs.Option) error

func (*TCPOutput) RegisterMetrics

func (t *TCPOutput) RegisterMetrics(reg *prometheus.Registry)

func (*TCPOutput) SetClusterName

func (t *TCPOutput) SetClusterName(name string)

func (*TCPOutput) SetEventProcessors

func (t *TCPOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, tcs map[string]*types.TargetConfig)

func (*TCPOutput) SetLogger

func (t *TCPOutput) SetLogger(logger *log.Logger)

func (*TCPOutput) SetName

func (t *TCPOutput) SetName(name string)

func (*TCPOutput) SetTargetsConfig

func (s *TCPOutput) SetTargetsConfig(map[string]*types.TargetConfig)

func (*TCPOutput) String

func (t *TCPOutput) String() string

func (*TCPOutput) Write

func (t *TCPOutput) Write(ctx context.Context, m proto.Message, meta outputs.Meta)

func (*TCPOutput) WriteEvent

func (t *TCPOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)