Index

A C D E F G H I J 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

ai.pipestream.dynamic.grpc.server - package ai.pipestream.dynamic.grpc.server

ai.pipestream.dynamic.grpc.util - package ai.pipestream.dynamic.grpc.util

ai.pipestream.platform.registration.client - package ai.pipestream.platform.registration.client

ai.pipestream.registration.api - package ai.pipestream.registration.api

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.topics - package ai.pipestream.registration.topics

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

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.

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

Configuration - Search tag in class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

Section

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

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

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.

customize(GrpcServerConfiguration, ServerBuilder) - Method in class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

Customizes the gRPC server builder to set the flow control window.

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

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, off the event loop.

equals(Object) - Method in record class ai.pipestream.registration.handlers.ValidationResult

Indicates whether some other object is "equal to" this one.

evictChannel(String) - Method in class ai.pipestream.platform.registration.client.RegistrationGrpcClients

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<String>) - Static method in record class ai.pipestream.registration.handlers.ValidationResult

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

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.

getActiveServiceCount() - Method in class ai.pipestream.platform.registration.client.RegistrationGrpcClients

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

getArtifactId() - Method in exception class ai.pipestream.registration.repository.ApicurioRegistryException

getArtifactMetadata(String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient

Get artifact metadata Never returns null - returns a failed Uni if metadata cannot be retrieved.

getCacheStats() - Method in class ai.pipestream.platform.registration.client.RegistrationGrpcClients

getGlobalId() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse

getModule(GetModuleRequest) - 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

getModuleSchema(String, String) - Method in class ai.pipestream.registration.api.ModuleSchemaResource

getModuleSchemaVersions(GetModuleSchemaVersionsRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

getModuleSchemaVersions(GetModuleSchemaVersionsRequest) - Method in class ai.pipestream.registration.handlers.SchemaRetrievalHandler

getPlatformRegistrationClient(String) - Method in class ai.pipestream.platform.registration.client.RegistrationGrpcClients

Get a PlatformRegistration client for a given service.

getSchema(String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient

Get schema by artifact ID (legacy naming, uses versionedArtifactId internally)

getSchemaByArtifactId(String, String) - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient

Get schema by raw artifact ID

getService(GetServiceRequest) - 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

getVersion() - Method in class ai.pipestream.registration.repository.ApicurioRegistryClient.SchemaRegistrationResponse

GrpcServerFlowControlCustomizer - Class in ai.pipestream.dynamic.grpc.server

Customizes the gRPC server builder to set the HTTP/2 flow control window for optimal large message throughput.

GrpcServerFlowControlCustomizer() - Constructor for class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

H

hashCode() - Method in record class ai.pipestream.registration.handlers.ValidationResult

Returns a hash code value for this object.

host - Variable in class ai.pipestream.registration.entity.ServiceModule

HostnameResolver - Class in ai.pipestream.dynamic.grpc.util

Simple utility to resolve hostname for service registration.

How It Works - Search tag in class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

Section

I

INACTIVE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus

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

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

listPlatformModules(ListPlatformModulesRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

listServices() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler

List all services (non-modules)

listServices(ListServicesRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

logHostnameResolution(String) - Static method in class ai.pipestream.dynamic.grpc.util.HostnameResolver

Log current hostname resolution for debugging.

M

MAINTENANCE - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus

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

metadata - Variable in class ai.pipestream.registration.entity.ServiceModule

ModuleRegisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleRegisteredExtractor

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 PostgreSQL.

ModuleRepository() - Constructor for class ai.pipestream.registration.repository.ModuleRepository

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

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

ModuleUnregisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ModuleUnregisteredExtractor

O

ok() - Static method in record class ai.pipestream.registration.handlers.ValidationResult

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

PlatformEventsKeyExtractors - Class in ai.pipestream.registration.events

PlatformEventsKeyExtractors() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors

PlatformEventsKeyExtractors.ModuleRegisteredExtractor - Class in ai.pipestream.registration.events

PlatformEventsKeyExtractors.ModuleUnregisteredExtractor - Class in ai.pipestream.registration.events

PlatformEventsKeyExtractors.ServiceRegisteredExtractor - Class in ai.pipestream.registration.events

PlatformEventsKeyExtractors.ServiceUnregisteredExtractor - Class in ai.pipestream.registration.events

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

priority() - Method in class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

Returns the priority for this customizer.

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

register(RegisterRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

Unified registration method - routes based on ServiceType.

registeredAt - Variable in class ai.pipestream.registration.entity.ServiceModule

registerModule(RegisterRequest) - Method in class ai.pipestream.registration.handlers.ModuleRegistrationHandler

Register a module with streaming status updates.

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

RegisterRequestValidator - Class in ai.pipestream.registration.handlers

Shared validation logic for RegisterRequest.

registerService(RegisterRequest) - Method in class ai.pipestream.registration.handlers.ServiceRegistrationHandler

Register a service with streaming status updates.

RegistrationGrpcClients - Class in ai.pipestream.platform.registration.client

Service-specific gRPC client factory for platform-registration-service.

RegistrationGrpcClients() - Constructor for class ai.pipestream.platform.registration.client.RegistrationGrpcClients

RegistrationVersionSanitizer - Class in ai.pipestream.registration.handlers

Defensive sanitizer for registration version strings coming from modules/services.

resolveHostname() - Static method in class ai.pipestream.dynamic.grpc.util.HostnameResolver

Resolve hostname with no service-specific lookup.

resolveHostname(String) - Static method in class ai.pipestream.dynamic.grpc.util.HostnameResolver

Resolve hostname using environment variables and fallbacks

resolveService(ResolveServiceRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

resolveService(ResolveServiceRequest) - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler

Resolve service to find the best available instance

S

sanitize(String, String, Logger, String) - Static method in class ai.pipestream.registration.handlers.RegistrationVersionSanitizer

saveSchema(String, String, String) - Method in class ai.pipestream.registration.repository.ModuleRepository

Save a configuration schema (dual storage: PostgreSQL + 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

Retrieves module configuration schemas from the platform registry (DB, then Apicurio).

SchemaRetrievalHandler() - Constructor for class ai.pipestream.registration.handlers.SchemaRetrievalHandler

schemaVersion - Variable in class ai.pipestream.registration.entity.ConfigSchema

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

ServiceRegisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceRegisteredExtractor

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

ServiceUnregisteredExtractor() - Constructor for class ai.pipestream.registration.events.PlatformEventsKeyExtractors.ServiceUnregisteredExtractor

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

T

toString() - Method in record class ai.pipestream.registration.handlers.ValidationResult

Returns a string representation of this record class.

U

UNHEALTHY - Enum constant in enum class ai.pipestream.registration.entity.ServiceStatus

unregister(UnregisterRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

Unified unregistration method.

unregisterModule(UnregisterRequest) - Method in class ai.pipestream.registration.handlers.ModuleRegistrationHandler

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

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

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<String>) - 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

W

watchModules() - Method in class ai.pipestream.registration.handlers.ServiceDiscoveryHandler

Watch for real-time updates to the list of all registered modules.

watchModules(WatchModulesRequest) - 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(WatchServicesRequest) - Method in class ai.pipestream.registration.grpc.PlatformRegistrationService

Why Separate Server Mode? - Search tag in class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

Section

Why This Is Critical - Search tag in class ai.pipestream.dynamic.grpc.server.GrpcServerFlowControlCustomizer

Section

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