Index (platform-registration-service 0.1.34 API)

A B C D E F G H I J K L M O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form

A

ACTIVE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus: The service is registered and considered operational.
ai.pipestream.registration.api - package ai.pipestream.registration.api
ai.pipestream.registration.descriptors - package ai.pipestream.registration.descriptors
ai.pipestream.registration.entity - package ai.pipestream.registration.entity
ai.pipestream.registration.events - package ai.pipestream.registration.events
ai.pipestream.registration.grpc - package ai.pipestream.registration.grpc
ai.pipestream.registration.handlers - package ai.pipestream.registration.handlers
ai.pipestream.registration.health - package ai.pipestream.registration.health
ai.pipestream.registration.metadata - package ai.pipestream.registration.metadata
ai.pipestream.registration.repository - package ai.pipestream.registration.repository
ai.pipestream.registration.topics - package ai.pipestream.registration.topics
apicurioArtifactId - Variable in class ai.pipestream.registration.entity.ConfigSchema: Apicurio artifact ID once the schema has been synced to the registry.
apicurioGlobalId - Variable in class ai.pipestream.registration.entity.ConfigSchema: Apicurio global ID once the schema has been synced to the registry.
ApicurioRegistryClient - Class in ai.pipestream.registration.repository: Client for interacting with Apicurio Registry v3.
ApicurioRegistryClient() - Constructor for class ai.pipestream.registration.repository.ApicurioRegistryClient: Creates a new client bean.
ApicurioRegistryClient.ArtifactContent - Record Class in ai.pipestream.registration.repository: Raw content + content-type of an artifact in an ARBITRARY group (e.g.
ApicurioRegistryClient.SchemaRegistrationResponse - Class in ai.pipestream.registration.repository: Result of registering a schema in Apicurio Registry, capturing the artifact ID, the assigned global ID, and the version that was stored.
ApicurioRegistryException - Exception Class in ai.pipestream.registration.repository: Exception thrown when operations with Apicurio Registry fail.
ApicurioRegistryException(String) - Constructor for exception class ai.pipestream.registration.repository.ApicurioRegistryException: Creates a new ApicurioRegistryException with a message.
ApicurioRegistryException(String, String, String, Throwable) - Constructor for exception class ai.pipestream.registration.repository.ApicurioRegistryException: Creates a new ApicurioRegistryException with context information.
ApicurioRegistryException(String, Throwable) - Constructor for exception class ai.pipestream.registration.repository.ApicurioRegistryException: Creates a new ApicurioRegistryException with a message and cause.
apicurioVersion - Variable in class ai.pipestream.registration.entity.MetadataPendingBake: Apicurio overlay version written by the promotion.
apicurioVersion() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.PromoteResult: Returns the value of the apicurioVersion record component.
ArtifactContent(byte[], String, String) - Constructor for record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Creates an instance of a ArtifactContent record class.

B

bakedFieldDescriptions(String) - Method in class ai.pipestream.registration.descriptors.TypeDescriptorIndex: The BAKED metadata layer: each direct field's leading proto doc-comment (trailing as fallback), keyed by field name.
bytes() - Method in record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Returns the value of the bytes record component.

C

call() - Method in class ai.pipestream.registration.health.DependentServicesHealthCheck
ConfigSchema - Class in ai.pipestream.registration.entity: Entity representing a configuration schema for a service.
ConfigSchema() - Constructor for class ai.pipestream.registration.entity.ConfigSchema: Creates an empty schema entity.
ConfigSchema.SyncStatus - Enum Class in ai.pipestream.registration.entity: Synchronization state of a schema relative to Apicurio Registry.
configSchemaId - Variable in class ai.pipestream.registration.entity.ServiceModule: Identifier of the associated configuration schema, if any.
contentType() - Method in record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Returns the value of the contentType record component.
countServicesByStatus() - Method in class ai.pipestream.registration.repository.ModuleRepository: Count registered services by status.
create(String, String, int) - Static method in class ai.pipestream.registration.entity.ServiceModule: Creates a new ServiceModule instance.
create(String, String, String) - Static method in class ai.pipestream.registration.entity.ConfigSchema: Factory method to create a new ConfigSchema.
createdAt - Variable in class ai.pipestream.registration.entity.ConfigSchema: Timestamp when the row was created (set on insert).
createdAt - Variable in class ai.pipestream.registration.entity.MetadataPendingBake: Promotion time.
createdBy - Variable in class ai.pipestream.registration.entity.ConfigSchema: Identifier of the principal that created the schema, if known.
createOrUpdateSchema(String, String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Create or update a schema in Apicurio Registry, deriving the artifact ID from the service name.
createOrUpdateSchemaWithArtifactBase(String, String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Create or update a schema with a custom artifact base name.
createOrUpdateSchemaWithArtifactId(String, String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Create or update a schema with a pre-built artifact ID.

D

deleteArtifact(String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Delete an artifact (for cleanup).
DependentServicesHealthCheck - Class in ai.pipestream.registration.health: Health check for services that platform-registration-service directly depends on.
DependentServicesHealthCheck() - Constructor for class ai.pipestream.registration.health.DependentServicesHealthCheck: Creates the health check bean.

E

emitModuleRegistered(String, String, String, int, String, String, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer: Emits a ModuleRegistered event to Kafka for OpenSearch indexing.
emitModuleUnregistered(String, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer: Emits a ModuleUnregistered event to Kafka for OpenSearch indexing.
emitServiceRegistered(String, String, String, int, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer: Emits a ServiceRegistered event to Kafka for OpenSearch indexing.
emitServiceUnregistered(String, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer: Emits a ServiceUnregistered event to Kafka for OpenSearch indexing.
ensureModuleTopic(String) - Method in class ai.pipestream.registration.topics.ModuleTopicProvisioner: Idempotently ensure pipestream.module.<moduleName> exists.
equals(Object) - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class ai.pipestream.registration.entity.TypeMetadataOverlay.Key
equals(Object) - Method in record class ai.pipestream.registration.handlers.ValidationResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.PromoteResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.SaveResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Indicates whether some other object is "equal to" this one.
extractKey(ModuleRegistered) - Method in class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleRegisteredExtractor
extractKey(ModuleUnregistered) - Method in class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleUnregisteredExtractor
extractKey(ServiceRegistered) - Method in class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceRegisteredExtractor
extractKey(ServiceUnregistered) - Method in class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceUnregisteredExtractor

F

failed(List) - Static method in record class ai.pipestream.registration.handlers.ValidationResult: Creates a failed result carrying the given failure reasons.
FAILED - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus: Sync failed.
fieldCount() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.SaveResult: Returns the value of the fieldCount record component.
fieldsJson - Variable in class ai.pipestream.registration.entity.MetadataPendingBake: JSON envelope of the promoted field annotations.
fieldsJson - Variable in class ai.pipestream.registration.entity.TypeMetadataOverlay: JSON envelope of field_path → FieldMetadataEntry.
fileDescriptorSet() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Returns the value of the fileDescriptorSet record component.
findById(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Get service by ID.
findCurrentSchemaByServiceName(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Resolve the schema of the module's CURRENT registration: the instance with the freshest heartbeat wins.
findLatestSchemaByServiceName(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Get the latest schema for a service (most recently created).
findSchemaById(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Get schema by ID.
findSchemasNeedingSync() - Method in class ai.pipestream.registration.repository.ModuleRepository: Get all schemas needing sync to Apicurio.
findSchemaVersionsByServiceName(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Get all schema versions for a service name, ordered by version descending.
findStaleServices() - Method in class ai.pipestream.registration.repository.ModuleRepository: Find stale services (no heartbeat for > 30 seconds).

G

generateSchemaId(String, String) - Static method in class ai.pipestream.registration.entity.ConfigSchema: Generates a unique schema ID.
generateServiceId(String, String, int) - Static method in class ai.pipestream.registration.entity.ServiceModule: Generates a unique service ID.
getActiveServices() - Method in class ai.pipestream.registration.repository.ModuleRepository: Get all active services.
getAllServices() - Method in class ai.pipestream.registration.repository.ModuleRepository: Get all services (for admin dashboard).
getArtifactContentFromGroup(String, String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Fetch any artifact's raw content from a specific group.
getArtifactId() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse: Returns the artifact ID the schema was registered under.
getArtifactId() - Method in exception class ai.pipestream.registration.repository.ApicurioRegistryException: Returns the artifact ID that was being operated on when the failure occurred.
getArtifactMetadata(String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Get artifact metadata.
getGlobalId() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse: Returns the global ID assigned by Apicurio.
getMerged(String, String) - Method in class ai.pipestream.registration.metadata.TypeMetadataService: Builds one type's merged view with per-layer provenance.
getModule(GetModuleRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getModuleById(String) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: Get module by ID.
getModuleByName(String) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: Get module by name.
getModuleSchema(GetModuleSchemaRequest) - Method in class ai.pipestream.registration.handlers.SchemaRetrievalHandler: Retrieves a module's config schema, trying the platform database first and falling back to Apicurio.
getModuleSchema(GetModuleSchemaRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getModuleSchema(String, String) - Method in class ai.pipestream.registration.api.ModuleSchemaResource: Returns a module's JSON config schema as a JSON body.
getModuleSchemaVersions(GetModuleSchemaVersionsRequest) - Method in class ai.pipestream.registration.handlers.SchemaRetrievalHandler: Lists all stored schema versions for a module, ordered by version descending.
getModuleSchemaVersions(GetModuleSchemaVersionsRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getSchema(String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Get schema by artifact ID (legacy naming, uses versionedArtifactId internally).
getSchemaArtifact(GetSchemaArtifactRequest) - Method in class ai.pipestream.registration.handlers.SchemaRetrievalHandler: One door for every named schema artifact.
getSchemaArtifact(GetSchemaArtifactRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getSchemaByArtifactId(String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Get schema by raw artifact ID.
getService(GetServiceRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getServiceById(String) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: Get service by ID.
getServiceByName(String) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: Get service by name (returns first healthy instance).
getServiceName() - Method in exception class ai.pipestream.registration.repository.ApicurioRegistryException: Returns the service name that was being operated on when the failure occurred.
getTypeDescriptor(GetTypeDescriptorRequest) - Method in class ai.pipestream.registration.handlers.TypeDescriptorHandler: Resolves one type to its self-contained, topologically ordered FileDescriptorSet.
getTypeDescriptor(GetTypeDescriptorRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getTypeMetadata(GetTypeMetadataRequest) - Method in class ai.pipestream.registration.handlers.TypeMetadataHandler: One type's merged metadata view.
getTypeMetadata(GetTypeMetadataRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
getVersion() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse: Returns the version that was stored.
graphId - Variable in class ai.pipestream.registration.entity.TypeMetadataOverlay.Key: Graph for PIPELINE scope; empty string for global.
group() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Returns the value of the group record component.
group() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Returns the value of the group record component.

H

hashCode() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Returns a hash code value for this object.
hashCode() - Method in class ai.pipestream.registration.entity.TypeMetadataOverlay.Key
hashCode() - Method in record class ai.pipestream.registration.handlers.ValidationResult: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.PromoteResult: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.SaveResult: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Returns a hash code value for this object.
host - Variable in class ai.pipestream.registration.entity.ServiceModule: Host address the service is reachable at.

I

id - Variable in class ai.pipestream.registration.entity.MetadataPendingBake: Bake record id (UUID string).
INACTIVE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus: The service is registered but not currently operational.
isHealthy() - Method in class ai.pipestream.registration.entity.ServiceModule: Checks if the service is healthy based on heartbeat.
isHealthy() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: Check if Apicurio is healthy.
isValidFieldPath(String, String) - Method in class ai.pipestream.registration.descriptors.TypeDescriptorIndex: Whether a dot-separated field path resolves against a type's schema.

J

jsonSchema - Variable in class ai.pipestream.registration.entity.ConfigSchema: The JSON schema content, stored as a JSONB column.

K

key - Variable in class ai.pipestream.registration.entity.TypeMetadataOverlay: The overlay identity.
Key() - Constructor for class ai.pipestream.registration.entity.TypeMetadataOverlay.Key: Creates an empty key for JPA.
Key(String, String, String) - Constructor for class ai.pipestream.registration.entity.TypeMetadataOverlay.Key: Creates a key.

L

lastHeartbeat - Variable in class ai.pipestream.registration.entity.ServiceModule: Timestamp of the most recent heartbeat.
lastSyncAttempt - Variable in class ai.pipestream.registration.entity.ConfigSchema: Timestamp of the most recent sync attempt.
list(String) - Method in class ai.pipestream.registration.descriptors.TypeDescriptorIndex: Lists every message type in the snapshot, sorted by full name.
listArtifacts() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient: List all artifacts in the group (for reconciliation).
listModules() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: List all modules.
listPlatformModules(ListPlatformModulesRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
listServices() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: List all services (non-modules).
listServices(ListServicesRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
listTypeDescriptors(ListTypeDescriptorsRequest) - Method in class ai.pipestream.registration.handlers.TypeDescriptorHandler: Lists every message type in the snapshot, optionally substring-filtered.
listTypeDescriptors(ListTypeDescriptorsRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
load() - Method in class ai.pipestream.registration.descriptors.TypeDescriptorIndex: Loads and indexes the baked descriptor snapshot.
lookup(String) - Method in class ai.pipestream.registration.descriptors.TypeDescriptorIndex: Resolves one message type to its self-contained descriptor set.

M

MAINTENANCE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus: The service is intentionally taken out of service for maintenance.
markSynced(String, Long) - Method in class ai.pipestream.registration.entity.ConfigSchema: Marks the schema as synced to Apicurio.
markSyncFailed(String) - Method in class ai.pipestream.registration.entity.ConfigSchema: Marks the schema sync as failed.
markUnhealthy(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Mark service as unhealthy.
messageFullName - Variable in class ai.pipestream.registration.entity.MetadataPendingBake: The promoted type.
messageFullName - Variable in class ai.pipestream.registration.entity.TypeMetadataOverlay.Key: The annotated message type.
messageFullName() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Returns the value of the messageFullName record component.
messageFullName() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Returns the value of the messageFullName record component.
messageNameFromTypeUrl(String) - Static method in class ai.pipestream.registration.descriptors.TypeDescriptorIndex: Extracts the message full name from an Any type_url (type.googleapis.com/pkg.Msg — everything after the last slash) or returns a bare name unchanged.
metadata - Variable in class ai.pipestream.registration.entity.ServiceModule: Free-form registration metadata, stored as a JSONB column.
MetadataPendingBake - Class in ai.pipestream.registration.entity: One promotion awaiting the phase-2 git bake: a snapshot of the annotations that were written to the Apicurio system of record, queued for the (future) automation that turns them into a protos PR so the next build bakes them into descriptors.
MetadataPendingBake() - Constructor for class ai.pipestream.registration.entity.MetadataPendingBake: Creates an empty entity instance for JPA.
ModuleRegisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleRegisteredExtractor: Creates the extractor bean.
ModuleRegistrationHandler - Class in ai.pipestream.registration.handlers: Handles module registration operations.
ModuleRegistrationHandler() - Constructor for class ai.pipestream.registration.handlers.ModuleRegistrationHandler: Creates the handler bean.
ModuleRepository - Class in ai.pipestream.registration.repository: Repository for managing service module registrations in PostgreSQL.
ModuleRepository() - Constructor for class ai.pipestream.registration.repository.ModuleRepository: Creates the repository bean.
ModuleSchemaResource - Class in ai.pipestream.registration.api: REST facade for module JSON config schemas (JSONForms / graph editor).
ModuleSchemaResource() - Constructor for class ai.pipestream.registration.api.ModuleSchemaResource: Creates the resource bean.
ModuleTopicProvisioner - Class in ai.pipestream.registration.topics: Creates the per-service module-work Kafka topic at module-registration time.
ModuleTopicProvisioner() - Constructor for class ai.pipestream.registration.topics.ModuleTopicProvisioner: Creates the provisioner bean.
ModuleUnregisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleUnregisteredExtractor: Creates the extractor bean.

O

ok() - Static method in record class ai.pipestream.registration.handlers.ValidationResult: Creates a successful result with no failure reasons.
OpenSearchEventsProducer - Class in ai.pipestream.registration.events: Produces events to Kafka for OpenSearch indexing.
OpenSearchEventsProducer() - Constructor for class ai.pipestream.registration.events.OpenSearchEventsProducer: Creates the producer bean.
OUT_OF_SYNC - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus: Schema changed, needs re-sync.

P

PENDING - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus: Not yet synced to Apicurio.
pendingBakeId() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.PromoteResult: Returns the value of the pendingBakeId record component.
PlatformEventsKeyExtractors - Class in ai.pipestream.registration.events: Holder for the UuidKeyExtractor beans that derive deterministic Kafka message keys from platform registration events.
PlatformEventsKeyExtractors() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors: Not instantiable; this class only groups the nested extractor beans.
PlatformEventsKeyExtractors.ModuleRegisteredExtractor - Class in ai.pipestream.registration.events: Keys ModuleRegistered events by their service ID.
PlatformEventsKeyExtractors.ModuleUnregisteredExtractor - Class in ai.pipestream.registration.events: Keys ModuleUnregistered events by their service ID.
PlatformEventsKeyExtractors.ServiceRegisteredExtractor - Class in ai.pipestream.registration.events: Keys ServiceRegistered events by their service ID.
PlatformEventsKeyExtractors.ServiceUnregisteredExtractor - Class in ai.pipestream.registration.events: Keys ServiceUnregistered events by their service ID.
PlatformRegistrationService - Class in ai.pipestream.registration.grpc: Main platform registration service implementation.
PlatformRegistrationService() - Constructor for class ai.pipestream.registration.grpc.PlatformRegistrationService: Creates the gRPC service bean.
port - Variable in class ai.pipestream.registration.entity.ServiceModule: Port the service is reachable at.
promote(String) - Method in class ai.pipestream.registration.metadata.TypeMetadataService: Promotes a type's global draft to the Apicurio system of record and queues the phase-2 bake record.
PromoteResult(String, String) - Constructor for record class ai.pipestream.registration.metadata.TypeMetadataService.PromoteResult: Creates an instance of a PromoteResult record class.
promoteTypeMetadata(PromoteTypeMetadataRequest) - Method in class ai.pipestream.registration.handlers.TypeMetadataHandler: Promotes a type's global draft (phase 1).
promoteTypeMetadata(PromoteTypeMetadataRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

R

reasons() - Method in record class ai.pipestream.registration.handlers.ValidationResult: Returns the value of the reasons record component.
reasonsAsString() - Method in record class ai.pipestream.registration.handlers.ValidationResult: Joins the failure reasons into a single semicolon-separated string.
register(RegisterRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
registeredAt - Variable in class ai.pipestream.registration.entity.ServiceModule: Timestamp when the module first registered (set on insert).
registerModule(RegisterRequest, Consumer) - Method in class ai.pipestream.registration.handlers.ModuleRegistrationHandler: Register a module with streaming status updates.
registerModule(String, String, int, String, Map, String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Register a new service module with optional schema.
RegisterRequestValidator - Class in ai.pipestream.registration.handlers: Shared validation logic for RegisterRequest.
registerService(RegisterRequest, Consumer) - Method in class ai.pipestream.registration.handlers.ServiceRegistrationHandler: Register a service with streaming status updates.
RegistrationVersionSanitizer - Class in ai.pipestream.registration.handlers: Defensive sanitizer for registration version strings coming from modules/services.
resolveService(ResolveServiceRequest) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: Resolve service to find the best available instance.
resolveService(ResolveServiceRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

S

sanitize(String, String, Logger, String) - Static method in class ai.pipestream.registration.handlers.RegistrationVersionSanitizer: Sanitizes a registration version string, falling back to RegistrationVersionSanitizer.FALLBACK_VERSION for null, blank, or placeholder-like values, and logging a warning when the value had to be replaced.
save(MetadataScope, String, String, Map) - Method in class ai.pipestream.registration.metadata.TypeMetadataService: Fully replaces one scope's annotations for a type.
SaveResult(int, Instant) - Constructor for record class ai.pipestream.registration.metadata.TypeMetadataService.SaveResult: Creates an instance of a SaveResult record class.
saveSchema(String, String, String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Save a configuration schema (dual storage: PostgreSQL + Apicurio).
saveTypeMetadata(SaveTypeMetadataRequest) - Method in class ai.pipestream.registration.handlers.TypeMetadataHandler: Saves one scope's annotations.
saveTypeMetadata(SaveTypeMetadataRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
schemaId - Variable in class ai.pipestream.registration.entity.ConfigSchema: Primary key: the generated unique schema ID.
SchemaRegistrationResponse(String, Long, String) - Constructor for class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse: Creates a registration response.
SchemaRetrievalHandler - Class in ai.pipestream.registration.handlers: Retrieves module configuration schemas from the platform registry (DB, then Apicurio).
SchemaRetrievalHandler() - Constructor for class ai.pipestream.registration.handlers.SchemaRetrievalHandler: Creates the handler bean.
schemaVersion - Variable in class ai.pipestream.registration.entity.ConfigSchema: Version of the schema.
scope - Variable in class ai.pipestream.registration.entity.TypeMetadataOverlay.Key: Overlay scope ("GLOBAL_DRAFT" or "PIPELINE").
ServiceDiscoveryHandler - Class in ai.pipestream.registration.handlers: Handles service discovery and lookup operations.
ServiceDiscoveryHandler() - Constructor for class ai.pipestream.registration.handlers.ServiceDiscoveryHandler: Creates the handler bean.
serviceId - Variable in class ai.pipestream.registration.entity.ServiceModule: Primary key: the generated unique service ID.
ServiceModule - Class in ai.pipestream.registration.entity: Entity representing a registered service module in the system.
ServiceModule() - Constructor for class ai.pipestream.registration.entity.ServiceModule: Creates an empty module entity.
serviceName - Variable in class ai.pipestream.registration.entity.ConfigSchema: Name of the service this schema belongs to.
serviceName - Variable in class ai.pipestream.registration.entity.ServiceModule: Name of the registered service.
ServiceRegisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceRegisteredExtractor: Creates the extractor bean.
ServiceRegistrationHandler - Class in ai.pipestream.registration.handlers: Handles service registration operations.
ServiceRegistrationHandler() - Constructor for class ai.pipestream.registration.handlers.ServiceRegistrationHandler: Creates the handler bean.
ServiceStatus - Enum Class in ai.pipestream.registration.entity: Status of a registered service module
ServiceUnregisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceUnregisteredExtractor: Creates the extractor bean.
status - Variable in class ai.pipestream.registration.entity.MetadataPendingBake: Bake status; PENDING until phase-2 automation consumes it.
status - Variable in class ai.pipestream.registration.entity.ServiceModule: Current lifecycle status; defaults to ServiceStatus.ACTIVE.
SYNCED - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus: Successfully synced.
syncError - Variable in class ai.pipestream.registration.entity.ConfigSchema: Error message from the most recent failed sync, or null when none.
syncStatus - Variable in class ai.pipestream.registration.entity.ConfigSchema: Current synchronization state with Apicurio; defaults to ConfigSchema.SyncStatus.PENDING.

T

toString() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.registration.handlers.ValidationResult: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.PromoteResult: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.SaveResult: Returns a string representation of this record class.
toString() - Method in record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Returns a string representation of this record class.
TypeDescriptorHandler - Class in ai.pipestream.registration.handlers: Serves the descriptor door: resolves Any type_urls to self-contained descriptor sets and lists the available type catalog, mapping TypeDescriptorIndex results onto the documented gRPC error contract (INVALID_ARGUMENT / NOT_FOUND / FAILED_PRECONDITION).
TypeDescriptorHandler() - Constructor for class ai.pipestream.registration.handlers.TypeDescriptorHandler: Creates the handler bean.
TypeDescriptorIndex - Class in ai.pipestream.registration.descriptors: In-memory index over the full-workspace protobuf descriptor snapshot baked into this service at build time (descriptors/pipestream-workspace.desc, a serialized DescriptorProtos.FileDescriptorSet produced by buf build over the entire pipestream-protos workspace).
TypeDescriptorIndex() - Constructor for class ai.pipestream.registration.descriptors.TypeDescriptorIndex: Creates the index bean.
TypeDescriptorIndex.TypeDescriptorPayload - Record Class in ai.pipestream.registration.descriptors: One type's served descriptor set: the bytes, their content-hash version, and catalog metadata.
TypeDescriptorIndex.TypeSummary - Record Class in ai.pipestream.registration.descriptors: Catalog row for ListTypeDescriptors.
TypeDescriptorPayload(byte[], String, String, String) - Constructor for record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Creates an instance of a TypeDescriptorPayload record class.
TypeMetadataHandler - Class in ai.pipestream.registration.handlers: Serves the type metadata catalog doors, mapping TypeMetadataService results onto the documented gRPC error contract (NOT_FOUND unknown type / missing draft; INVALID_ARGUMENT bad scope combination or unknown field_path).
TypeMetadataHandler() - Constructor for class ai.pipestream.registration.handlers.TypeMetadataHandler: Creates the handler bean.
TypeMetadataOverlay - Class in ai.pipestream.registration.entity: One writable metadata overlay: a (scope, graph, type) triple holding the field annotations for that layer.
TypeMetadataOverlay() - Constructor for class ai.pipestream.registration.entity.TypeMetadataOverlay: Creates an empty entity instance for JPA.
TypeMetadataOverlay.Key - Class in ai.pipestream.registration.entity: Composite key: scope + graph + type.
TypeMetadataService - Class in ai.pipestream.registration.metadata: The type metadata catalog: layered field annotations over message types.
TypeMetadataService() - Constructor for class ai.pipestream.registration.metadata.TypeMetadataService: Creates the service bean.
TypeMetadataService.PromoteResult - Record Class in ai.pipestream.registration.metadata: Result of a promotion.
TypeMetadataService.SaveResult - Record Class in ai.pipestream.registration.metadata: Result of a save.
TypeSummary(String, String, String) - Constructor for record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Creates an instance of a TypeSummary record class.

U

UNHEALTHY - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus: The service is registered but failing its health signals.
unregister(UnregisterRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
unregisterModule(UnregisterRequest) - Method in class ai.pipestream.registration.handlers.ModuleRegistrationHandler: Unregisters a module from Consul and, on success, emits a ModuleUnregistered OpenSearch event.
unregisterModule(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Unregister a service.
unregisterService(UnregisterRequest) - Method in class ai.pipestream.registration.handlers.ServiceRegistrationHandler: Unregister a service using the unified UnregisterRequest.
updatedAt - Variable in class ai.pipestream.registration.entity.TypeMetadataOverlay: Last save time.
updatedAt() - Method in record class ai.pipestream.registration.metadata.TypeMetadataService.SaveResult: Returns the value of the updatedAt record component.
updateHeartbeat() - Method in class ai.pipestream.registration.entity.ServiceModule: Updates the last heartbeat timestamp.
updateHeartbeat(String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Update heartbeat for a service.
upsertNamedArtifact(String, String, String) - Method in class ai.pipestream.registration.repository.ModuleRepository: Upsert a NAMED schema artifact (recipe schema, uischema, ...) as a ConfigSchema row keyed by the artifact name — same update-on-change semantics as module config schemas, so SNAPSHOT re-registrations refresh content and mark PENDING for Apicurio re-sync.

V

valid() - Method in record class ai.pipestream.registration.handlers.ValidationResult: Returns the value of the valid record component.
validateBase(RegisterRequest) - Static method in class ai.pipestream.registration.handlers.RegisterRequestValidator: Validates base fields common to all registration requests: name required, connectivity required, host required, port > 0.
validateModuleRequest(RegisterRequest) - Static method in class ai.pipestream.registration.handlers.RegisterRequestValidator: Validates a module registration request: base checks + version required.
validateServiceRequest(RegisterRequest) - Static method in class ai.pipestream.registration.handlers.RegisterRequestValidator: Validates a service registration request: base checks + type must be SERVICE or CONNECTOR.
ValidationResult - Record Class in ai.pipestream.registration.handlers: Result of validating a RegisterRequest.
ValidationResult(boolean, List) - Constructor for record class ai.pipestream.registration.handlers.ValidationResult: Creates an instance of a ValidationResult record class.
valueOf(String) - Static method in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.registration.entity.ServiceStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipestream.registration.entity.ServiceStatus: Returns an array containing the constants of this enum class, in the order they are declared.
version - Variable in class ai.pipestream.registration.entity.ServiceModule: Reported version of the service, if any.
version() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeDescriptorPayload: Returns the value of the version record component.
version() - Method in record class ai.pipestream.registration.descriptors.TypeDescriptorIndex.TypeSummary: Returns the value of the version record component.
version() - Method in record class ai.pipestream.registration.repository.ApicurioRegistryClient.ArtifactContent: Returns the value of the version record component.

W

watchModules(WatchModulesRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
watchServices(WatchServicesRequest, StreamObserver) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

A B C D E F G H I J K L M O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form