Struct CoordinatorServer 

pub struct CoordinatorServer { /* private fields */ }

Server implementation for the coordinator.

CoordinatorServer wraps a Coordinator and implements the CoordinatorService trait, allowing shards and clients to interact with the coordinator via tarpc RPC.

Thread Safety

The coordinator is wrapped in Arc as it uses interior mutability (RwLock, AtomicU64) for thread-safe access.

Example

use phago_distributed::rpc::server::CoordinatorServer;
use phago_distributed::coordinator::Coordinator;

let coordinator = Arc::new(Coordinator::new(3));
let server = CoordinatorServer::new(coordinator);
server.serve("127.0.0.1:8080".parse().unwrap()).await?;

Implementations

impl CoordinatorServer

pub fn new(coordinator: Arc<Coordinator>) -> Self

Create a new coordinator server.

Arguments

• coordinator - The coordinator to serve

pub async fn start(self, addr: SocketAddr) -> Result<(), Error>

Start serving on the given address.

Arguments

• addr - The socket address to bind to

Errors

Returns an error if the server fails to bind to the address.

Trait Implementations

impl Clone for CoordinatorServer

fn clone(&self) -> CoordinatorServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CoordinatorService for CoordinatorServer

async fn register(self, _ctx: Context, info: ShardInfo) -> RpcResult<ShardId>

Register a new shard with the coordinator.

async fn unregister(self, _ctx: Context, shard_id: ShardId) -> RpcResult<()>

Unregister a shard from the coordinator.

async fn phase_complete( self, _ctx: Context, shard_id: ShardId, phase: TickPhase, tick: u64, ) -> RpcResult<()>

Report that a shard has completed a tick phase.

async fn route_document(self, _ctx: Context, doc_id: DocumentId) -> ShardId

Get the shard responsible for a document.

async fn route_node(self, _ctx: Context, node_id: NodeId) -> ShardId

Get the shard responsible for a node.

async fn get_global_df( self, _ctx: Context, terms: Vec<String>, ) -> RpcResult<HashMap<String, u64>>

Get global document frequencies for TF-IDF.

async fn barrier_ready( self, _ctx: Context, shard_id: ShardId, phase: TickPhase, tick: u64, ) -> RpcResult<bool>

Signal ready for next phase (barrier).

async fn current_tick(self, _ctx: Context) -> u64

Get current tick number.

async fn list_shards(self, _ctx: Context) -> Vec<ShardInfo>

Get all registered shards.

async fn start_tick(self, _ctx: Context) -> RpcResult<u64>

Request to start a new tick.

async fn tick_status(self, _ctx: Context) -> RpcResult<TickStatus>

Get the status of the current tick.

fn serve(self) -> ServeCoordinatorService<Self>

Returns a serving function to use with InFlightRequest::execute.