Struct location_manager::net::data_request_server::DataRequestServer

pub struct DataRequestServer {
    mod_config: Config,
    object_tracker: Arc<ObjectTracker>,
    move_handles: Arc<MoveHandleMap>,
    data_request_client: Arc<DataRequestClient>,
    data_exchange_client: Arc<DataExchangeClient>,
    signature_options: SignatureOptions,
    async_rt_manager: Arc<AsyncRuntimeManager>,
}

Fields

mod_config: Config

object_tracker: Arc<ObjectTracker>

move_handles: Arc<MoveHandleMap>

data_request_client: Arc<DataRequestClient>

data_exchange_client: Arc<DataExchangeClient>

signature_options: SignatureOptions

async_rt_manager: Arc<AsyncRuntimeManager>

Implementations

impl DataRequestServer

pub fn new( mod_config: Config, object_tracker: Arc<ObjectTracker>, move_handles: Arc<MoveHandleMap>, data_request_client: AsyncArc<DataRequestClient>, data_exchange_client: AsyncArc<DataExchangeClient>, config: &RSyncConfig, async_rt_manager: Arc<AsyncRuntimeManager> ) -> Self

async fn get_object_bytes(&self, object_id: ObjectId) -> Option<Vec<u8>>

async fn get_move_status(&self, object_id: ObjectId) -> Option<ObjectMoveStatus>

Trait Implementations

impl DataRequest for DataRequestServer

fn get_move_status<'life0, 'async_trait>( &'life0 self, request: Request<ProtoObjectMoveHandle> ) -> Pin<Box<dyn Future<Output = Result<Response<ProtoObjectMoveHandle>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn move_object<'life0, 'async_trait>( &'life0 self, request: Request<MoveProperties> ) -> Pin<Box<dyn Future<Output = Result<Response<ProtoObjectMoveHandle>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn trigger_move<'life0, 'async_trait>( &'life0 self, request: Request<TriggerMoveProperties> ) -> Pin<Box<dyn Future<Output = Result<Response<ProtoObjectMoveHandle>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,