Crate byteor_pipeline_exec 

Executors (SP + SingleRing) and loop control.

This crate runs threads/loops. It must remain free of product policy.

Re-exports

pub use lane_graph::validate_sp;

pub use lane_graph::run_lane_graph_mp_role_shm;

pub use lane_graph::run_sp;

pub use lane_graph::spawn_lane_graph_sp_shm_runtime;

pub use lane_graph::spawn_lane_graph_sp_shm_runtime_with_thread_init;

pub use lane_graph::LaneGraphRoleActivitySnapshot;

pub use lane_graph::LaneGraphSpRuntime;

pub use lane_graph::SpShmOptions;

pub use single_ring::run_single_ring_shm;

pub use single_ring::run_single_ring_shm_per_key_sharded_with_wait;

pub use single_ring::run_single_ring_shm_per_key_sharded_with_wait_and_resolver;

pub use single_ring::run_single_ring_shm_per_key_sharded_with_wait_and_resolver_and_prefault;

pub use single_ring::run_single_ring_shm_per_key_sharded_with_wait_and_resolver_and_thread_init;

pub use single_ring::run_single_ring_shm_per_key_sharded_with_wait_and_resolver_and_thread_init_and_prefault;

pub use single_ring::run_single_ring_shm_record_with_wait_and_resolver_and_thread_init;

pub use single_ring::run_single_ring_shm_with_wait;

pub use single_ring::run_single_ring_shm_with_wait_and_resolver;

pub use single_ring::run_single_ring_shm_with_wait_and_resolver_and_prefault;

pub use single_ring::run_single_ring_shm_with_wait_and_resolver_and_thread_init;

pub use single_ring::run_single_ring_shm_with_wait_and_resolver_and_thread_init_and_prefault;

pub use single_ring::spawn_single_ring_shm_runtime;

pub use single_ring::spawn_single_ring_shm_runtime_with_wait;

pub use single_ring::spawn_single_ring_shm_runtime_with_wait_and_resolver;

pub use single_ring::spawn_single_ring_shm_runtime_with_wait_and_resolver_and_prefault;

pub use single_ring::spawn_single_ring_shm_runtime_with_wait_and_resolver_and_thread_init;

pub use single_ring::spawn_single_ring_shm_runtime_with_wait_and_resolver_and_thread_init_and_prefault;

pub use single_ring::SingleRingSpRuntime;

pub use single_ring::WaitPreset;

Modules

lane_graph

LaneGraph-oriented executor APIs.

single_ring

SingleRing-oriented executor APIs.

Structs

ExecError

Executor errors.

SliceStageRegistry

A minimal slice-based stage registry.

StageEntry

One named stage entry for use with SliceStageRegistry.

ThreadInitContext

Context passed to the thread init hook.

Enums

ResolvedStage

Resolved stage callable.

RoleKind

Role kind for thread init context.

Traits

StageResolver

Stage resolver used by executors.

StatefulStage

Stateful stage implementation.

StatefulTransformStage

Stateful transform stage implementation.

Functions

resolve_or_err

Resolve a stage by name or return an executor error.

Type Aliases

ResolvedStageFactory

Factory function for producing a ResolvedStage.

StageError

Cold-path stage error type.

StatefulStageBox

Convenience alias for the boxed stateful stage type.

StatefulTransformStageBox

Convenience alias for the boxed stateful transform stage type.

ThreadInitHook

Hook invoked at the start of an executor thread.