Struct ccsr::Client [−][src]
Expand description
An API client for a Confluent-compatible schema registry.
Fields
inner: Client
url: Url
auth: Option<Auth>
Implementations
fn make_request<P>(&self, method: Method, path: P) -> RequestBuilder where
P: IntoIterator,
P::Item: AsRef<str>,
Gets the schema with the associated ID.
Gets the latest schema for the specified subject.
Gets the latest version of the specified subject.
pub async fn get_subject_and_references(
&self,
subject: &str
) -> Result<(Subject, Vec<Subject>), GetBySubjectError>
pub async fn get_subject_and_references(
&self,
subject: &str
) -> Result<(Subject, Vec<Subject>), 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.
Gets a subject and 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]
) -> Result<i32, PublishError>
pub async fn publish_schema(
&self,
subject: &str,
schema: &str,
schema_type: SchemaType,
references: &[SchemaReference]
) -> 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.
Lists the names of all subjects that the schema registry is aware of.
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
) -> Result<(Subject, Vec<Subject>), GetBySubjectError>
pub async fn get_subject_and_references_by_id(
&self,
id: i32
) -> Result<(Subject, Vec<Subject>), 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
Auto Trait Implementations
impl !RefUnwindSafe for Client
impl !UnwindSafe for Client
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more