udpserver

Documentation

Index

• type SharedUDPServer
  • func NewSharedUDPServer(context pipeline.Context, decoder, format, addr, dispatchKey string, ...) (*SharedUDPServer, error)
  • func (s *SharedUDPServer) IsRunning() bool
  • func (s *SharedUDPServer) RegisterCollectors(key string, collector pipeline.Collector)
  • func (s *SharedUDPServer) Start() error
  • func (s *SharedUDPServer) Stop() error
  • func (s *SharedUDPServer) UnregisterCollectors(key string)
• type UDPServer
  • func (u *UDPServer) Description() string
  • func (u *UDPServer) Init(context pipeline.Context) (int, error)
  • func (u *UDPServer) Start(collector pipeline.Collector) error
  • func (u *UDPServer) Stop() error

Types

type SharedUDPServer

type SharedUDPServer struct {
	// contains filtered or unexported fields
}

SharedUDPServer used for multi configs, such as using in JMX fetcher

func NewSharedUDPServer

func NewSharedUDPServer(context pipeline.Context, decoder, format, addr, dispatchKey string, maxBufferSize int) (*SharedUDPServer, error)

func (*SharedUDPServer) IsRunning

func (s *SharedUDPServer) IsRunning() bool

func (*SharedUDPServer) RegisterCollectors

func (s *SharedUDPServer) RegisterCollectors(key string, collector pipeline.Collector)

func (*SharedUDPServer) Start

func (s *SharedUDPServer) Start() error

func (*SharedUDPServer) Stop

func (s *SharedUDPServer) Stop() error

func (*SharedUDPServer) UnregisterCollectors

func (s *SharedUDPServer) UnregisterCollectors(key string)

type UDPServer

type UDPServer struct {
	Decoder       string
	Format        string
	Address       string
	MaxBufferSize int
	// contains filtered or unexported fields
}

func (*UDPServer) Description

func (u *UDPServer) Description() string

func (*UDPServer) Init

func (u *UDPServer) Init(context pipeline.Context) (int, error)

func (*UDPServer) Start

func (u *UDPServer) Start(collector pipeline.Collector) error

func (*UDPServer) Stop

func (u *UDPServer) Stop() error