Schema registry API

Provide a REST API to call with a schema registry.

Examples

List subjects

```rust, norun use reqwest::Url; use schemaregistry_api::SchemaRegistry;

#[tokio::main]

async fn main() -> anyhow::Result<()> {

// Create a SchemaRegistry let baseurl = Url::parse("http://localhost:8081")?; let sr = SchemaRegistry::builddefault(base_url)?;

// List subjects let subjects = sr.subject().list(None, None).await?;

if subjects.is_empty() { println!("No subject found"); } for subject in &subjects { println!("Found subject '{subject}'"); }

Ok(())

}

```

Register a schema

```rust, norun use reqwest::Url; use schemaregistry_api::{RegisterSchema, SchemaRegistry};

#[tokio::main]

async fn main() -> anyhow::Result<()> {

// Create a SchemaRegistry let baseurl = Url::parse("http://localhost:8081")?; let sr = SchemaRegistry::builddefault(base_url)?;

// Create a subject let subject = "a-topic-value".parse()?; // Create the RegisterSchema let schema = RegisterSchema { schema: includestr!("../tests/assets/arecord.avsc").to_string(), ..Default::default() };

// Register the schema for the subject let registeredschema = sr.subject().newversion(&subject, &schema, None).await?; // Get the schema id let schemaid = registeredschema.id;

println!("The schema #{schema_id} is registered for subject '{subject}'");

Ok(())

}

```

License

Licensed under either of

• Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.