pub struct FuseMount {
pub mount_id: DUuid,
pub bucket_id: DUuid,
pub mount_point: String,
pub enabled: DBool,
pub auto_mount: DBool,
pub read_only: DBool,
pub cache_size_mb: i64,
pub cache_ttl_secs: i64,
pub status: MountStatus,
pub error_message: Option<String>,
pub created_at: OffsetDateTime,
pub updated_at: OffsetDateTime,
}Expand description
FUSE mount configuration stored in database
Fields§
§mount_id: DUuid§bucket_id: DUuid§mount_point: String§enabled: DBool§auto_mount: DBool§read_only: DBool§cache_size_mb: i64§cache_ttl_secs: i64§status: MountStatus§error_message: Option<String>§created_at: OffsetDateTime§updated_at: OffsetDateTimeImplementations§
Source§impl FuseMount
impl FuseMount
Sourcepub async fn create(
bucket_id: Uuid,
mount_point: &str,
auto_mount: bool,
read_only: bool,
cache_size_mb: Option<i64>,
cache_ttl_secs: Option<i64>,
db: &Database,
) -> Result<FuseMount, Error>
pub async fn create( bucket_id: Uuid, mount_point: &str, auto_mount: bool, read_only: bool, cache_size_mb: Option<i64>, cache_ttl_secs: Option<i64>, db: &Database, ) -> Result<FuseMount, Error>
Create a new FUSE mount configuration
Sourcepub async fn get(
mount_id: Uuid,
db: &Database,
) -> Result<Option<FuseMount>, Error>
pub async fn get( mount_id: Uuid, db: &Database, ) -> Result<Option<FuseMount>, Error>
Get a FUSE mount by ID
Sourcepub async fn update(
mount_id: Uuid,
mount_point: Option<&str>,
enabled: Option<bool>,
auto_mount: Option<bool>,
read_only: Option<bool>,
cache_size_mb: Option<i64>,
cache_ttl_secs: Option<i64>,
db: &Database,
) -> Result<Option<FuseMount>, Error>
pub async fn update( mount_id: Uuid, mount_point: Option<&str>, enabled: Option<bool>, auto_mount: Option<bool>, read_only: Option<bool>, cache_size_mb: Option<i64>, cache_ttl_secs: Option<i64>, db: &Database, ) -> Result<Option<FuseMount>, Error>
Update a FUSE mount configuration
Sourcepub async fn update_status(
mount_id: Uuid,
status: MountStatus,
error_message: Option<&str>,
db: &Database,
) -> Result<bool, Error>
pub async fn update_status( mount_id: Uuid, status: MountStatus, error_message: Option<&str>, db: &Database, ) -> Result<bool, Error>
Update the status of a FUSE mount
Trait Implementations§
Source§impl<'de> Deserialize<'de> for FuseMount
impl<'de> Deserialize<'de> for FuseMount
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl<'a, R: Row> FromRow<'a, R> for FuseMountwhere
&'a str: ColumnIndex<R>,
DUuid: Decode<'a, R::Database> + Type<R::Database>,
String: Decode<'a, R::Database> + Type<R::Database>,
DBool: Decode<'a, R::Database> + Type<R::Database>,
i64: Decode<'a, R::Database> + Type<R::Database>,
MountStatus: Decode<'a, R::Database> + Type<R::Database>,
Option<String>: Decode<'a, R::Database> + Type<R::Database>,
OffsetDateTime: Decode<'a, R::Database> + Type<R::Database>,
impl<'a, R: Row> FromRow<'a, R> for FuseMountwhere
&'a str: ColumnIndex<R>,
DUuid: Decode<'a, R::Database> + Type<R::Database>,
String: Decode<'a, R::Database> + Type<R::Database>,
DBool: Decode<'a, R::Database> + Type<R::Database>,
i64: Decode<'a, R::Database> + Type<R::Database>,
MountStatus: Decode<'a, R::Database> + Type<R::Database>,
Option<String>: Decode<'a, R::Database> + Type<R::Database>,
OffsetDateTime: Decode<'a, R::Database> + Type<R::Database>,
Auto Trait Implementations§
impl Freeze for FuseMount
impl RefUnwindSafe for FuseMount
impl Send for FuseMount
impl Sync for FuseMount
impl Unpin for FuseMount
impl UnwindSafe for FuseMount
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more
Source§fn follow_redirects(self) -> FollowRedirect<Self>where
Self: Sized,
fn follow_redirects(self) -> FollowRedirect<Self>where
Self: Sized,
Source§fn sensitive_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveRequestHeaders<SetSensitiveResponseHeaders<Self>>where
Self: Sized,
fn sensitive_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveRequestHeaders<SetSensitiveResponseHeaders<Self>>where
Self: Sized,
Source§fn sensitive_request_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveRequestHeaders<Self>where
Self: Sized,
fn sensitive_request_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveRequestHeaders<Self>where
Self: Sized,
Source§fn sensitive_response_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveResponseHeaders<Self>where
Self: Sized,
fn sensitive_response_headers(
self,
headers: impl IntoIterator<Item = HeaderName>,
) -> SetSensitiveResponseHeaders<Self>where
Self: Sized,
Source§fn request_body_limit(self, limit: usize) -> RequestBodyLimit<Self>where
Self: Sized,
fn request_body_limit(self, limit: usize) -> RequestBodyLimit<Self>where
Self: Sized,
Intercept requests with over-sized payloads and convert them into
413 Payload Too Large responses. Read more