- 1
//! `vak-bus`: High-throughput distributed event & message fabric for massive agent swarms. - 2
//! - 3
//! Provides CloudEvents envelopes with W3C distributed tracing and Merkle causal hash chaining, - 4
//! zero-trust AES-256-GCM envelope payload encryption, deterministic subject algebra with - 5
//! role-based ACLs, and production NATS Core + JetStream as well as standalone concurrent engines. - 6
- 7
pub mod bus; - 8
pub mod crypto; - 9
pub mod envelope; - 10
pub mod subjects; - 11
pub mod telemetry; - 12
- 13
pub use bus::{ - 14
BusError, ClaimedTask, EventPublisher, EventSubscriber, InMemoryBus, NatsBus, NatsConfig, - 15
TaskAckHandle, WorkQueue, - 16
}; - 17
pub use crypto::{CryptoError, decrypt_envelope, derive_workspace_key, encrypt_envelope}; - 18
pub use envelope::{CausalLineage, EncryptionMeta, MessageEnvelope, TraceContext}; - 19
pub use subjects::{AclPolicy, Subject, SubjectError, matches_pattern}; - 20
pub use telemetry::{ - 21
BusMetrics, BusMetricsSnapshot, DeadLetterEvent, extract_trace_context, inject_trace_context, - 22
}; - 23
source · Rust
Lib
crates/vak-bus/src/lib.rs976 B23 linesSnapshot ed4ab258