Package ai.pipestream.registration.repository

Class ApicurioRegistryClient

java.lang.Object

ai.pipestream.registration.repository.ApicurioRegistryClient

@ApplicationScoped
public class ApicurioRegistryClient
extends Object

Client for interacting with Apicurio Registry v3. This is the secondary storage for schemas (primary is MySQL).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ApicurioRegistryClient.SchemaRegistrationResponse

Constructor Summary

Constructors

Constructor	Description
ApicurioRegistryClient()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<ApicurioRegistryClient.SchemaRegistrationResponse>	createOrUpdateSchema(String serviceName, String version, String jsonSchema)	Create or update a schema in Apicurio Registry
io.smallrye.mutiny.Uni<Boolean>	deleteArtifact(String serviceName)	Delete an artifact (for cleanup)
io.smallrye.mutiny.Uni<io.apicurio.registry.rest.client.models.ArtifactMetaData>	getArtifactMetadata(String serviceName)	Get artifact metadata
io.smallrye.mutiny.Uni<String>	getSchema(String serviceName, String version)	Get schema by artifact ID
io.smallrye.mutiny.Uni<Boolean>	isHealthy()	Check if Apicurio is healthy
io.smallrye.mutiny.Uni<List<io.apicurio.registry.rest.client.models.SearchedArtifact>>	listArtifacts()	List all artifacts in the group (for reconciliation)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ApicurioRegistryClient

public ApicurioRegistryClient()

Method Details

createOrUpdateSchema

public io.smallrye.mutiny.Uni<ApicurioRegistryClient.SchemaRegistrationResponse> createOrUpdateSchema(String serviceName,
 String version,
 String jsonSchema)

Create or update a schema in Apicurio Registry

getSchema

public io.smallrye.mutiny.Uni<String> getSchema(String serviceName,
 String version)

Get schema by artifact ID

isHealthy

public io.smallrye.mutiny.Uni<Boolean> isHealthy()

Check if Apicurio is healthy

listArtifacts

public io.smallrye.mutiny.Uni<List<io.apicurio.registry.rest.client.models.SearchedArtifact>> listArtifacts()

List all artifacts in the group (for reconciliation)

deleteArtifact

public io.smallrye.mutiny.Uni<Boolean> deleteArtifact(String serviceName)

Delete an artifact (for cleanup)

getArtifactMetadata

public io.smallrye.mutiny.Uni<io.apicurio.registry.rest.client.models.ArtifactMetaData> getArtifactMetadata(String serviceName)

Get artifact metadata