teller-providers 2.0.7

A developer-first multi provider secret manager
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use std::collections::{BTreeMap, HashMap};

use crate::providers::ProviderKind;
use crate::Result;
use crate::{config::ProviderCfg, Provider};

pub struct Registry {
    providers: HashMap<String, Box<dyn Provider + Sync + Send>>,
}

impl Registry {
    /// Create a registry from config
    ///
    /// # Errors
    ///
    /// This function will return an error if any provider loading failed
    pub async fn new(providers: &BTreeMap<String, ProviderCfg>) -> Result<Self> {
        let mut loaded_providers = HashMap::new();
        for (k, provider) in providers {
            let provider: Box<dyn Provider + Sync + Send> = match provider.kind {
                ProviderKind::Inmem => Box::new(crate::providers::inmem::Inmem::new(
                    k,
                    provider.options.clone(),
                )?),

                #[cfg(feature = "dotenv")]
                ProviderKind::Dotenv => Box::new(crate::providers::dotenv::Dotenv::new(
                    k,
                    provider
                        .options
                        .clone()
                        .map(serde_json::from_value)
                        .transpose()?,
                )?),
                #[cfg(feature = "hashicorp_vault")]
                ProviderKind::Hashicorp => {
                    Box::new(crate::providers::hashicorp_vault::Hashivault::new(
                        k,
                        provider
                            .options
                            .clone()
                            .map(serde_json::from_value)
                            .transpose()?,
                    )?)
                }
                #[cfg(feature = "ssm")]
                ProviderKind::SSM => {
                    Box::new(crate::providers::ssm::SSM::new(k, provider.options.clone()).await?)
                }
                #[cfg(feature = "aws_secretsmanager")]
                ProviderKind::AWSSecretsManager => Box::new(
                    crate::providers::aws_secretsmanager::AWSSecretsManager::new(
                        k,
                        provider
                            .options
                            .clone()
                            .map(serde_json::from_value)
                            .transpose()?,
                    )
                    .await?,
                ),
                #[cfg(feature = "google_secretmanager")]
                ProviderKind::GoogleSecretManager => Box::new(
                    crate::providers::google_secretmanager::GoogleSecretManager::new(
                        k,
                        Box::new(crate::providers::google_secretmanager::GSMClient::new().await?)
                            as Box<dyn crate::providers::google_secretmanager::GSM + Send + Sync>,
                    ),
                ),
                #[cfg(feature = "hashicorp_consul")]
                ProviderKind::HashiCorpConsul => {
                    Box::new(crate::providers::hashicorp_consul::HashiCorpConsul::new(
                        k,
                        provider
                            .options
                            .clone()
                            .map(serde_json::from_value)
                            .transpose()?,
                    )?)
                }
                #[cfg(feature = "etcd")]
                ProviderKind::Etcd => Box::new(
                    crate::providers::etcd::Etcd::new(
                        k,
                        provider
                            .options
                            .clone()
                            .map(serde_json::from_value)
                            .transpose()?,
                    )
                    .await?,
                ),
            };
            loaded_providers.insert(k.clone(), provider);
        }
        Ok(Self {
            providers: loaded_providers,
        })
    }
    #[must_use]
    #[allow(clippy::borrowed_box)]
    pub fn get(&self, name: &str) -> Option<&Box<dyn Provider + Sync + Send>> {
        self.providers.get(name)
    }
}