xdp

Documentation

Index

• type AddressFilter
• type XDPReceiver
  • func NewXDPReceiver(iface *net.Interface, port int, addressFilter AddressFilter) (xdpReceiver *XDPReceiver, err error)
  • func (r *XDPReceiver) Close() error
  • func (r *XDPReceiver) Recv(b []byte) (int, netip.AddrPort, error)
  • func (r *XDPReceiver) RunHealthCheck() error

Types

type AddressFilter

type AddressFilter func(netip.Addr) bool

type XDPReceiver

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

func NewXDPReceiver

func NewXDPReceiver(iface *net.Interface, port int, addressFilter AddressFilter) (xdpReceiver *XDPReceiver, err error)

func (*XDPReceiver) Close

func (r *XDPReceiver) Close() error

func (*XDPReceiver) Recv

func (r *XDPReceiver) Recv(b []byte) (int, netip.AddrPort, error)

func (*XDPReceiver) RunHealthCheck

func (r *XDPReceiver) RunHealthCheck() error