byteflow-actors 0.9.2

Embeddable flow runtime: M:N scheduler, Atomic Hop (Message+Cap), supervisor — use byteflow::
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! M:N **flows**, mailboxes, timer, supervisor and [`Runtime`].
//!
//! A **flow** is Byteflow's unit of concurrent work (not an OS thread). Flows
//! exchange **Atomic Hops** ([`crate::Value::Message`]) — never bare scalars
//! on bytecode `Send` / `Ask`.
//!
//! # Authority boundary
//!
//! The VM only validates types. This module owns delivery:
//!
//! 1. Resolve [`crate::Value::Cap`] → [`FlowId`] + rights ([`CapRights`])
//! 2. Stamp `Message.sender` and mint `reply_cap` (SEND-only)
//! 3. Push into the target [`Mailbox`] (bounded; anti lost-wakeup under one mutex)
//!
//! [`crate::Value::Pid`] is identity inside hops, not an ambient address.
//! Host [`Runtime::send`] takes [`FlowId`] directly (trusted).
//!
//! See [`crate::docs::security`] and [`crate::docs::atomic_hop`].

mod capability;
mod directory;
mod error;
mod finalize;
mod handle;
mod link;
mod link_admin;
mod monitor;
mod registry;
#[cfg(feature = "jit")]
mod jit;
mod mailbox;
mod metrics;
pub(crate) mod oneshot;
mod process;
mod quota;
mod runtime;
mod spawn;
mod delegate;
mod supervisor;
mod sync_lock;
mod timer;
mod worker;

pub use capability::{CapError, CapRights, Capability};
pub use quota::{FlowQuota, QuotaConfig, QuotaError};
pub use delegate::{exec_delegate, DelegateError};
pub use link_admin::{check_admin, check_link, check_monitor, AdminError, LinkError};
pub use error::{fault_count, report_fault, LifecycleError, RuntimeError, SpawnError};
pub use link::LinkId;
pub use monitor::{DownEvent, FlowExitReason, MonitorRef};
pub use registry::RegistryName;
pub use handle::FlowHandle;
pub use mailbox::{
    Delivery, Mailbox, MailboxBytes, MailboxCapacity, MailboxConfig, MailboxFull,
    MailboxFullReason, MailboxStats, OverflowPolicy, WaitEpoch,
};
pub use metrics::{RuntimeMetrics, RuntimeMetricsSnapshot};
pub use process::{
    next_flow_id, Flow, FlowId, FlowMetrics, FlowOutcome, RestartPolicy,
};
pub use runtime::{
    flow_id_from_u64, Runtime, RuntimeConfig, RuntimeSpawner, SendError, DEFAULT_QUANTUM,
};
#[cfg(feature = "jit")]
pub use runtime::JitConfig;
pub use supervisor::{ChildSpec, RestartStrategy, Supervisor, SupervisorConfig};