Struct RemoteFragmentEndpoint 

pub struct RemoteFragmentEndpoint { /* private fields */ }

Worker-side endpoint for the internal fragment protocol.

The cluster transport supplies authenticated node-to-node delivery. This endpoint owns bounded active cursors and returns one Arrow IPC batch per pull. Pull framing provides backpressure without buffering a whole result on either peer.

Implementations

impl RemoteFragmentEndpoint

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

Creates a bounded worker endpoint.

pub fn with_limits( executor: Arc<dyn FragmentExecutor>, max_executions: usize, max_message_bytes: usize, ) -> Self

Creates a worker endpoint with explicit cursor and frame bounds.

pub fn active_executions(&self) -> usize

Number of live remote fragment cursors.

pub fn lifecycle_metrics(&self) -> FragmentLifecycleSnapshot

Fragment lifecycle metrics including active cursor count (P0.4-T6).

pub async fn handle(&self, bytes: &[u8]) -> DistributedResult<Vec<u8>>

Handles one authenticated internal RPC body.