Index (im2be-platform-libs :: apicurio-client 1.1.0-SNAPSHOT API)

A B C D E F G H I J K P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

APICURIO - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryClient.Kind: ApicurioSchemaRegistryClient — native 8-byte globalId wire format.
APICURIO - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryProperties.Mode: Apicurio native 8-byte globalId prefix.
APICURIO_8_BYTE - Enum constant in enum class com.aim2be.platform.schema.WireFormat: Apicurio native: 8-byte big-endian globalId prefix.
APICURIO_PREFIX_LENGTH - Static variable in class com.aim2be.platform.schema.WireFormatCodec: Apicurio prefix length: 8 bytes (long, big-endian).
apicurioRegistryClient(SchemaRegistryProperties) - Method in class com.aim2be.platform.schema.SchemaRegistryAutoConfiguration: Builds the Apicurio v2 REST client targeting SchemaRegistryProperties.getUrl().
apicurioSchemaRegistryClient(RegistryClient, SchemaRegistryProperties, OpenTelemetry) - Method in class com.aim2be.platform.schema.SchemaRegistryAutoConfiguration: Primary path: Apicurio native 8-byte globalId prefix.
ApicurioSchemaRegistryClient - Class in com.aim2be.platform.schema: Apicurio Registry implementation of SchemaRegistryClient (ADR-0011 §B, primary path).
ApicurioSchemaRegistryClient(RegistryClient, String, String, OpenTelemetry) - Constructor for class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
AVRO - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryClient.SchemaType: Apache Avro JSON-form schema.

B

bytes() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns the value of the bytes record component.

C

com.aim2be.platform.schema - package com.aim2be.platform.schema
CONFLUENT - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryProperties.Mode: Confluent legacy 0x00 + 4-byte schemaId prefix.
CONFLUENT_4_BYTE - Enum constant in enum class com.aim2be.platform.schema.WireFormat: Confluent legacy: 0x00 magic byte + 4-byte big-endian schemaId.
CONFLUENT_MAGIC_BYTE - Static variable in class com.aim2be.platform.schema.WireFormatCodec: Confluent magic byte sentinel: 0x00.
CONFLUENT_PREFIX_LENGTH - Static variable in class com.aim2be.platform.schema.WireFormatCodec: Confluent prefix length: 1 magic byte + 4-byte int (big-endian) = 5 bytes.
CONFLUENT_WIRE_COMPAT - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryClient.Kind: ConfluentWireCompatSchemaRegistryClient — 4-byte schemaId wire format atop Apicurio.
confluentWireCompatSchemaRegistryClient(RegistryClient, SchemaRegistryProperties, OpenTelemetry) - Method in class com.aim2be.platform.schema.SchemaRegistryAutoConfiguration: Confluent wire-format hedge: Apicurio storage backend + 4-byte schemaId prefix at the wire.
ConfluentWireCompatSchemaRegistryClient - Class in com.aim2be.platform.schema: Confluent wire-format compatibility client (ADR-0011 §B fallback hedge).
ConfluentWireCompatSchemaRegistryClient(RegistryClient, String, String, OpenTelemetry) - Constructor for class com.aim2be.platform.schema.ConfluentWireCompatSchemaRegistryClient

D

DUAL - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryClient.Kind: DualSchemaRegistryClient — see its class Javadoc.
DUAL - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryProperties.Mode: Apicurio primary, Confluent fallback on 5xx / IOException.
dualSchemaRegistryClient(RegistryClient, SchemaRegistryProperties, OpenTelemetry) - Method in class com.aim2be.platform.schema.SchemaRegistryAutoConfiguration: Dual coordinator: wire-format coexistence layer (DualSchemaRegistryClient).
DualSchemaRegistryClient - Class in com.aim2be.platform.schema: Wire-format hedge coordinator (ADR-0011 §B optional hedge).
DualSchemaRegistryClient(SchemaRegistryClient, SchemaRegistryClient, OpenTelemetry) - Constructor for class com.aim2be.platform.schema.DualSchemaRegistryClient

