Struct SchemaRegistryClient 

pub struct SchemaRegistryClient { /* private fields */ }

Client for interacting with the Danube Schema Registry

Provides methods for registering, retrieving, and managing schemas in the centralized schema registry.

Implementations

impl SchemaRegistryClient

pub async fn new(client: &DanubeClient) -> Result<Self>

Create a new SchemaRegistryClient from a DanubeClient

pub fn register_schema( &mut self, subject: impl Into<String>, ) -> SchemaRegistrationBuilder<'_>

Register a new schema or get existing schema ID

Returns a builder for configuring schema registration

pub async fn get_schema_by_id(&mut self, schema_id: u64) -> Result<SchemaInfo>

Get schema by ID

Returns schema information for the given schema ID. Schema ID identifies a subject (not a specific version).

pub async fn get_schema_version( &mut self, schema_id: u64, version: Option<u32>, ) -> Result<SchemaInfo>

Get specific schema version

Returns schema information for a specific version of a schema subject.

pub async fn get_latest_schema( &mut self, subject: impl Into<String>, ) -> Result<SchemaInfo>

Get latest schema for a subject

Returns the latest schema version for the given subject.

pub async fn check_compatibility( &mut self, subject: impl Into<String>, schema_data: Vec<u8>, schema_type: SchemaType, mode: Option<CompatibilityMode>, ) -> Result<CheckCompatibilityResponse>

Check if a schema is compatible with existing versions

Arguments

• subject - Schema subject name
• schema_data - Raw schema content
• schema_type - Schema type (Avro, JsonSchema, Protobuf)
• mode - Optional compatibility mode override (uses subject’s default if None)

pub async fn set_compatibility_mode( &mut self, subject: impl Into<String>, mode: CompatibilityMode, ) -> Result<SetCompatibilityModeResponse>

Set compatibility mode for a subject

Arguments

• subject - Schema subject name
• mode - Compatibility mode to set

Example

use danube_client::{SchemaRegistryClient, CompatibilityMode};

schema_client.set_compatibility_mode("critical-orders", CompatibilityMode::Full).await?;

pub async fn list_versions( &mut self, subject: impl Into<String>, ) -> Result<Vec<u32>>

List all versions for a subject

Trait Implementations

impl Clone for SchemaRegistryClient

fn clone(&self) -> SchemaRegistryClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SchemaRegistryClient

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

Formats the value using the given formatter.