Struct SubjectClient

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

The subject client

Implementations

impl SubjectClient<'_>

pub async fn list( &self, subject_prefix: Option<&str>, deleted: Option<bool>, ) -> Result<Vec<SubjectName>, SchemaRegistryError>

A list of all subjects.

Errors

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

pub async fn versions( &self, name: &SubjectName, ) -> Result<Vec<SchemaVersion>, SchemaRegistryError>

Get a list of versions registered under the specified subject.

Errors

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

pub async fn delete( &self, name: &SubjectName, permanent: Option<bool>, ) -> Result<Vec<SchemaVersion>, SchemaRegistryError>

Deletes the specified subject and its associated compatibility level if registered.

Errors

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

pub async fn version( &self, name: &SubjectName, version: SchemaVersion, ) -> Result<Option<Subject>, SchemaRegistryError>

Get a specific version of the schema registered under this subject.

Errors

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

pub async fn schema( &self, name: &SubjectName, version: SchemaVersion, ) -> Result<Option<String>, SchemaRegistryError>

Get the schema for the specified version of this subject.

Errors

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

pub async fn new_version( &self, name: &SubjectName, schema: &RegisterSchema, normalize: Option<bool>, ) -> Result<RegisteredSchema, SchemaRegistryError>

Register a new schema under the specified subject.

Errors

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

pub async fn check_schema( &self, name: &SubjectName, schema: &RegisterSchema, normalize: Option<bool>, ) -> Result<Subject, SchemaRegistryError>

Check if a schema has already been registered under the specified subject.

Errors

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

pub async fn delete_version( &self, name: &SubjectName, version: SchemaVersion, permanent: Option<bool>, ) -> Result<Option<SchemaVersion>, SchemaRegistryError>

Deletes a specific version of the schema registered under this subject.

Errors

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

pub async fn referenced_by( &self, name: &SubjectName, version: SchemaVersion, ) -> Result<Vec<SchemaId>, SchemaRegistryError>

Get a list of IDs of schemas that reference the schema with the given subject and version.

Errors

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

Trait Implementations

impl<'sr> Debug for SubjectClient<'sr>

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

Formats the value using the given formatter.