Module single_ring 

SingleRing-oriented executor APIs.

Structs

SingleRingSpRuntime

In-process SP runtime handle for SingleRing SHM execution.

Enums

WaitPreset

Wait/backoff policy presets for SingleRing hot loops.

Functions

run_single_ring_shm

Run a SingleRing spec over a SHM SequencedSlots backing.

run_single_ring_shm_per_key_sharded_with_wait

Run a PerKey-sharded SingleRing spec by partitioning input by shard key.

run_single_ring_shm_per_key_sharded_with_wait_and_resolver

Run a PerKey-sharded SingleRing spec by partitioning input by shard key, resolving any ResolverKey stages using resolver (cold path).

run_single_ring_shm_per_key_sharded_with_wait_and_resolver_and_prefault

Run a PerKey-sharded SingleRing spec by partitioning input by shard key, resolving any ResolverKey stages using resolver (cold path), with explicit control over SHM prefault.

run_single_ring_shm_per_key_sharded_with_wait_and_resolver_and_thread_init

Run a PerKey-sharded SingleRing spec by partitioning input by shard key, resolving any ResolverKey stages using resolver (cold path), and invoking thread_init for each stage thread (within each shard’s executor).

run_single_ring_shm_per_key_sharded_with_wait_and_resolver_and_thread_init_and_prefault

Run a PerKey-sharded SingleRing spec by partitioning input by shard key, resolving any ResolverKey stages using resolver (cold path), invoking thread_init for each stage thread, and explicitly controlling SHM prefault.

run_single_ring_shm_record_with_wait_and_resolver_and_thread_init

Run a SingleRing spec over a SHM SequencedSlots backing treating input as a single record.

run_single_ring_shm_with_wait

Run a SingleRing spec over a SHM SequencedSlots backing, using a wait preset.

run_single_ring_shm_with_wait_and_resolver

Run a SingleRing spec over a SHM SequencedSlots backing, resolving any ResolverKey stages using resolver (cold path).

run_single_ring_shm_with_wait_and_resolver_and_prefault

Run a SingleRing spec over a SHM SequencedSlots backing, resolving any ResolverKey stages using resolver (cold path), with explicit control over SHM prefault.

run_single_ring_shm_with_wait_and_resolver_and_thread_init

Run a SingleRing spec over a SHM SequencedSlots backing, resolving any ResolverKey stages using resolver (cold path) and invoking thread_init at the start of each stage thread.

run_single_ring_shm_with_wait_and_resolver_and_thread_init_and_prefault

Run a SingleRing spec over a SHM SequencedSlots backing, resolving any ResolverKey stages using resolver (cold path) and invoking thread_init at the start of each stage thread, with explicit control over SHM prefault.

spawn_single_ring_shm_runtime

Spawn a long-running SingleRing runtime that processes until stopped.

spawn_single_ring_shm_runtime_with_wait

Spawn a long-running SingleRing runtime that processes until stopped, using a wait preset.

spawn_single_ring_shm_runtime_with_wait_and_resolver

Spawn a long-running SingleRing runtime that processes until stopped, resolving any ResolverKey stages using resolver (cold path).

spawn_single_ring_shm_runtime_with_wait_and_resolver_and_prefault

Spawn a long-running SingleRing runtime that processes until stopped, resolving any ResolverKey stages using resolver (cold path), with explicit control over SHM prefault.

spawn_single_ring_shm_runtime_with_wait_and_resolver_and_thread_init

Spawn a long-running SingleRing runtime that processes until stopped, resolving any ResolverKey stages using resolver (cold path) and invoking thread_init at the start of each stage thread (before entering hot loops).

spawn_single_ring_shm_runtime_with_wait_and_resolver_and_thread_init_and_prefault

Spawn a long-running SingleRing runtime that processes until stopped, resolving any ResolverKey stages using resolver (cold path) and invoking thread_init at the start of each stage thread (before entering hot loops), with explicit control over SHM prefault.