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)
  • func (u *UDPSock) SetLogger(logger *log.Logger)
  • func (u *UDPSock) SetName(name string)
  • 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"`
	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)

func (*UDPSock) SetLogger

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

func (*UDPSock) SetName

func (u *UDPSock) SetName(name string)

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)