Skip to main content

FileStore

Struct FileStore 

Source
pub struct FileStore { /* private fields */ }
Expand description

OpenDAL-backed file storage for the proxy server.

Supports any OpenDAL backend (memory, S3, GCS, local filesystem, etc.) through the FileStorageConfig backend configuration.

Implementations§

Source§

impl FileStore

Source

pub fn from_config(config: &FileStorageConfig) -> Result<Self, String>

Build a FileStore from proxy file storage configuration.

Parses the backend scheme from config.backend, builds an OpenDAL operator with the provided backend_config, and stores config.prefix for path prefixing.

§Errors

Returns an error string if the scheme is unknown or the operator cannot be constructed.

Source

pub async fn write(&self, key: &str, data: Bytes) -> Result<(), String>

Write data to the store under the given key.

§Errors

Returns an error string if the write operation fails.

Source

pub async fn read(&self, key: &str) -> Result<Bytes, String>

Read data from the store for the given key.

§Errors

Returns an error string if the key does not exist or the read fails.

Source

pub async fn delete(&self, key: &str) -> Result<(), String>

Delete a key from the store.

§Errors

Returns an error string if the delete operation fails.

Source

pub async fn list(&self, prefix: Option<&str>) -> Result<Vec<String>, String>

List keys under an optional prefix (relative to the store prefix).

Returns the full key paths (without the store prefix).

§Errors

Returns an error string if the list operation fails.

Source

pub async fn exists(&self, key: &str) -> Result<bool, String>

Check whether a key exists in the store.

§Errors

Returns an error string if the existence check fails.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

Source§

impl<T> MaybeSend for T
where T: Send,