spacegate-config 0.2.0-alpha.4

A library-first, lightweight, high-performance, cloud-native supported API gateway
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

use crate::service::Delete;
use crate::{service::config_format::ConfigFormat, BoxError};

use super::Fs;
impl<F> Delete for Fs<F>
where
    F: ConfigFormat + Send + Sync,
{
    async fn delete_plugin(&self, id: &spacegate_model::PluginInstanceId) -> Result<(), BoxError> {
        self.modify_cached(|config| {
            config.plugins.remove(id);
            Ok(())
        })
        .await
    }

    async fn delete_config_item_gateway(&self, gateway_name: &str) -> Result<(), BoxError> {
        self.modify_cached(|config| {
            config.gateways.remove(gateway_name);
            Ok(())
        })
        .await
    }

    async fn delete_config_item_route(&self, gateway_name: &str, route_name: &str) -> Result<(), BoxError> {
        self.modify_cached(|config| {
            if let Some(gw) = config.gateways.get_mut(gateway_name) {
                gw.routes.remove(route_name);
            }
            Ok(())
        })
        .await
    }

    async fn delete_config_item(&self, gateway_name: &str) -> Result<(), BoxError> {
        self.modify_cached(|config| {
            config.gateways.remove(gateway_name);
            Ok(())
        })
        .await
    }

    async fn delete_config_item_all_routes(&self, gateway_name: &str) -> Result<(), BoxError> {
        self.modify_cached(|config| {
            if let Some(gw) = config.gateways.get_mut(gateway_name) {
                gw.routes.clear()
            }
            Ok(())
        })
        .await
    }
}