Struct mz_storage_client::types::connections::CsrClient

pub struct CsrClient {
    inner: Client,
    _drop_token: Option<Box<dyn Any + Send + Sync>>,
}

A mz_ccsr::Client optionally enriched with a keep-alive tokens.

Fields

inner: Client

_drop_token: Option<Box<dyn Any + Send + Sync>>

Methods from Deref<Target = Client>

pub async fn get_schema_by_id(
    &self,
    id: i32
) -> impl Future<Output = Result<Schema, GetByIdError>>

Gets the schema with the associated ID.

pub async fn get_schema_by_subject(
    &self,
    subject: &str
) -> impl Future<Output = Result<Schema, GetBySubjectError>>

Gets the latest schema for the specified subject.

pub async fn get_subject(
    &self,
    subject: &str
) -> impl Future<Output = Result<Subject, GetBySubjectError>>

Gets the latest version of the specified subject.

pub async fn get_subject_and_references(
    &self,
    subject: &str
) -> impl Future<Output = Result<(Subject, Vec<Subject, Global>), GetBySubjectError>>

Gets the latest version of the specified subject as well as all other subjects referenced by that subject (recursively).

The dependencies are returned in alphabetical order by subject name.

pub async fn publish_schema(
    &self,
    subject: &str,
    schema: &str,
    schema_type: SchemaType,
    references: &[SchemaReference]
) -> impl Future<Output = Result<i32, PublishError>>

Publishes a new schema for the specified subject. The ID of the new schema is returned.

Note that if a schema that is identical to an existing schema for the same subject is published, the ID of the existing schema will be returned.

pub async fn list_subjects(
    &self
) -> impl Future<Output = Result<Vec<String, Global>, ListError>>

Lists the names of all subjects that the schema registry is aware of.

pub async fn delete_subject(
    &self,
    subject: &str
) -> impl Future<Output = Result<(), DeleteError>>

Deletes all schema versions associated with the specified subject.

This API is only intended to be used in development environments. Deleting schemas only allows new, potentially incompatible schemas to be registered under the same subject. It does not allow the schema ID to be reused.

pub async fn get_subject_and_references_by_id(
    &self,
    id: i32
) -> impl Future<Output = Result<(Subject, Vec<Subject, Global>), GetBySubjectError>>

Gets the latest version of the first subject found associated with the scheme with the given id, as well as all other subjects referenced by that subject (recursively).

The dependencies are returned in alphabetical order by subject name.

Trait Implementations

impl Debug for CsrClient

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

Formats the value using the given formatter.

impl Deref for CsrClient

type Target = Client

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.