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 UnsafeUnpin 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