async fn create_replica(
        &self,
        request: &CreateReplica,
    ) -> Result<Replica, SvcError> {
        let mut ctx = self.grpc_client().await?;
        let rpc_replica = ctx
            .client
            .create_replica(bus_replica_to_rpc(request))
            .await
            .context(GrpcCreateReplica {})?;

        Ok(rpc_replica_to_bus(&rpc_replica.into_inner(), self.id()))
    }
/// Create a replica on the pool via gRPC
Create a replica on the pool via gRPC
Create a replica on the pool via gRPC
async fn create_replica(
        &self,
        request: &CreateReplica,
    ) -> Result<Replica, SvcError> {
        let mut ctx = self.grpc_client().await?;
        let rpc_replica = ctx
            .client
            .create_replica(bus_replica_to_rpc(request))
            .await
            .context(GrpcCreateReplica {})?;
        Ok(rpc_replica_to_bus(&rpc_replica.into_inner(), self.id()))
    }
async fn create_replica ( & self , request : & CreateReplica , ) -> Result < Replica , SvcError > { let mut ctx = self . grpc_client ( ) . await ? ; let rpc_replica = ctx . client . create_replica ( bus_replica_to_rpc ( request ) ) . await . context ( GrpcCreateReplica { } ) ? ; Ok ( rpc_replica_to_bus ( & rpc_replica . into_inner ( ) , self . id ( ) ) ) }
Create a replica on the pool via gRPC
Create a replica on the pool via gRPC
&self
request
&CreateReplica