schemreg 0.2.0

Async Confluent + AWS Glue schema registry client — wire format, traits, caching, HTTP
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! Standalone schema registry client library.
//!
//! Provides Confluent Schema Registry, Apicurio Registry v3, and AWS Glue
//! Schema Registry integration with:
//! - Wire format encode/decode (Confluent 5-byte header, AWS Glue 18-byte header)
//! - Subject name strategies
//! - Pluggable async registry clients
//! - In-memory caching with in-flight coalescing
//! - Encoder and decoder adapters (Avro, JSON Schema, raw)

pub mod cache;
pub mod decoder;
pub mod error;
pub mod glue;
pub mod subject;
pub mod traits;
pub mod types;
pub mod wire;

#[cfg(any(feature = "confluent", feature = "apicurio"))]
pub(crate) mod http;

#[cfg(feature = "avro")]
pub mod avro;

#[cfg(feature = "confluent")]
pub mod confluent;

#[cfg(feature = "json")]
pub mod json;

#[cfg(feature = "apicurio")]
pub mod apicurio;

#[cfg(feature = "apicurio")]
pub use apicurio::{ApicurioSchemaRegistry, ApicurioSchemaRegistryBuilder};
pub use cache::{CachedSchemaRegistry, DEFAULT_MAX_CACHE_ENTRIES, WarmCacheError};
pub use decoder::{DecodedMessage, SchemaFormat, SchemaMetadata, WireFormatDecoder};
pub use error::{Result, SchemaRegError};
#[cfg(feature = "glue")]
pub use glue::DynGlueSchemaRegistryClient;
pub use glue::{
    CachedGlueSchemaRegistry, DEFAULT_MAX_GLUE_CACHE_ENTRIES, GlueCompression, GlueDataFormat,
    GlueSchema, GlueSchemaRegistryClient, GlueSchemaVersionId, WarmGlueCacheError,
    decode_glue_wire_format, decode_glue_wire_format_bytes, encode_glue_wire_format,
};
pub use subject::SubjectNameStrategy;
pub use traits::{
    AnySchemaCache, DynSchemaRegistryClient, SchemaDecoder, SchemaEncoder, SchemaRegistryClient,
};
pub use types::{
    ArtifactId, EncodeTarget, Schema, SchemaId, SchemaReference, SchemaType, SchemaVersion,
};
pub use wire::{
    DetectedWireFormat, decode_protobuf_message_indexes, decode_wire_format,
    decode_wire_format_bytes, detect_wire_format, encode_protobuf_wire_format, encode_wire_format,
};

#[cfg(feature = "confluent")]
pub use confluent::{
    ConfluentSchemaEncoder, ConfluentSchemaEncoderBuilder, ConfluentSchemaRegistry,
    ConfluentSchemaRegistryBuilder,
};

#[cfg(feature = "json")]
pub use json::{JsonSchemaDecoder, JsonSchemaEncoder, JsonSchemaEncoderBuilder};