afxdp

package module

Go to main page

Versions in this module

v0

v0.7.0

Aug 2, 2026

Changes in this version

type Option — linux/amd64

+ func WithMultiBuffer() Option

+ type Packet []Desc — linux/amd64

+ func (p Packet) Len() int

type Program — linux/amd64

+ func NewMultiBufferProgram(maxQueues int) (*Program, error)

type Socket — linux/amd64

+ func (xsk *Socket) CopyOut(p Packet, dst []byte) int

+ func (xsk *Socket) ReceivePackets(maxFrames int) []Packet

+ func (xsk *Socket) RecyclePackets(pkts []Packet)

v0.6.0

Aug 2, 2026

Changes in this version

type Info — linux/amd64

+ Tuning string

type Option — linux/amd64

+ func WithKeepManagement(extraTCPPorts ...uint16) Option

+ func WithNAPITuning(deferIRQs int, flush time.Duration) Option

+ func WithoutAutoTune() Option

v0.5.3

Aug 1, 2026

v0.5.2

Aug 1, 2026

Changes in this version

type Stats — linux/amd64

+ Polls uint64

+ func (s Stats) PacketsPerPoll() float64

v0.5.1

Aug 1, 2026

v0.5.0

Jul 31, 2026

Changes in this version

type Stats — linux/amd64

+ Kicks uint64

+ KicksSuppressed uint64

v0.4.1

Jul 30, 2026

v0.4.0

Jul 30, 2026

Changes in this version

type Option — linux/amd64

+ func WithNeedWakeup() Option

type Socket — linux/amd64

+ func (xsk *Socket) NeedsWakeupRx() bool

+ func (xsk *Socket) NeedsWakeupTx() bool

v0.3.1

Jul 27, 2026

Changes in this version

type Socket — linux/amd64

+ func (xsk *Socket) PollWith(extra []int32, timeout time.Duration) (bool, error)

v0.3.0

Jul 26, 2026

Changes in this version

type Socket — linux/amd64

+ func (xsk *Socket) FrameSize() int

+ func (xsk *Socket) UMEM() []byte

v0.2.0

Jul 8, 2026

Changes in this version

type Fleet — linux/amd64

+ func (f *Fleet) WaitLinkUp(timeout time.Duration) bool

v0.1.0

Jul 6, 2026

Changes in this version

+ const BindCopy

+ const BindZeroCopy

+ const XDPFlagsDrvMode

+ const XDPFlagsHwMode

+ const XDPFlagsSkbMode

+ func CountQueues(iface string) (int, error)

+ type Desc unix.XDPDesc

+ type Fleet struct

+ func Open(iface string, opts ...Option) (*Fleet, error)

+ func OpenFleet(iface string, options *Options) (*Fleet, error)

+ func (f *Fleet) Close() error

+ func (f *Fleet) Info() (Info, error)

+ func (f *Fleet) NumQueues() int

+ func (f *Fleet) Program() *Program

+ func (f *Fleet) Socket(queueID int) *Socket

+ func (f *Fleet) Sockets() []*Socket

+ func (f *Fleet) Stats() (FleetStats, error)

+ type FleetStats struct

+ PerQueue []Stats

+ Queues int

+ RxDropped uint64

+ RxFillRingEmpty uint64

+ RxInvalidDescs uint64

+ RxPackets uint64

+ RxRingFull uint64

+ TxInvalidDescs uint64

+ TxPackets uint64

+ TxRingEmpty uint64

+ func (s FleetStats) String() string

+ type Info struct

+ Driver string

+ Filter string

+ FrameSize int

+ Ifindex int

+ Interface string

+ NumFrames int

+ NumQueues int

+ XDPMode string

+ ZeroCopy bool

+ func (i Info) String() string

+ type Match struct

+ func MatchAll() Match

+ func MatchDstIP(cidr string) Match

+ func MatchEtherType(etherType uint16) Match

+ func MatchFlow(srcCIDR, dstCIDR string) Match

+ func MatchICMPEcho() Match

+ func MatchIPProto(proto uint8) Match

+ func MatchNone() Match

+ func MatchSrcIP(cidr string) Match

+ func MatchTCPPort(ports ...uint16) Match

+ func MatchUDPPort(ports ...uint16) Match

+ type Option func(*config)

+ func WithDriverMode() Option

+ func WithFilter(matches ...Match) Option

+ func WithFrameSize(n int) Option

+ func WithGenericMode() Option

+ func WithNumFrames(n int) Option

+ func WithOptions(o Options) Option

+ func WithQueues(n int) Option

+ func WithReceiveHeavy() Option

+ func WithRingSize(n int) Option

+ func WithTxFrames(n int) Option

+ func WithUDPPorts(ports ...uint16) Option

+ func WithZeroCopy() Option

+ type Options struct

+ BindFlags uint16

+ CompletionRingNumDescs int

+ FillRingNumDescs int

+ FrameSize int

+ NumFrames int

+ RxRingNumDescs int

+ TxFrames int

+ TxRingNumDescs int

+ XDPFlags uint32

+ func DefaultOptions() Options

+ type Program struct

+ Program *ebpf.Program

+ Queues *ebpf.Map

+ Sockets *ebpf.Map

+ func NewProgram(maxQueues int) (*Program, error)

+ func (p *Program) Attach(ifindex int, xdpFlags uint32) error

+ func (p *Program) Close() error

+ func (p *Program) Detach(ifindex int) error

+ func (p *Program) Register(queueID, fd int) error

+ func (p *Program) Unregister(queueID int) error

+ type Socket struct

+ func NewSocket(ifindex, queueID int, options *Options) (*Socket, error)

+ func (xsk *Socket) Alloc(n int) []Desc

+ func (xsk *Socket) Close() error

+ func (xsk *Socket) Complete(n int) int

+ func (xsk *Socket) FD() int

+ func (xsk *Socket) Fill(n int) int

+ func (xsk *Socket) FreeRxFrames() int

+ func (xsk *Socket) FreeTxFrames() int

+ func (xsk *Socket) GetFrame(d Desc) []byte

+ func (xsk *Socket) Kick() error

+ func (xsk *Socket) NumCompleted() int

+ func (xsk *Socket) NumFilled() int

+ func (xsk *Socket) NumFreeFillSlots() int

+ func (xsk *Socket) NumFreeTxSlots() int

+ func (xsk *Socket) NumReceived() int

+ func (xsk *Socket) NumTransmitted() int

+ func (xsk *Socket) Poll(timeoutMs int) (numReceived int, err error)

+ func (xsk *Socket) Receive(max int) []Desc

+ func (xsk *Socket) Recycle(descs []Desc)

+ func (xsk *Socket) SendBatch(payloads [][]byte) int

+ func (xsk *Socket) SendFunc(count int, build func(i int, frame []byte) int) int

+ func (xsk *Socket) Stats() (Stats, error)

+ func (xsk *Socket) Transmit(descs []Desc) int

+ func (xsk *Socket) ZeroCopy() (bool, error)

+ type Stats struct

+ Completed uint64

+ Filled uint64

+ KernelStats unix.XDPStatistics

+ Received uint64

+ Transmitted uint64

+ func (s Stats) String() string

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