udp

package

v1.10.3 Latest Latest Go to latest Published: Feb 6, 2026 License: MIT Imports: 11 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/slackhq/nebula

Links

Documentation ¶

Rendered for

Index ¶

Constants
Variables
func NewUDPStatsEmitter(udpConns []Conn) func()
type Conn
- func NewListener(l *logrus.Logger, ip netip.Addr, port int, multi bool, batch int) (Conn, error)
type EncReader
type NoopConn
type StdConn

Constants ¶

View Source

const MTU = 9001

Variables ¶

View Source

var ErrInvalidIPv6RemoteForSocket = errors.New("listener is IPv4, but writing to IPv6 remote")

Functions ¶

func NewUDPStatsEmitter ¶

func NewUDPStatsEmitter(udpConns []Conn) func()

Types ¶

type Conn ¶

type Conn interface {
	Rebind() error
	LocalAddr() (netip.AddrPort, error)
	ListenOut(r EncReader)
	WriteTo(b []byte, addr netip.AddrPort) error
	ReloadConfig(c *config.C)
	SupportsMultipleReaders() bool
	Close() error
}

func NewListener ¶

func NewListener(l *logrus.Logger, ip netip.Addr, port int, multi bool, batch int) (Conn, error)

type EncReader ¶

type EncReader func(
	addr netip.AddrPort,
	payload []byte,
)

type NoopConn ¶ added in v1.8.0

type NoopConn struct{}

func (NoopConn) Close ¶ added in v1.8.0

func (NoopConn) Close() error

func (NoopConn) ListenOut ¶ added in v1.8.0

func (NoopConn) ListenOut(_ EncReader)

func (NoopConn) LocalAddr ¶ added in v1.8.0

func (NoopConn) LocalAddr() (netip.AddrPort, error)

func (NoopConn) Rebind ¶ added in v1.8.0

func (NoopConn) Rebind() error

func (NoopConn) ReloadConfig ¶ added in v1.8.0

func (NoopConn) ReloadConfig(_ *config.C)

func (NoopConn) SupportsMultipleReaders ¶ added in v1.10.0

func (NoopConn) SupportsMultipleReaders() bool

func (NoopConn) WriteTo ¶ added in v1.8.0

func (NoopConn) WriteTo(_ []byte, _ netip.AddrPort) error

type StdConn ¶ added in v1.8.0

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

func (*StdConn) Close ¶ added in v1.8.0

func (u *StdConn) Close() error

func (*StdConn) GetRecvBuffer ¶ added in v1.8.0

func (u *StdConn) GetRecvBuffer() (int, error)

func (*StdConn) GetSendBuffer ¶ added in v1.8.0

func (u *StdConn) GetSendBuffer() (int, error)

func (*StdConn) GetSoMark ¶ added in v1.10.0

func (u *StdConn) GetSoMark() (int, error)

func (*StdConn) ListenOut ¶ added in v1.8.0

func (u *StdConn) ListenOut(r EncReader)

func (*StdConn) LocalAddr ¶ added in v1.8.0

func (u *StdConn) LocalAddr() (netip.AddrPort, error)

func (*StdConn) PrepareRawMessages ¶ added in v1.8.0

func (u *StdConn) PrepareRawMessages(n int) ([]rawMessage, [][]byte, [][]byte)

func (*StdConn) ReadMulti ¶ added in v1.8.0

func (u *StdConn) ReadMulti(msgs []rawMessage) (int, error)

func (*StdConn) ReadSingle ¶ added in v1.8.0

func (u *StdConn) ReadSingle(msgs []rawMessage) (int, error)

func (*StdConn) Rebind ¶ added in v1.8.0

func (u *StdConn) Rebind() error

func (*StdConn) ReloadConfig ¶ added in v1.8.0

func (u *StdConn) ReloadConfig(c *config.C)

func (*StdConn) SetRecvBuffer ¶ added in v1.8.0

func (u *StdConn) SetRecvBuffer(n int) error

func (*StdConn) SetSendBuffer ¶ added in v1.8.0

func (u *StdConn) SetSendBuffer(n int) error

func (*StdConn) SetSoMark ¶ added in v1.10.0

func (u *StdConn) SetSoMark(mark int) error

func (*StdConn) SupportsMultipleReaders ¶ added in v1.10.0

func (u *StdConn) SupportsMultipleReaders() bool

func (*StdConn) WriteTo ¶ added in v1.8.0

func (u *StdConn) WriteTo(b []byte, ip netip.AddrPort) error

Source Files ¶

View all Source files

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