udp

package

v0.10.1 Latest Latest Go to latest Published: Jan 13, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/atavakoliyext/cloudprober

Links

Open Source Insights

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(port int, 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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Listen ¶

func Listen(port int, 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.

Source Files ¶

View all Source files

udp.go

Directories ¶

Path	Synopsis
cmd This binary implements a stand-alone UDP server using the cloudprober/servers/udp/udp package.	This binary implements a stand-alone UDP server using the cloudprober/servers/udp/udp package.
proto

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL