dataplane

Aug 31, 2026

Changes in this version

type FilterPlan

+ HardwareUnsupported string

+ Steering packetio.SteeringFilter

type Info

+ Backend string

+ BackendWhy string

+ PerWorker int

+ Sizing string

+ func (i Info) Workers() int

type PreflightInput

+ Backend string

Aug 10, 2026

Changes in this version

type Info

+ MultiBuffer bool

type PreflightInput

+ MultiBuffer bool

Aug 2, 2026

Changes in this version

type FilterPlan

+ KeepManagement bool

type Info

+ Tuning string

Aug 2, 2026

Changes in this version

+ func MemoryNeeded(queues, numFrames, frameSize int) uint64

+ func RaiseMemlock() (uint64, error)

+ type Check struct

+ Detail string

+ Fix string

+ Level Level

+ Title string

+ type DefaultFilterBuilder struct

+ func (DefaultFilterBuilder) Plan(cfg *config.Config, res *discovery.Resolved) (FilterPlan, error)

+ type Environment struct

+ DefaultRouteLink int

+ Euid int

+ HasDefaultRoute bool

+ HasNetRaw bool

+ MemlockCur uint64

+ MemlockMax uint64

+ MemlockUnlimited bool

+ SSHConnection string

+ func HostEnvironment(src discovery.Source) Environment

+ type FilterBuilder interface

+ Plan func(cfg *config.Config, res *discovery.Resolved) (FilterPlan, error)

+ type FilterPlan struct

+ Dangerous bool

+ Limitations []string

+ Matches []afxdp.Match

+ Redirects string

+ Summary string

+ Warnings []string

+ func (p FilterPlan) Receives() bool

+ type Info struct

+ Driver string

+ Filter string

+ FrameSize int

+ Interface string

+ LinkWait time.Duration

+ NumFrames int

+ PacketSizes string

+ Pattern string

+ Queues int

+ Reused bool

+ XDPMode string

+ ZeroCopy bool

+ func (i Info) String() string

+ type Level int

+ const LevelDanger

+ const LevelFatal

+ const LevelInfo

+ const LevelWarn

+ func (l Level) String() string

+ type Options struct

+ FrameSize int

+ Frames generator.FrameSource

+ Logf func(format string, args ...any)

+ NumFrames int

+ Session *Session

+ type Preflight struct

+ Checks []Check

+ func RunPreflight(in PreflightInput) *Preflight

+ func (p *Preflight) Dangerous() []Check

+ func (p *Preflight) Err() error

+ func (p *Preflight) Fatal() []Check

+ func (p *Preflight) NeedsConfirmation() bool

+ func (p *Preflight) OK() bool

+ func (p *Preflight) Warnings() []Check

+ type PreflightInput struct

+ AllLinks []discovery.Link

+ Cfg *config.Config

+ Env Environment

+ FrameSize int

+ MaxFrameLen int

+ NumFrames int

+ Plan FilterPlan

+ Queues int

+ Res *discovery.Resolved

+ type Runner struct

+ func New(cfg *config.Config, res *discovery.Resolved, opts Options) (*Runner, error)

+ func (r *Runner) AdjustRate(factor float64) (pps, bps uint64)

+ func (r *Runner) Collector() *stats.Collector

+ func (r *Runner) Info() Info

+ func (r *Runner) Paused() bool

+ func (r *Runner) Plan() FilterPlan

+ func (r *Runner) Preflight(src discovery.Source) *Preflight

+ func (r *Runner) Queues() int

+ func (r *Runner) Rate() (pps, bps uint64)

+ func (r *Runner) Run(ctx context.Context) error

+ func (r *Runner) SetPaused(p bool)

+ func (r *Runner) SetRate(pps, bps uint64)

+ func (r *Runner) Start(ctx context.Context) error

+ func (r *Runner) Stats() *stats.Snapshot

+ func (r *Runner) Stop()

+ func (r *Runner) Wait() error

+ type Session struct

+ func NewSession() *Session

+ func (s *Session) Attached() bool

+ func (s *Session) Close() error

+ func (s *Session) Fleet(key fleetKey, open func() (*afxdp.Fleet, error)) (*afxdp.Fleet, bool, error)