taktora_executor/
lib.rs

1//! # taktora-executor
2//!
3//! Execution framework on top of [iceoryx2](https://docs.rs/iceoryx2).
4//! Provides:
5//!
6//! * [`ExecutableItem`] — the unit of work the executor schedules.
7//! * [`Executor`] / [`Runner`] — the run loop and a dedicated-thread host.
8//! * [`Channel<T>`](Channel) / [`Service`] — pub/sub and request-response primitives
9//!   with paired event services so subscribers wake on send.
10//! * Sequential [chains](Executor::add_chain) and parallel
11//!   [graphs](Executor::add_graph).
12//! * Signal/slot via [`signal_slot::pair`].
13//! * Lifecycle hooks via [`Observer`] and timing hooks via
14//!   [`ExecutionMonitor`].
15//!
16//! See the workspace `README.md` for a quick-start.
17#![doc(html_root_url = "https://docs.rs/taktora-executor/0.1.0")]
18#![cfg_attr(docsrs, feature(doc_cfg))]
19
20mod chain;
21mod channel;
22mod condition;
23mod context;
24mod control_flow;
25mod error;
26mod executor;
27mod fault;
28mod graph;
29mod item;
30mod monitor;
31mod observer;
32mod payload;
33mod pool;
34mod ready_ring;
35mod runner;
36mod service;
37pub mod signal_slot;
38mod task_id;
39mod task_kind;
40mod thread_attrs;
41mod trigger;
42
43pub use channel::{Channel, EVENT_SUFFIX, NotifyOutcome, Publisher, Subscriber};
44pub use condition::{Conditional, wrap_with_condition};
45pub use context::{Context, Stoppable};
46pub use control_flow::{ControlFlow, ExecuteResult};
47pub use error::{ExecutorError, ItemError};
48pub use executor::{Executor, ExecutorBuilder, ExecutorGraphBuilder};
49pub use fault::{ExecutorFaultReason, ExecutorFaultState, FaultReason, FaultState};
50pub use graph::{GraphBuilder, Vertex};
51pub use item::{ExecutableItem, FnItem, FnItemWithTriggers, item, item_with_triggers};
52pub use monitor::ExecutionMonitor;
53pub use observer::{Observer, UserEvent};
54pub use payload::Payload;
55pub use runner::{Runner, RunnerFlags};
56pub use service::{
57    ActiveRequest, Client, PendingRequest, REQ_EVENT_SUFFIX, RESP_EVENT_SUFFIX, Server, Service,
58};
59pub use task_id::TaskId;
60pub use thread_attrs::ThreadAttributes;
61pub use trigger::{RawListener, TriggerDeclarer};
taktora_executor/lib.rs

taktora_executor/
lib.rs
