Struct Client

pub struct Client {
    inner: Client,
    url: Vec<Url>,
    username: Option<String>,
    password: Option<String>,
}

An client for communication with schema registry

Fields

inner: Client

url: Vec<Url>

username: Option<String>

password: Option<String>

Implementations

impl Client

pub(crate) fn new( url: Vec<Url>, client_config: &SchemaRegistryAuth, ) -> Result<Self, InvalidOptionError>

async fn concurrent_req<'a, T>( &'a self, method: Method, path: &'a [&'a (impl AsRef<str> + ?Sized + Debug + ToString)], ) -> Result<T, ConcurrentRequestError>

where T: DeserializeOwned + Send + Sync + 'static,

pub async fn get_schema_by_id( &self, id: i32, ) -> Result<ConfluentSchema, ConcurrentRequestError>

get schema by id

pub async fn get_schema_by_subject( &self, subject: &str, ) -> Result<ConfluentSchema, ConcurrentRequestError>

get the latest schema of the subject

pub async fn get_subject( &self, subject: &str, ) -> Result<Subject, ConcurrentRequestError>

get the latest version of the subject

pub async fn get_subject_and_references( &self, subject: &str, ) -> Result<(Subject, Vec<Subject>), ConcurrentRequestError>

get the latest version of the subject and all it’s references(deps)

Trait Implementations

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.