Enum BThreadRule 

pub enum BThreadRule {
    Mutex {
        scope: EventPattern,
        key: String,
        ttl_secs: Option<u64>,
    },
    Require {
        trigger: EventPattern,
        prerequisite: EventPattern,
        reset: Option<EventPattern>,
    },
    BlockUntil {
        trigger: EventPattern,
        block: Vec<EventPattern>,
        until: EventPattern,
        escalate: bool,
        escalation_message: Option<String>,
    },
    BlockAlways {
        scope: EventPattern,
    },
    RateLimit {
        scope: EventPattern,
        max: u32,
        window_secs: u64,
    },
    Timeout {
        scope: EventPattern,
        max_duration_secs: u64,
        action: TimeoutAction,
    },
    Partition {
        scope: EventPattern,
        strategy: PartitionStrategy,
        agent_count: u32,
    },
}

Rule types for b-thread coordination.

Variants

Mutex

Only one agent can hold a resource at a time.

Fields

scope: EventPattern

key: String

Template key, e.g. “file:{target}” or “schema-global”

ttl_secs: Option<u64>

Require

Action X requires prior event Y (with optional reset).

Fields

trigger: EventPattern

prerequisite: EventPattern

reset: Option<EventPattern>

BlockUntil

Block event Y after event X until event Z occurs.

Fields

trigger: EventPattern

block: Vec<EventPattern>

until: EventPattern

escalate: bool

escalation_message: Option<String>

BlockAlways

Unconditionally block matching events.

Fields

scope: EventPattern

RateLimit

Max N events in a time window.

Fields

scope: EventPattern

max: u32

window_secs: u64

Timeout

Kill operations exceeding a time budget.

Fields

scope: EventPattern

max_duration_secs: u64

action: TimeoutAction

Partition

Deterministic work sharding across agents.

Fields

scope: EventPattern

strategy: PartitionStrategy

agent_count: u32

Implementations

impl BThreadRule

pub fn parse(rule_type: &str, spec: &str) -> Result<BThreadRule, Error>

Parse a rule from its type name and spec string.

The spec is space-separated key=value pairs. Example: kind=FileWrite key=file:{target} with rule_type=“Mutex”

Trait Implementations

impl Clone for BThreadRule

fn clone(&self) -> BThreadRule

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BThreadRule

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BThreadRule

fn deserialize<__D>( __deserializer: __D, ) -> Result<BThreadRule, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BThreadRule

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.