udp_output

Documentation

Index

• type Config
• type UDPSock
  • func (u *UDPSock) Close() error
  • func (u *UDPSock) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error
  • func (u *UDPSock) RegisterMetrics(reg *prometheus.Registry)
  • func (u *UDPSock) SetClusterName(name string)
  • func (u *UDPSock) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, ...) error
  • func (u *UDPSock) SetLogger(logger *log.Logger)
  • func (u *UDPSock) SetName(name string)
  • func (u *UDPSock) SetTargetsConfig(map[string]*types.TargetConfig)
  • func (u *UDPSock) String() string
  • func (u *UDPSock) Write(ctx context.Context, m proto.Message, meta outputs.Meta)
  • func (u *UDPSock) 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"`
	SplitEvents        bool          `mapstructure:"split-events,omitempty"`
	RetryInterval      time.Duration `mapstructure:"retry-interval,omitempty"`
	EnableMetrics      bool          `mapstructure:"enable-metrics,omitempty"`
	EventProcessors    []string      `mapstructure:"event-processors,omitempty"`
}

type UDPSock

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

func (*UDPSock) Close

func (u *UDPSock) Close() error

func (*UDPSock) Init

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

func (*UDPSock) RegisterMetrics

func (u *UDPSock) RegisterMetrics(reg *prometheus.Registry)

func (*UDPSock) SetClusterName

func (u *UDPSock) SetClusterName(name string)

func (*UDPSock) SetEventProcessors

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

func (*UDPSock) SetLogger

func (u *UDPSock) SetLogger(logger *log.Logger)

func (*UDPSock) SetName

func (u *UDPSock) SetName(name string)

func (*UDPSock) SetTargetsConfig

func (u *UDPSock) SetTargetsConfig(map[string]*types.TargetConfig)

func (*UDPSock) String

func (u *UDPSock) String() string

func (*UDPSock) Write

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

func (*UDPSock) WriteEvent

func (u *UDPSock) WriteEvent(ctx context.Context, ev *formatters.EventMsg)