Struct CapabilityRequirement 

#[non_exhaustive]
pub struct CapabilityRequirement {
    pub tokens: BTreeSet<String>,
}

A pre-parsed capability requirement (the “execution requires X” shape).

Thin newtype over a sorted token set — sorted so CSV serialization is deterministic and log correlation is stable. The Valkey wire form is the CSV join of this set; the Postgres wire form is the text[] projection of tokens.

Constructed via CapabilityRequirement::new or parsed from CSV via CapabilityRequirement::from_csv. The struct is #[non_exhaustive] — additions (e.g. semver predicates, tier hints) land additively.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

tokens: BTreeSet<String>

Required tokens. Empty → match any worker.

Implementations

impl CapabilityRequirement

pub fn new<I, S>(tokens: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Build from any iterable of string-like tokens.

Empty strings are dropped (they can’t satisfy anything and would pollute the CSV form). Duplicates collapse via the BTreeSet.

pub fn from_csv(csv: &str) -> Self

Parse from the Valkey wire form: comma-separated tokens.

Mirrors Lua parse_capability_csv in lua/scheduling.lua: empty tokens (from ",gpu,,cuda,") are dropped. No validation of token contents — that’s ingress’s job (see ff-scheduler::claim and ff-sdk::FlowFabricWorker::connect).

pub fn is_empty(&self) -> bool

True iff no tokens are required (matches any worker).

Trait Implementations

impl Clone for CapabilityRequirement

fn clone(&self) -> CapabilityRequirement

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CapabilityRequirement

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CapabilityRequirement

fn default() -> CapabilityRequirement

Returns the “default value” for a type.

impl PartialEq for CapabilityRequirement

fn eq(&self, other: &CapabilityRequirement) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for CapabilityRequirement

impl StructuralPartialEq for CapabilityRequirement