Struct SchemaRegistryClient

pub struct SchemaRegistryClient { /* private fields */ }

A client for interacting with the Schema Registry within Redpanda.

Implementations

impl SchemaRegistryClient

pub fn new() -> Self

Create a new default Schema Registry client that connects to Redpanda’s Schema Registry when running within the context of a data transform.

pub fn new_wrapping(delegate: Box<dyn SchemaRegistryClientImpl>) -> Self

Create a new custom Schema Registry client wrapping the implementation.

This is useful in testing when you want to inject a mock client.

pub fn lookup_schema_by_id(&self, id: SchemaId) -> Result<Schema>

Lookup a schema via its global ID.

pub fn lookup_schema_by_version( &self, subject: impl AsRef<str>, version: SchemaVersion, ) -> Result<SubjectSchema>

Lookup a schema for a given subject at a specific version.

pub fn lookup_latest_schema( &self, subject: impl AsRef<str>, ) -> Result<SubjectSchema>

Lookup the latest schema for a subject.

pub fn create_schema( &mut self, subject: impl AsRef<str>, schema: Schema, ) -> Result<SubjectSchema>

Create a schema in the Schema Registry under the given subject, returning the version and ID.

If an equivalent schema already exists globally, that schema ID will be reused. If an equivalent schema already exists within that subject, this will be a noop and the existing schema version will be returned.

Trait Implementations

impl Default for SchemaRegistryClient

fn default() -> Self

Returns the “default value” for a type.