Skip to main content

SchemaRegistryAware

laminar_connectors::schema::traits

Trait SchemaRegistryAware 

Source 
pub trait SchemaRegistryAware: Send + Sync {
    // Required methods
    fn fetch_schema<'life0, 'life1, 'async_trait>(
        &'life0 self,
        subject: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = SchemaResult<RegisteredSchema>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn fetch_schema_by_id<'life0, 'async_trait>(
        &'life0 self,
        schema_id: i32,
    ) -> Pin<Box<dyn Future<Output = SchemaResult<RegisteredSchema>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn check_compatibility<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        subject: &'life1 str,
        proposed: &'life2 SchemaRef,
    ) -> Pin<Box<dyn Future<Output = SchemaResult<bool>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn register_schema<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        subject: &'life1 str,
        schema: &'life2 SchemaRef,
    ) -> Pin<Box<dyn Future<Output = SchemaResult<RegisteredSchema>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn build_registry_decoder(
        &self,
        schema: &RegisteredSchema,
    ) -> SchemaResult<Box<dyn FormatDecoder>>;
}
Expand description

A connector that integrates with a schema registry.

Supports fetching, registering, and checking compatibility of schemas against an external registry (e.g., Confluent Schema Registry).

Required Methods§

Source

fn fetch_schema<'life0, 'life1, 'async_trait>( &'life0 self, subject: &'life1 str, ) -> Pin<Box<dyn Future<Output = SchemaResult<RegisteredSchema>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetches the latest schema for a subject.

§Errors

Returns SchemaError::RegistryError if the registry is unreachable or the subject is not found.

Source

fn fetch_schema_by_id<'life0, 'async_trait>( &'life0 self, schema_id: i32, ) -> Pin<Box<dyn Future<Output = SchemaResult<RegisteredSchema>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Fetches a schema by its numeric ID.

§Errors

Returns a schema error if the ID is not found.

Source

fn check_compatibility<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, subject: &'life1 str, proposed: &'life2 SchemaRef, ) -> Pin<Box<dyn Future<Output = SchemaResult<bool>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Checks whether proposed is compatible with the existing schema for subject under the configured compatibility mode.

§Errors

Returns a schema error if the compatibility check itself fails.

Source

fn register_schema<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, subject: &'life1 str, schema: &'life2 SchemaRef, ) -> Pin<Box<dyn Future<Output = SchemaResult<RegisteredSchema>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Registers a new schema version for a subject.

§Errors

Returns a schema error if registration fails.

Source

fn build_registry_decoder( &self, schema: &RegisteredSchema, ) -> SchemaResult<Box<dyn FormatDecoder>>

Builds a FormatDecoder configured for the registry schema.

This is a sync method because the decoder construction itself is not async — the registry lookup should happen beforehand.

§Errors

Returns a schema error if the decoder cannot be constructed (e.g., unsupported schema type).

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§