E

equals(Object) - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class com.aim2be.platform.schema.WireFormatCodec.ParsedRecord: Indicates whether some other object is "equal to" this one.

F

fetchByGlobalId(long) - Method in class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
fetchByGlobalId(long) - Method in class com.aim2be.platform.schema.ConfluentWireCompatSchemaRegistryClient
fetchByGlobalId(long) - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
fetchByGlobalId(long) - Method in interface com.aim2be.platform.schema.SchemaRegistryClient: Fetches a schema by registry global ID.
fetchLatestBySubject(String) - Method in class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
fetchLatestBySubject(String) - Method in class com.aim2be.platform.schema.ConfluentWireCompatSchemaRegistryClient
fetchLatestBySubject(String) - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
fetchLatestBySubject(String) - Method in interface com.aim2be.platform.schema.SchemaRegistryClient: Fetches the latest schema body registered under subject.

G

getCompatibility() - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
getDelegate() - Method in class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
getFallback() - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
getGroupId() - Method in class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
getGroupId() - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
getMode() - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
getPrimary() - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
getUrl() - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
globalId() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns the value of the globalId record component.

H

hashCode() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns a hash code value for this object.
hashCode() - Method in record class com.aim2be.platform.schema.WireFormatCodec.ParsedRecord: Returns a hash code value for this object.

I

id() - Method in record class com.aim2be.platform.schema.WireFormatCodec.ParsedRecord: Returns the value of the id record component.
isEnabled() - Method in class com.aim2be.platform.schema.SchemaRegistryProperties

J

JSON - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryClient.SchemaType: JSON Schema.

K

kind() - Method in class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
kind() - Method in class com.aim2be.platform.schema.ConfluentWireCompatSchemaRegistryClient
kind() - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
kind() - Method in interface com.aim2be.platform.schema.SchemaRegistryClient: Returns the implementation kind.

P

parseApicurioPrefix(byte[]) - Static method in class com.aim2be.platform.schema.WireFormatCodec: Parses an Apicurio-prefixed wire byte array.
parseConfluentPrefix(byte[]) - Static method in class com.aim2be.platform.schema.WireFormatCodec: Parses a Confluent-prefixed wire byte array.
ParsedRecord(long, byte[]) - Constructor for record class com.aim2be.platform.schema.WireFormatCodec.ParsedRecord: Creates an instance of a ParsedRecord record class.
payload() - Method in record class com.aim2be.platform.schema.WireFormatCodec.ParsedRecord: Returns the value of the payload record component.
prependApicurioPrefix(long, byte[]) - Static method in class com.aim2be.platform.schema.WireFormatCodec: Prepends the Apicurio 8-byte big-endian globalId to payload.
prependConfluentPrefix(int, byte[]) - Static method in class com.aim2be.platform.schema.WireFormatCodec: Prepends the Confluent 0x00 + 4-byte schemaId prefix to payload.
PROTOBUF - Enum constant in enum class com.aim2be.platform.schema.SchemaRegistryClient.SchemaType: Protobuf .proto (Apicurio stores the proto text).

R

register(String, byte[], SchemaRegistryClient.SchemaType) - Method in class com.aim2be.platform.schema.ApicurioSchemaRegistryClient
register(String, byte[], SchemaRegistryClient.SchemaType) - Method in class com.aim2be.platform.schema.ConfluentWireCompatSchemaRegistryClient
register(String, byte[], SchemaRegistryClient.SchemaType) - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
register(String, byte[], SchemaRegistryClient.SchemaType) - Method in interface com.aim2be.platform.schema.SchemaRegistryClient: Registers schemaBytes under subject, returning the registry-assigned global ID.

S

