schema-registry-client 0.4.2

Serialize/deserialize data to/from Kafka using the Confluent Schema Registry
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

use crate::serdes::serde::SerdeError;
use std::collections::HashMap;
use std::sync::Arc;
use tink_core::registry::KmsClient;

pub trait KmsDriver: Send + Sync {
    fn get_key_url_prefix(&self) -> &'static str;

    fn new_kms_client(
        &self,
        conf: &HashMap<String, String>,
        key_url: &str,
    ) -> Result<Arc<dyn KmsClient>, SerdeError>;
}