Struct ConfigClient

pub struct ConfigClient<'sr> { /* private fields */ }

The configuration client

Implementations

impl ConfigClient<'_>

pub async fn set( &self, compatibility: Compatibility, ) -> Result<Compatibility, SchemaRegistryError>

Update global compatibility level.

Errors

Fail if we cannot send the query Fail if the schema registry return an error

pub async fn get(&self) -> Result<GetCompatibility, SchemaRegistryError>

Get global compatibility level.

Errors

Fail if we cannot send the query Fail if the schema registry return an error

pub async fn set_subject( &self, subject: &SubjectName, compatibility: Compatibility, ) -> Result<Compatibility, SchemaRegistryError>

Update compatibility level for the specified subject.

Errors

Fail if we cannot send the query Fail if the schema registry return an error

pub async fn get_subject( &self, subject: &SubjectName, default_to_global: Option<bool>, ) -> Result<GetCompatibility, SchemaRegistryError>

Update compatibility level for the specified subject.

Errors

Fail if we cannot send the query Fail if the schema registry return an error

pub async fn delete_subject( &self, subject: &SubjectName, ) -> Result<GetCompatibility, SchemaRegistryError>

Deletes the specified subject-level compatibility level config and reverts to the global default.

Errors

Fail if we cannot send the query Fail if the schema registry return an error

Trait Implementations

impl<'sr> Debug for ConfigClient<'sr>

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

Formats the value using the given formatter.