Crate scx_flow 

Flow scheduler front end.

Copyright (c) 2026 Galih Tama galpt@v.recipes Loads the BPF object, seeds the topology view, then drives the loop. Observability is counters through the stats server plus the loopback dashboard with per CPU cards plus a JSON snapshot for debugging.

Re-exports

pub(crate) use std::mem::MaybeUninit; 🔒

pub(crate) use std::sync::Arc; 🔒

pub(crate) use std::sync::atomic::AtomicBool; 🔒

pub(crate) use std::sync::atomic::Ordering; 🔒

pub(crate) use std::time::Duration; 🔒

pub(crate) use anyhow::Result; 🔒

pub(crate) use clap::CommandFactory; 🔒

pub(crate) use clap::Parser; 🔒

pub(crate) use clap_complete::Shell; 🔒

pub(crate) use clap_complete::generate; 🔒

pub(crate) use crossbeam::channel::RecvTimeoutError; 🔒

pub(crate) use log::info; 🔒

pub(crate) use scx_utils::UserExitInfo; 🔒

pub(crate) use scx_utils::build_id; 🔒

pub(crate) use scx_utils::libbpf_clap_opts::LibbpfOpts; 🔒

pub(crate) use scx_utils::scx_ops_attach; 🔒

pub(crate) use scx_utils::scx_ops_load; 🔒

pub(crate) use scx_utils::scx_ops_open; 🔒

pub(crate) use scx_utils::try_set_rlimit_infinity; 🔒

pub(crate) use scx_utils::uei_exited; 🔒

pub(crate) use scx_utils::uei_report; 🔒

pub use bpf_intf::*;

pub(crate) use scx_stats::prelude::*; 🔒

Modules

bpf_intf

bpf_skel 🔒

config 🔒

Validated scheduling constants for the flow scheduler.

imp

snapshot 🔒

Snapshot reads for the flow scheduler.

stats 🔒

Stats server for the flow scheduler.

topology 🔒

Topology view for the flow scheduler.

types

webui 🔒

Loopback dashboard for the flow scheduler.

Structs

BpfLinks

BpfMaps

BpfProgs

BpfSkel

BpfSkelBuilder

Config 🔒

Validated scheduling constants.

Metrics 🔒

Counters with placement, admission, and miss detail. BPF holds 17 counters, Rust adds display-only uptime for eighteen.

OpenBpfMaps

OpenBpfProgs

OpenBpfSkel

Opts 🔒

OwnedRef

Scheduler 🔒

StructOps

Constants

SCHEDULER_NAME 🔒

Statics

DATA

Functions

build_skel_config

full_version 🔒

main 🔒

poll_interval_secs 🔒

Validated poll interval from float seconds. Rejects NaN plus infinite plus non-positive plus over one hour, so a bad flag fails closed before any timer starts with no panic.