pub struct ConfigClient<'sr> { /* private fields */ }
Expand description
The configuration client
Implementations§
Source§impl ConfigClient<'_>
impl ConfigClient<'_>
Sourcepub async fn set(
&self,
compatibility: Compatibility,
) -> Result<Compatibility, SchemaRegistryError>
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
Sourcepub async fn get(&self) -> Result<GetCompatibility, SchemaRegistryError>
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
Sourcepub async fn set_subject(
&self,
subject: &SubjectName,
compatibility: Compatibility,
) -> Result<Compatibility, SchemaRegistryError>
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
Sourcepub async fn get_subject(
&self,
subject: &SubjectName,
default_to_global: Option<bool>,
) -> Result<GetCompatibility, SchemaRegistryError>
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
Sourcepub async fn delete_subject(
&self,
subject: &SubjectName,
) -> Result<GetCompatibility, SchemaRegistryError>
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§
Auto Trait Implementations§
impl<'sr> Freeze for ConfigClient<'sr>
impl<'sr> !RefUnwindSafe for ConfigClient<'sr>
impl<'sr> Send for ConfigClient<'sr>
impl<'sr> Sync for ConfigClient<'sr>
impl<'sr> Unpin for ConfigClient<'sr>
impl<'sr> !UnwindSafe for ConfigClient<'sr>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more