Index
All Classes and Interfaces|All Packages
A
- ACTIVE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus
- ai.pipestream.registration.consul - package ai.pipestream.registration.consul
- 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.repository - package ai.pipestream.registration.repository
- ai.pipestream.registration.startup - package ai.pipestream.registration.startup
- apicurioArtifactId - Variable in class ai.pipestream.registration.entity.ConfigSchema
- apicurioGlobalId - Variable in class ai.pipestream.registration.entity.ConfigSchema
- ApicurioRegistryClient - Class in ai.pipestream.registration.repository
-
Client for interacting with Apicurio Registry v3.
- ApicurioRegistryClient() - Constructor for class ai.pipestream.registration.repository.ApicurioRegistryClient
- ApicurioRegistryClient.SchemaRegistrationResponse - Class in ai.pipestream.registration.repository
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
- ConfigSchema.SyncStatus - Enum Class in ai.pipestream.registration.entity
- configSchemaId - Variable in class ai.pipestream.registration.entity.ServiceModule
- ConsulClientProducer - Class in ai.pipestream.registration.consul
- ConsulClientProducer() - Constructor for class ai.pipestream.registration.consul.ConsulClientProducer
- ConsulHealthChecker - Class in ai.pipestream.registration.consul
-
Handles health check operations for services registered with Consul
- ConsulHealthChecker() - Constructor for class ai.pipestream.registration.consul.ConsulHealthChecker
- ConsulRegistrar - Class in ai.pipestream.registration.consul
-
Handles service registration and unregistration with Consul
- ConsulRegistrar() - Constructor for class ai.pipestream.registration.consul.ConsulRegistrar
- 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
- create(String, String, String) - Static method in class ai.pipestream.registration.entity.ConfigSchema
- createdAt - Variable in class ai.pipestream.registration.entity.ConfigSchema
- createdBy - Variable in class ai.pipestream.registration.entity.ConfigSchema
- createOrUpdateSchema(String, String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient
-
Create or update a schema in Apicurio Registry
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
E
- emitModuleRegistered(String, String, String, int, String, String, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer
- emitModuleUnregistered(String, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer
- emitServiceRegistered(String, String, String, int, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer
- emitServiceUnregistered(String, String) - Method in class ai.pipestream.registration.events.OpenSearchEventsProducer
F
- FAILED - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus
- findById(String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Get service by ID
- findLatestSchemaByServiceName(String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Get 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
- 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
- generateServiceId(String, String, int) - Static method in class ai.pipestream.registration.consul.ConsulRegistrar
-
Generate a consistent service ID from service details
- generateServiceId(String, String, int) - Static method in class ai.pipestream.registration.entity.ServiceModule
- 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)
- getArtifactId() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse
- getArtifactMetadata(String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient
-
Get artifact metadata
- getGlobalId() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse
- getModule(ServiceLookupRequest) - 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.grpc.PlatformRegistrationService
- getModuleSchema(GetModuleSchemaRequest) - Method in class ai.pipestream.registration.handlers.SchemaRetrievalHandler
-
Get module configuration schema from Apicurio Registry or fallback to module direct call
- getSchema(String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient
-
Get schema by artifact ID
- getService(ServiceLookupRequest) - 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)
- getVersion() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse
H
- host - Variable in class ai.pipestream.registration.entity.ServiceModule
I
- INACTIVE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus
- isHealthy() - Method in class ai.pipestream.registration.entity.ServiceModule
- isHealthy() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient
-
Check if Apicurio is healthy
J
- jsonSchema - Variable in class ai.pipestream.registration.entity.ConfigSchema
L
- lastHeartbeat - Variable in class ai.pipestream.registration.entity.ServiceModule
- lastSyncAttempt - Variable in class ai.pipestream.registration.entity.ConfigSchema
- 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
- listModules(Empty) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- listServices() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler
-
List all services (non-modules)
- listServices(Empty) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
M
- MAINTENANCE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus
- markSynced(String, Long) - Method in class ai.pipestream.registration.entity.ConfigSchema
- markSyncFailed(String) - Method in class ai.pipestream.registration.entity.ConfigSchema
- markUnhealthy(String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Mark service as unhealthy
- metadata - Variable in class ai.pipestream.registration.entity.ServiceModule
- ModuleRegistrationHandler - Class in ai.pipestream.registration.handlers
-
Handles module registration operations with proper reactive flow
- ModuleRegistrationHandler() - Constructor for class ai.pipestream.registration.handlers.ModuleRegistrationHandler
- ModuleRepository - Class in ai.pipestream.registration.repository
-
Repository for managing service module registrations in MySQL.
- ModuleRepository() - Constructor for class ai.pipestream.registration.repository.ModuleRepository
O
- OpenSearchEventsProducer - Class in ai.pipestream.registration.events
-
Produces events to Kafka for OpenSearch indexing.
- OpenSearchEventsProducer() - Constructor for class ai.pipestream.registration.events.OpenSearchEventsProducer
- OUT_OF_SYNC - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus
P
- PENDING - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus
- PlatformRegistrationService - Class in ai.pipestream.registration.grpc
-
Main platform registration service implementation
- PlatformRegistrationService() - Constructor for class ai.pipestream.registration.grpc.PlatformRegistrationService
- port - Variable in class ai.pipestream.registration.entity.ServiceModule
- produceConsulClient() - Method in class ai.pipestream.registration.consul.ConsulClientProducer
R
- registeredAt - Variable in class ai.pipestream.registration.entity.ServiceModule
- registerModule(ModuleRegistrationRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- registerModule(ModuleRegistrationRequest) - Method in class ai.pipestream.registration.handlers.ModuleRegistrationHandler
-
Register a module with streaming status updates Flow: Validate → Consul → Health → Fetch Metadata → Apicurio → Database → OpenSearch
- registerModule(String, String, int, String, Map<String, Object>, String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Register a new service module with optional schema Updates existing module if it already exists
- registerService(ServiceRegistrationRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- registerService(ServiceRegistrationRequest) - Method in class ai.pipestream.registration.handlers.ServiceRegistrationHandler
-
Register a service with streaming status updates
- registerService(ServiceRegistrationRequest, String) - Method in class ai.pipestream.registration.consul.ConsulRegistrar
-
Register a service with Consul including health check configuration
- resolveService(ServiceResolveRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- resolveService(ServiceResolveRequest) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler
-
Resolve service to find the best available instance
S
- saveSchema(String, String, String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Save a configuration schema (dual storage: MySQL + Apicurio)
- schemaId - Variable in class ai.pipestream.registration.entity.ConfigSchema
- SchemaRegistrationResponse(String, Long, String) - Constructor for class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse
- SchemaRetrievalHandler - Class in ai.pipestream.registration.handlers
-
Handles schema retrieval operations from Apicurio Registry with fallback to module direct calls
- SchemaRetrievalHandler() - Constructor for class ai.pipestream.registration.handlers.SchemaRetrievalHandler
- schemaVersion - Variable in class ai.pipestream.registration.entity.ConfigSchema
- SelfRegistrationService - Class in ai.pipestream.registration.startup
-
Handles self-registration of the platform-registration-service with Consul.
- SelfRegistrationService() - Constructor for class ai.pipestream.registration.startup.SelfRegistrationService
- ServiceDiscoveryHandler - Class in ai.pipestream.registration.handlers
-
Handles service discovery and lookup operations
- ServiceDiscoveryHandler() - Constructor for class ai.pipestream.registration.handlers.ServiceDiscoveryHandler
- serviceId - Variable in class ai.pipestream.registration.entity.ServiceModule
- 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
- serviceName - Variable in class ai.pipestream.registration.entity.ConfigSchema
- serviceName - Variable in class ai.pipestream.registration.entity.ServiceModule
- ServiceRegistrationHandler - Class in ai.pipestream.registration.handlers
-
Handles service registration operations
- ServiceRegistrationHandler() - Constructor for class ai.pipestream.registration.handlers.ServiceRegistrationHandler
- ServiceStatus - Enum Class in ai.pipestream.registration.entity
-
Status of a registered service module
- status - Variable in class ai.pipestream.registration.entity.ServiceModule
- SYNCED - Enum constant in enum class ai.pipestream.registration.entity.ConfigSchema.SyncStatus
- syncError - Variable in class ai.pipestream.registration.entity.ConfigSchema
- syncStatus - Variable in class ai.pipestream.registration.entity.ConfigSchema
U
- UNHEALTHY - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus
- unregisterModule(UnregisterRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- unregisterModule(UnregisterRequest) - Method in class ai.pipestream.registration.handlers.ModuleRegistrationHandler
-
Unregister a module
- unregisterModule(String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Unregister a service
- unregisterService(UnregisterRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- unregisterService(UnregisterRequest) - Method in class ai.pipestream.registration.handlers.ServiceRegistrationHandler
-
Unregister a service
- unregisterService(String) - Method in class ai.pipestream.registration.consul.ConsulRegistrar
-
Unregister a service from Consul
- updateHeartbeat() - Method in class ai.pipestream.registration.entity.ServiceModule
- updateHeartbeat(String) - Method in class ai.pipestream.registration.repository.ModuleRepository
-
Update heartbeat for a service
V
- 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
W
- waitForHealthy(String) - Method in class ai.pipestream.registration.consul.ConsulHealthChecker
-
Wait for a service to become healthy in Consul's view
- watchModules() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler
-
Watch for real-time updates to the list of all registered modules.
- watchModules(Empty) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
- watchServices() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler
-
Watch for real-time updates to the list of all healthy services.
- watchServices(Empty) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService
All Classes and Interfaces|All Packages