Schema(long, String, byte[], SchemaRegistryClient.SchemaType, int) - Constructor for record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Creates an instance of a Schema record class.
SchemaRegistryAutoConfiguration - Class in com.aim2be.platform.schema: Spring Boot auto-configuration for the apicurio-client module.
SchemaRegistryAutoConfiguration() - Constructor for class com.aim2be.platform.schema.SchemaRegistryAutoConfiguration
SchemaRegistryClient - Interface in com.aim2be.platform.schema: Schema-registry abstraction (ADR-0011 §B).
SchemaRegistryClient.Kind - Enum Class in com.aim2be.platform.schema: Implementation kinds.
SchemaRegistryClient.Schema - Record Class in com.aim2be.platform.schema: Immutable schema record returned by fetch operations.
SchemaRegistryClient.SchemaType - Enum Class in com.aim2be.platform.schema: Supported schema types.
SchemaRegistryIOException - Exception in com.aim2be.platform.schema: Wraps IOException thrown while streaming schema bodies from the registry, surfacing it as an unchecked failure to keep the SchemaRegistryClient interface checked-exception-free.
SchemaRegistryIOException(String, IOException) - Constructor for exception com.aim2be.platform.schema.SchemaRegistryIOException
schemaRegistryOpenTelemetry() - Method in class com.aim2be.platform.schema.SchemaRegistryAutoConfiguration: Falls back to a no-op OpenTelemetry instance ONLY when no real OpenTelemetry bean is present; lets the client emit spans without forcing every consumer to wire OTel up first.
SchemaRegistryProperties - Class in com.aim2be.platform.schema: Externalised configuration for the schema-registry client (ADR-0011 §B + ADR-0014 D-3).
SchemaRegistryProperties() - Constructor for class com.aim2be.platform.schema.SchemaRegistryProperties
SchemaRegistryProperties.Mode - Enum Class in com.aim2be.platform.schema: Wire-format mode selector.
setCompatibility(String) - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
setEnabled(boolean) - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
setGroupId(String) - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
setMode(SchemaRegistryProperties.Mode) - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
setUrl(String) - Method in class com.aim2be.platform.schema.SchemaRegistryProperties
subject() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns the value of the subject record component.

T

toString() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns a string representation of this record class.
toString() - Method in record class com.aim2be.platform.schema.WireFormatCodec.ParsedRecord: Returns a string representation of this record class.
type() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns the value of the type record component.

V

valueOf(String) - Static method in enum class com.aim2be.platform.schema.SchemaRegistryClient.Kind: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.aim2be.platform.schema.SchemaRegistryClient.SchemaType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.aim2be.platform.schema.SchemaRegistryProperties.Mode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.aim2be.platform.schema.WireFormat: Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.aim2be.platform.schema.SchemaRegistryClient.Kind: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.aim2be.platform.schema.SchemaRegistryClient.SchemaType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.aim2be.platform.schema.SchemaRegistryProperties.Mode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.aim2be.platform.schema.WireFormat: Returns an array containing the constants of this enum class, in the order they are declared.
version() - Method in record class com.aim2be.platform.schema.SchemaRegistryClient.Schema: Returns the value of the version record component.

W

wireFormat() - Method in class com.aim2be.platform.schema.ConfluentWireCompatSchemaRegistryClient
wireFormat() - Method in class com.aim2be.platform.schema.DualSchemaRegistryClient
wireFormat() - Method in interface com.aim2be.platform.schema.SchemaRegistryClient: Returns the wire format this client emits / parses.
WireFormat - Enum Class in com.aim2be.platform.schema: On-wire schema-ID prefix encoding (ADR-0011 §B).
WireFormatCodec - Class in com.aim2be.platform.schema: Pure utility for encoding / decoding the on-wire schema-ID prefix.
WireFormatCodec.ParsedRecord - Record Class in com.aim2be.platform.schema: Result of parsing a wire-prefixed byte array.
WireFormatException - Exception in com.aim2be.platform.schema: Thrown by WireFormatCodec when on-wire bytes do not satisfy the declared WireFormat (e.g. byte array shorter than the required prefix length, or Confluent magic byte !
WireFormatException(String) - Constructor for exception com.aim2be.platform.schema.WireFormatException
WireFormatException(String, Throwable) - Constructor for exception com.aim2be.platform.schema.WireFormatException

A B C D E F G H I J K P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form