udp

Documentation

Overview

Package udp implements a UDP server. It listens on a given port and echos whatever it receives. This is used for the UDP probe.

Index

• func Listen(addr *net.UDPAddr, l *logger.Logger) (*net.UDPConn, error)
• type Server
  • func New(initCtx context.Context, c *configpb.ServerConf, l *logger.Logger) (*Server, error)
  • func (s *Server) Start(ctx context.Context, dataChan chan<- *metrics.EventMetrics) error

Functions

func Listen

func Listen(addr *net.UDPAddr, l *logger.Logger) (*net.UDPConn, error)

Listen opens a UDP socket on the given port. It also attempts to set recv buffer to a large value so that we can have many outstanding UDP messages. Listen is exported only because it's used by udp probe tests.

Types

type Server

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

Server implements a basic UDP server.

func New

func New(initCtx context.Context, c *configpb.ServerConf, l *logger.Logger) (*Server, error)

New returns an UDP server.

func (*Server) Start

func (s *Server) Start(ctx context.Context, dataChan chan<- *metrics.EventMetrics) error

Start starts the UDP server. It returns only when context is canceled.