Trait mz_storage::types::connections::PopulateClientConfig

source · [−]

pub trait PopulateClientConfig {
    fn kafka_connection(&self) -> &KafkaConnection;
    fn options(&self) -> &BTreeMap<String, StringOrSecret>;

    fn drop_option_keys() -> HashSet<&'static str> { ... }
    fn populate_client_config<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        config: &'life1 mut ClientConfig,
        secrets_reader: &'life2 dyn SecretsReader
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        'life2: 'async_trait,
        Self: Sync + 'async_trait,
    { ... }
}