Struct HttpRegistryClient 

pub struct HttpRegistryClient { /* private fields */ }

The RegistryClient this crate ships: Confluent’s HTTP API over reqwest, rustls only.

Trait Implementations

impl Debug for HttpRegistryClient

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

Formats the value using the given formatter.

impl RegistryClient for HttpRegistryClient

fn schema_by_id( &self, id: u32, ) -> BoxFuture<'_, Result<Arc<RegisteredSchema>, KafkaError>>

The schema the registry holds under id.

fn latest( &self, subject: &str, ) -> BoxFuture<'_, Result<Option<Arc<RegisteredSchema>>, KafkaError>>

subject’s latest version, or None when the registry has no such subject.

fn register( &self, subject: &str, schema_type: SchemaType, definition: String, ) -> BoxFuture<'_, Result<u32, KafkaError>>

Registers definition under subject and returns the id, which is idempotent registry-side: an identical schema keeps the id it already had.

fn lookup_id( &self, subject: &str, schema_type: SchemaType, definition: String, ) -> BoxFuture<'_, Result<u32, KafkaError>>

The id definition already has under subject, registering nothing.

fn is_compatible( &self, subject: &str, schema_type: SchemaType, definition: String, ) -> BoxFuture<'_, Result<Option<bool>, KafkaError>>

Whether the registry would register definition under subject, judged by the compatibility level the subject is configured with.