Struct InMemoryTransport 

pub struct InMemoryTransport { /* private fields */ }

In-memory FragmentTransport: routes fragments to per-tablet executors, records starts/cancellations/refills for test introspection, and keeps each fragment’s ExecutionControl so cancellations are observable.

Implementations

impl InMemoryTransport

pub fn new(default_executor: Arc<dyn FragmentExecutor>) -> Self

A transport whose every fragment runs on default_executor.

pub fn with_executor( self, tablet: TabletId, executor: Arc<dyn FragmentExecutor>, ) -> Self

Pins one tablet to its own executor.

pub fn started_fragments(&self) -> Vec<FragmentId>

Fragments started so far, in start order.

pub fn cancelled_fragments(&self) -> Vec<FragmentId>

Fragments cancelled so far, in cancel order.

pub fn refill_log(&self) -> Vec<(FragmentId, usize, usize)>

Top-k refills issued so far: (fragment_id, offset, limit).

pub fn control_for(&self, fragment_id: FragmentId) -> Option<ExecutionControl>

The control handed to a started fragment, for cancellation assertions.

Trait Implementations

impl FragmentTransport for InMemoryTransport

fn execute_fragment<'life0, 'life1, 'async_trait>( &'life0 self, fragment: &'life1 PlanFragment, inputs: Vec<FragmentStream>, control: FragmentControl, ) -> Pin<Box<dyn Future<Output = DistributedResult<FragmentStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Starts a fragment on its assigned worker and returns its output stream.

fn cancel_fragment(&self, fragment_id: FragmentId) -> DistributedResult<()>

Best-effort cancellation of a running (or abandoned) fragment.

fn refill_top_k( &self, fragment: &PlanFragment, offset: usize, limit: usize, ) -> DistributedResult<TopKRefill>

Fetches the next top-k batch of a fragment’s tablet (adaptive refill). Transports without a refill binding leave the default.