Struct ShardServiceClient 

pub struct ShardServiceClient<Stub = Channel<ShardServiceRequest, ShardServiceResponse>>(/* private fields */);

The client stub that makes RPC calls to the server. All request methods return Futures.

Implementations

impl ShardServiceClient

pub fn new<T>( config: Config, transport: T, ) -> NewClient<Self, RequestDispatch<ShardServiceRequest, ShardServiceResponse, T>>

where T: Transport<ClientMessage<ShardServiceRequest>, Response<ShardServiceResponse>>,

Returns a new client stub that sends requests over the given transport.

impl<Stub> ShardServiceClient<Stub>

where Stub: Stub<Req = ShardServiceRequest, Resp = ShardServiceResponse>,

pub fn ingest_document( &self, ctx: Context, doc: Document, ) -> impl Future<Output = Result<RpcResult<DocumentId>, RpcError>> + '_

Ingest a document into this shard.

The document will be processed by local agents during the next tick. Returns the document ID assigned to the ingested document.

pub fn tick_phase( &self, ctx: Context, phase: TickPhase, tick: u64, ) -> impl Future<Output = Result<RpcResult<PhaseResult>, RpcError>> + '_

Execute a tick phase on this shard.

Phases are executed in order: Sense -> Act -> Decay -> Advance. Each phase must complete on all shards before the next phase begins (barrier sync).

pub fn local_query( &self, ctx: Context, req: LocalQueryRequest, ) -> impl Future<Output = Result<RpcResult<LocalQueryResult>, RpcError>> + '_

Execute a local query (part of distributed query).

Returns matching nodes from this shard’s portion of the graph. Results are combined by the coordinator using scatter-gather.

pub fn get_term_frequencies( &self, ctx: Context, terms: Vec<String>, ) -> impl Future<Output = Result<RpcResult<HashMap<String, u64>>, RpcError>> + '_

Get term frequencies for global DF computation.

Returns a map of term -> document frequency for TF-IDF calculation. Used during global DF aggregation for TF-IDF scoring.

pub fn get_node( &self, ctx: Context, id: NodeId, ) -> impl Future<Output = Result<RpcResult<Option<NodeData>>, RpcError>> + '_

Fetch a node’s full data (for ghost node resolution).

Used when a shard needs detailed information about a node that exists on another shard.

pub fn health_check( &self, ctx: Context, ) -> impl Future<Output = Result<RpcResult<ShardHealth>, RpcError>> + '_

Health check.

Returns the current health status of this shard including resource usage and processing statistics.

pub fn resolve_ghost_nodes( &self, ctx: Context, node_ids: Vec<NodeId>, ) -> impl Future<Output = Result<RpcResult<Vec<GhostNode>>, RpcError>> + '_

Resolve cross-shard edges by fetching ghost node data.

Batch operation to fetch data for multiple nodes at once, creating ghost node representations for cross-shard edges.

pub fn get_neighbors( &self, ctx: Context, node_id: NodeId, ) -> impl Future<Output = Result<RpcResult<Vec<NodeId>>, RpcError>> + '_

Get the list of nodes connected to a given node.

Returns node IDs of all neighbors, including cross-shard references.

pub fn receive_signals( &self, ctx: Context, signals: Vec<CrossShardSignal>, ) -> impl Future<Output = Result<RpcResult<()>, RpcError>> + '_

Receive cross-shard signals during the Exchange phase.

Signals from other shards are delivered here for local processing.

Trait Implementations

impl<Stub: Clone> Clone for ShardServiceClient<Stub>

fn clone(&self) -> ShardServiceClient<Stub>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Stub: Debug> Debug for ShardServiceClient<Stub>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Stub> From<Stub> for ShardServiceClient<Stub>

where Stub: Stub<Req = ShardServiceRequest, Resp = ShardServiceResponse>,

fn from(stub: Stub) -> Self

Returns a new client stub that sends requests over the given transport.