Struct location_manager::net::data_exchange_server::DataExchangeServer

pub(crate) struct DataExchangeServer {
    _mod_config: Config,
    object_tracker: Arc<ObjectTracker>,
    move_handles: Arc<MoveHandleMap>,
    signature_options: SignatureOptions,
}

Fields

_mod_config: Config

object_tracker: Arc<ObjectTracker>

move_handles: Arc<MoveHandleMap>

signature_options: SignatureOptions

Implementations

impl DataExchangeServer

pub fn new( mod_config: Config, object_tracker: Arc<ObjectTracker>, move_handles: Arc<MoveHandleMap> ) -> Self

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

async fn get_backing_storage_path(&self, object_id: ObjectId) -> Option<PathBuf>

async fn reload(&self, object_id: ObjectId) -> Result<(), Error>

async fn push_initial_version(&self, object_id: ObjectId) -> Result<(), Error>

Trait Implementations

impl DataExchange for DataExchangeServer

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

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