Struct ControlServiceClient 

pub struct ControlServiceClient<Stub = Channel<ControlServiceRequest, ControlServiceResponse>>(/* private fields */);

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

Implementations

impl ControlServiceClient

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

where T: Transport<ClientMessage<ControlServiceRequest>, Response<ControlServiceResponse>>,

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

impl<Stub> ControlServiceClient<Stub>

where Stub: Stub<Req = ControlServiceRequest, Resp = ControlServiceResponse>,

pub fn resolve_addrs( &self, ctx: Context, peers: HashSet<AgentId>, ) -> impl Future<Output = Result<Result<HashMap<AgentId, IpAddr>, ResolveError>, RpcError>> + '_

Resolve the addresses of the given agents.

pub fn get_env_info( &self, ctx: Context, env_id: EnvId, ) -> impl Future<Output = Result<Option<EnvInfo>, RpcError>> + '_

Get the environment info for the given environment.

pub fn post_transfer_status( &self, ctx: Context, id: u32, status: TransferStatusUpdate, ) -> impl Future<Output = Result<(), RpcError>> + '_

Emit an agent transfer status update.

pub fn post_transfer_statuses( &self, ctx: Context, statuses: Vec<(u32, TransferStatus)>, ) -> impl Future<Output = Result<(), RpcError>> + '_

Emit current agent transfers. Will overwrite old status.

pub fn post_block_status( &self, ctx: Context, height: u32, timestamp: i64, state_root: String, block_hash: String, prev_block_hash: String, ) -> impl Future<Output = Result<(), RpcError>> + '_

Emit an agent block status update.

pub fn post_node_status( &self, ctx: Context, update: NodeStatus, ) -> impl Future<Output = Result<(), RpcError>> + '_

Emit an agent node status update.

Trait Implementations

impl<Stub: Clone> Clone for ControlServiceClient<Stub>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Stub: Debug> Debug for ControlServiceClient<Stub>

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

Formats the value using the given formatter.

impl<Stub> From<Stub> for ControlServiceClient<Stub>

where Stub: Stub<Req = ControlServiceRequest, Resp = ControlServiceResponse>,

fn from(stub: Stub) -> Self

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