Struct FsProvider

pub struct FsProvider { /* private fields */ }

fs capability provider implementation

Implementations

impl FsProvider

pub async fn run() -> Result<()>

Trait Implementations

impl Clone for FsProvider

fn clone(&self) -> FsProvider

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for FsProvider

fn default() -> FsProvider

Returns the “default value” for a type.

impl Handler<Option<Context>> for FsProvider

async fn clear_container( &self, cx: Option<Context>, name: String, ) -> Result<Result<(), String>>

async fn container_exists( &self, cx: Option<Context>, name: String, ) -> Result<Result<bool, String>>

async fn create_container( &self, cx: Option<Context>, name: String, ) -> Result<Result<(), String>>

async fn delete_container( &self, cx: Option<Context>, name: String, ) -> Result<Result<(), String>>

async fn get_container_info( &self, cx: Option<Context>, name: String, ) -> Result<Result<ContainerMetadata, String>>

async fn list_container_objects( &self, cx: Option<Context>, name: String, limit: Option<u64>, offset: Option<u64>, ) -> Result<Result<(Pin<Box<dyn Stream<Item = Vec<String>> + Send>>, Pin<Box<dyn Future<Output = Result<(), String>> + Send>>), String>>

async fn copy_object( &self, cx: Option<Context>, src: ObjectId, dest: ObjectId, ) -> Result<Result<(), String>>

async fn delete_object( &self, cx: Option<Context>, id: ObjectId, ) -> Result<Result<(), String>>

async fn delete_objects( &self, cx: Option<Context>, container: String, objects: Vec<String>, ) -> Result<Result<(), String>>

async fn get_container_data( &self, cx: Option<Context>, id: ObjectId, start: u64, end: u64, ) -> Result<Result<(Pin<Box<dyn Stream<Item = Bytes> + Send>>, Pin<Box<dyn Future<Output = Result<(), String>> + Send>>), String>>

async fn get_object_info( &self, cx: Option<Context>, id: ObjectId, ) -> Result<Result<ObjectMetadata, String>>

async fn has_object( &self, cx: Option<Context>, id: ObjectId, ) -> Result<Result<bool, String>>

async fn move_object( &self, cx: Option<Context>, src: ObjectId, dest: ObjectId, ) -> Result<Result<(), String>>

async fn write_container_data( &self, cx: Option<Context>, id: ObjectId, data: Pin<Box<dyn Stream<Item = Bytes> + Send>>, ) -> Result<Result<Pin<Box<dyn Future<Output = Result<(), String>> + Send>>, String>>

impl Provider for FsProvider

async fn receive_link_config_as_target( &self, __arg1: LinkConfig<'_>, ) -> Result<()>

The fs provider has one configuration parameter, the root of the file system

async fn delete_link_as_target(&self, info: impl LinkDeleteInfo) -> Result<()>

Notify the provider that the link is dropped where the provider is the target

async fn shutdown(&self) -> Result<()>

Handle system shutdown message

fn init( &self, init_config: impl ProviderInitConfig, ) -> impl Future<Output = Result<(), E>> + Send

Initialize the provider

fn on_config_update( &self, update: impl ProviderConfigUpdate, ) -> impl Future<Output = Result<(), E>> + Send

Process a configuration update for the provider

fn receive_link_config_as_source( &self, config: LinkConfig<'_>, ) -> impl Future<Output = Result<(), E>> + Send

Receive and handle a link that has been established on the lattice where this provider is the source.

fn delete_link_as_source( &self, _info: impl LinkDeleteInfo, ) -> impl Future<Output = Result<(), E>> + Send

Notify the provider that the link is dropped where the provider is the source

fn health_request( &self, _arg: &HealthCheckRequest, ) -> impl Future<Output = Result<HealthCheckResponse, E>> + Send

Perform health check. Called at regular intervals by host Default implementation always returns healthy