Struct NodeSessionManagerHandle 

pub struct NodeSessionManagerHandle { /* private fields */ }

Implementations

impl NodeSessionManagerHandle

pub async fn shutdown(&self)

pub async fn allocate_shard( &self, node_id: &str, type_name: String, shard_id: String, timeout: Duration, ) -> Result<ShardAllocation, String>

pub async fn remember_shard_allocations( &self, node_id: &str, table: ShardAllocationTable, timeout: Duration, ) -> Result<(), String>

pub async fn get_shard_allocations( &self, node_id: &str, type_name: String, timeout: Duration, ) -> Result<ShardAllocationTable, String>

pub async fn forward_shard_envelopes( &self, node_id: &str, batch: ForwardShardEnvelopes, timeout: Duration, ) -> Result<ShardEnvelopeBatchResult, String>

pub async fn complete_sharding_ask( &self, node_id: &str, response: CompleteShardingAsk, timeout: Duration, ) -> Result<(), String>

pub async fn forward_shard_pipe_envelopes( &self, node_id: &str, batch: ForwardShardEnvelopes, ) -> Result<(), String>

pub async fn complete_sharding_ask_pipe( &self, node_id: &str, response: CompleteShardingAsk, ) -> Result<(), String>

pub fn try_complete_sharding_ask_pipe( &self, node_id: &str, response: CompleteShardingAsk, ) -> Result<(), String>

Trait Implementations

impl Clone for NodeSessionManagerHandle

fn clone(&self) -> NodeSessionManagerHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.