Package ai.pipestream.registration.entity

Class ConfigSchema

java.lang.Object

io.quarkus.hibernate.reactive.panache.PanacheEntityBase

ai.pipestream.registration.entity.ConfigSchema

@Entity
public class ConfigSchema
extends io.quarkus.hibernate.reactive.panache.PanacheEntityBase

Entity representing a configuration schema for a service. This is the system of record, with Apicurio Registry as a secondary store.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ConfigSchema.SyncStatus

Field Summary

Fields

Modifier and Type	Field	Description
String	apicurioArtifactId
Long	apicurioGlobalId
LocalDateTime	createdAt
String	createdBy
String	jsonSchema
LocalDateTime	lastSyncAttempt
String	schemaId
String	schemaVersion
String	serviceName
String	syncError
ConfigSchema.SyncStatus	syncStatus

Constructor Summary

Constructors

Constructor	Description
ConfigSchema()

Method Summary

Modifier and Type	Method	Description
static ConfigSchema	create(String serviceName, String version, String jsonSchema)
static String	generateSchemaId(String serviceName, String version)
void	markSynced(String artifactId, Long globalId)
void	markSyncFailed(String error)

Methods inherited from class io.quarkus.hibernate.reactive.panache.PanacheEntityBase

count, count, count, count, delete, delete, delete, delete, deleteAll, deleteById, find, find, find, find, find, find, findAll, findAll, findById, findById, flush, getSession, isPersistent, list, list, list, list, list, list, listAll, listAll, persist, persist, persist, persist, persistAndFlush, update, update, update

Methods inherited from class java.lang.Object

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

Field Details

schemaId

public String schemaId

serviceName

public String serviceName

schemaVersion

public String schemaVersion

jsonSchema

public String jsonSchema

createdAt

public LocalDateTime createdAt

createdBy

public String createdBy

apicurioArtifactId

public String apicurioArtifactId

apicurioGlobalId

public Long apicurioGlobalId

syncStatus

public ConfigSchema.SyncStatus syncStatus

lastSyncAttempt

public LocalDateTime lastSyncAttempt

syncError

public String syncError

Constructor Details

ConfigSchema

public ConfigSchema()

Method Details

create

public static ConfigSchema create(String serviceName,
 String version,
 String jsonSchema)

generateSchemaId

public static String generateSchemaId(String serviceName,
 String version)

markSynced

public void markSynced(String artifactId,
 Long globalId)

markSyncFailed

public void markSyncFailed(String error)