opendal/services/monoiofs/config.rs
1// Licensed to the Apache Software Foundation (ASF) under one
2// or more contributor license agreements. See the NOTICE file
3// distributed with this work for additional information
4// regarding copyright ownership. The ASF licenses this file
5// to you under the Apache License, Version 2.0 (the
6// "License"); you may not use this file except in compliance
7// with the License. You may obtain a copy of the License at
8//
9// http://www.apache.org/licenses/LICENSE-2.0
10//
11// Unless required by applicable law or agreed to in writing,
12// software distributed under the License is distributed on an
13// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14// KIND, either express or implied. See the License for the
15// specific language governing permissions and limitations
16// under the License.
17
18use serde::Deserialize;
19use serde::Serialize;
20
21use super::backend::MonoiofsBuilder;
22
23/// Config for monoiofs services support.
24#[derive(Default, Debug, Serialize, Deserialize, Clone, PartialEq, Eq)]
25#[serde(default)]
26#[non_exhaustive]
27pub struct MonoiofsConfig {
28 /// The Root of this backend.
29 ///
30 /// All operations will happen under this root.
31 ///
32 /// Builder::build will return error if not set.
33 pub root: Option<String>,
34}
35
36impl crate::Configurator for MonoiofsConfig {
37 type Builder = MonoiofsBuilder;
38
39 fn from_uri(uri: &crate::types::OperatorUri) -> crate::Result<Self> {
40 let mut map = uri.options().clone();
41
42 if let Some(root) = uri.root() {
43 if !root.is_empty() {
44 map.insert("root".to_string(), root.to_string());
45 }
46 }
47
48 Self::from_iter(map)
49 }
50
51 fn into_builder(self) -> Self::Builder {
52 MonoiofsBuilder { config: self }
53 }
54}
55
56#[cfg(test)]
57mod tests {
58 use super::*;
59 use crate::Configurator;
60 use crate::types::OperatorUri;
61
62 #[test]
63 fn from_uri_sets_root() {
64 let uri = OperatorUri::new("monoiofs:///tmp", Vec::<(String, String)>::new()).unwrap();
65
66 let cfg = MonoiofsConfig::from_uri(&uri).unwrap();
67 assert_eq!(cfg.root.as_deref(), Some("tmp"));
68 }
69}