tcp_output

package
v0.26.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 29, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.7.0

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

func (*TCPOutput) SetClusterName added in v0.8.0

func (t *TCPOutput) SetClusterName(name string)

func (*TCPOutput) SetEventProcessors added in v0.6.0

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

func (*TCPOutput) SetLogger added in v0.5.2

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

func (*TCPOutput) SetName added in v0.7.0

func (t *TCPOutput) SetName(name string)

func (*TCPOutput) SetTargetsConfig added in v0.18.0

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 added in v0.7.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL