udpserver

package

v1.2.0 Latest Latest Go to latest Published: Sep 23, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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

func (s *SharedUDPServer) IsRunning() bool

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

func (s *SharedUDPServer) Start() error

func (s *SharedUDPServer) Stop() error

func (s *SharedUDPServer) UnregisterCollectors(key string)

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

func (u *UDPServer) Description() string

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

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

func (u *UDPServer) Stop() error