afxdp

package module

Go to main page

Versions in this module

v0

v0.12.0

Sep 6, 2026

Changes in this version

+ const DescTxMetadata — linux/amd64

+ const TxMetaChecksum — linux/amd64

+ const TxMetaTimestamp — linux/amd64

type Fleet — linux/amd64

+ func (f *Fleet) Extra() (addr uint64, mem []byte)

+ func (f *Fleet) Memory() []byte

type Option — linux/amd64

+ func WithOnForeignComplete(f func(addr uint64)) Option

+ func WithSharedMemory(extra int) Option

+ func WithTxMetadata() Option

type Options — linux/amd64

+ FrameBase int

+ Memory []byte

+ OnForeignComplete func(addr uint64)

+ TxMetadataLen int

type Socket — linux/amd64

+ func (xsk *Socket) KickIfNeeded() error

+ func (xsk *Socket) QueueID() int

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

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

+ func (xsk *Socket) TxMeta(frame []byte) []byte

+ func (xsk *Socket) TxMetadataLen() int

+ type TxMetadata struct — linux/amd64

+ CsumOffset uint16

+ CsumStart uint16

+ Flags uint64

+ func (m TxMetadata) Put(b []byte)

+ type XSKFeatures struct — linux/amd64

+ RXMetadata uint64

+ TxChecksum bool

+ TxTimestamp bool

+ XDPFeatures uint64

+ ZCMaxSegs uint32

+ func QueryXSKFeatures(iface string) (XSKFeatures, error)

+ func (f XSKFeatures) ZeroCopy() bool

v0.11.2

Sep 4, 2026

Changes in this version

type Socket — linux/amd64

+ func (xsk *Socket) MaxPacket() int

+ func (xsk *Socket) MultiBuffer() bool

v0.11.1

Aug 30, 2026

v0.11.0

Aug 30, 2026

Changes in this version

type Option — linux/amd64

+ func WithoutMPWQETune() Option

v0.10.0

Aug 25, 2026

Changes in this version

type Fleet — linux/amd64

+ func (f *Fleet) Affinity() []int

type Info — linux/amd64

+ Affinity string

type Option — linux/amd64

+ func WithAffinity(cpus ...int) Option

+ func WithoutAffinity() Option

type Socket — linux/amd64

+ func (xsk *Socket) Pin() (int, error)

+ func (xsk *Socket) PinError() error

+ func (xsk *Socket) PinnedCPU() int

+ func (xsk *Socket) Unpin() error

v0.9.0

Aug 19, 2026

Changes in this version

+ const EtherTypeARP — linux/amd64

+ const EtherTypeIPv4 — linux/amd64

+ const EtherTypeIPv6 — linux/amd64

+ const EtherTypeVLAN — linux/amd64

+ const OffEtherType — linux/amd64

+ func MatchPacket(pkt []byte, opts ...Option) (bool, error) — linux/amd64

+ func NetShort(v uint16) int32 — linux/amd64

type Match — linux/amd64

+ func MatchError(desc string, err error) Match

+ func MatchICMPv4Echo() Match

+ func MatchICMPv6Echo() Match

+ func MatchIPv4Proto(proto uint8) Match

+ func MatchIPv6NextHeader(nh uint8) Match

+ func MatchTCPSrcPort(ports ...uint16) Match

+ func MatchUDPSrcPort(ports ...uint16) Match

+ func NewMatch(desc string, build func(MatchEnv) (asm.Instructions, error)) Match

+ type MatchEnv struct — linux/amd64

+ Data asm.Register

+ DataEnd asm.Register

+ Next string

+ Redirect string

+ func (e MatchEnv) Bounds(base asm.Register, n int32) asm.Instructions

+ func (e MatchEnv) FrameBase() (asm.Instructions, asm.Register)

+ func (e MatchEnv) Label(name string) string

type Option — linux/amd64

+ func WithExcept(matches ...Match) Option

v0.8.0

Aug 12, 2026

Changes in this version

type Option — linux/amd64

+ func WithTxReuseRxFrames() Option

type Options — linux/amd64

+ TxReuseRxFrames bool

v0.7.1

Aug 11, 2026

Changes in this version

type Option — linux/amd64

+ func WithBusyPoll(usecs, budget int) Option

type Options — linux/amd64

+ BusyPollBudget int

+ BusyPollUsecs int

type Socket — linux/amd64

+ func (xsk *Socket) WakeupRx() error

type Stats — linux/amd64

+ InflightHW uint64

+ RingFull uint64

+ RxKicks uint64

+ SendGot uint64

+ SendReq uint64

+ Submitted uint64

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