udp

Documentation

Index

• Constants
• type UDP
  • func New(logger *zap.Logger, host, port string, workers int) (*UDP, error)
  • func (u *UDP) Stop(ctx context.Context) error
  • func (u *UDP) Write(ctx context.Context, data output.LogRecord) error

Constants

const (
	// DefaultUDPChannelSize is the default size of the data channel
	DefaultUDPChannelSize = 100

	// DefaultUDPWorkers is the default number of worker goroutines
	DefaultUDPWorkers = 1

	// DefaultUDPWriteTimeout is the default timeout for writing data to UDP connections
	DefaultUDPWriteTimeout = 5 * time.Second

	// DefaultUDPStopTimeout is the default timeout for graceful shutdown
	DefaultUDPStopTimeout = 30 * time.Second
)

Types

type UDP

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

UDP implements the Output interface for UDP connections

func New

func New(logger *zap.Logger, host, port string, workers int) (*UDP, error)

New creates a new UDP output instance

func (*UDP) Stop

func (u *UDP) Stop(ctx context.Context) error

Stop gracefully shuts down all workers and closes UDP connections Stop shall not be called more than once. If the provided context is done, Stop will return immediately even if workers are still shutting down.

func (*UDP) Write

func (u *UDP) Write(ctx context.Context, data output.LogRecord) error

Write sends data to the UDP output channel for processing by workers. Write shall not be called after Stop is called. If the provided context is done, Write will return immediately even if the data is not written to the channel.