Struct SchemaRegistryClient 

pub struct SchemaRegistryClient { /* private fields */ }

Client for interacting with the Danube Schema Registry.

Obtained via [DanubeClient::schema()]. Provides methods for registering, retrieving, and managing schemas in the centralized schema registry.

Follows the same connection pattern as other Danube services — a fresh gRPC connection is obtained from the shared ConnectionManager on each call.

Implementations

impl SchemaRegistryClient

pub fn register_schema( &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(&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( &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( &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( &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( &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

pub async fn list_versions( &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.