Crate actionqueue_budget 

Budget enforcement and event subscription primitives for ActionQueue.

This crate provides the in-memory budget tracking and event subscription matching logic that Caelum uses for Cognitive Thread budget enforcement, preemptibility, and reactive coordination.

Architecture

The actionqueue-budget crate is intentionally small: it provides pure in-memory data structures reconstructed from WAL-sourced events. All durability is handled by actionqueue-storage; this crate depends only on actionqueue-core for domain types.

Components

• tracker::BudgetTracker — per-task budget state (allocations, consumption)
• gate::BudgetGate — pre-dispatch eligibility check
• subscription::registry::SubscriptionRegistry — active subscription state
• subscription::matcher::check_event — event-to-subscription matching

Re-exports

pub use gate::BudgetGate;

pub use subscription::registry::SubscriptionRegistry;

pub use tracker::BudgetState;

pub use tracker::BudgetTracker;

pub use tracker::ConsumeResult;

Modules

gate

Pre-dispatch budget gate.

subscription

Event subscription submodule.

tracker

Per-task budget state tracking.

Enums

ActionQueueEvent

An event that occurred within the dispatch loop, evaluated against subscriptions.

Traits

SubscriptionSource

Trait for types that expose active subscription filters.

Functions

check_event

Checks a ActionQueueEvent against all active subscriptions in registry.