Package ai.pipestream.platform.registration.v1

Class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub>

io.grpc.stub.AbstractBlockingStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub>

ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub

Enclosing class:

PlatformRegistrationServiceGrpc

public static class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub>

A stub to allow clients to do limited synchronous rpc calls to service PlatformRegistrationService.

 Unified registration service for all platform services and modules.
 Provides centralized service discovery via Consul with health monitoring,
 module schema management via Apicurio Registry, and real-time event streaming
 for registration lifecycle tracking.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
GetModuleResponse	getModule(GetModuleRequest request)	Get specific module details by name or Consul service ID.
GetModuleSchemaResponse	getModuleSchema(GetModuleSchemaRequest request)	Get module schema from Apicurio Registry.
GetModuleSchemaVersionsResponse	getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)	List all available schema versions for a module.
GetServiceResponse	getService(GetServiceRequest request)	Get specific service details by name or Consul service ID.
ListModulesResponse	listModules(ListModulesRequest request)	List all registered modules with schema and capability information.
ListServicesResponse	listServices(ListServicesRequest request)	List all registered services with health status and metadata.
Iterator<RegisterResponse>	register(RegisterRequest request)	Register a service or module with streaming status updates.
ResolveServiceResponse	resolveService(ResolveServiceRequest request)	Resolve service endpoint for dynamic routing.
UnregisterResponse	unregister(UnregisterRequest request)	Unregister a service or module from Consul and the platform registry.
Iterator<WatchModulesResponse>	watchModules(WatchModulesRequest request)	Watch for real-time updates to the list of all registered modules.
Iterator<WatchServicesResponse>	watchServices(WatchServicesRequest request)	Watch for real-time updates to the list of all healthy services.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Details

build

protected PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceBlockingStub>

register

public Iterator<RegisterResponse> register(RegisterRequest request)

 Register a service or module with streaming status updates.
 Returns a stream of RegistrationEvent messages tracking progress through
 validation, Consul registration, health check configuration, and completion.
 For modules, also includes schema validation and Apicurio registration.
 

unregister

public UnregisterResponse unregister(UnregisterRequest request)

 Unregister a service or module from Consul and the platform registry.
 

listServices

public ListServicesResponse listServices(ListServicesRequest request)

 List all registered services with health status and metadata.
 

listModules

public ListModulesResponse listModules(ListModulesRequest request)

 List all registered modules with schema and capability information.
 

getService

public GetServiceResponse getService(GetServiceRequest request)

 Get specific service details by name or Consul service ID.
 

getModule

public GetModuleResponse getModule(GetModuleRequest request)

 Get specific module details by name or Consul service ID.
 

resolveService

public ResolveServiceResponse resolveService(ResolveServiceRequest request)

 Resolve service endpoint for dynamic routing.
 Returns the best available instance of a service based on health and load.
 Supports preference criteria like local instances or required capabilities.
 

watchServices

public Iterator<WatchServicesResponse> watchServices(WatchServicesRequest request)

 Watch for real-time updates to the list of all healthy services.
 The server will send an initial list, and then send a new full
 list whenever any service is registered, unregistered, or changes
 its health status.
 

watchModules

public Iterator<WatchModulesResponse> watchModules(WatchModulesRequest request)

 Watch for real-time updates to the list of all registered modules.
 The server will send an initial list, and then send a new full
 list whenever any module is registered, unregistered, or changes
 its health status.
 

getModuleSchema

public GetModuleSchemaResponse getModuleSchema(GetModuleSchemaRequest request)

 Get module schema from Apicurio Registry.
 Retrieves either a specific version or the latest schema for a module.
 Returns JSON Schema used for validating module configuration.
 

getModuleSchemaVersions

public GetModuleSchemaVersionsResponse getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)

 List all available schema versions for a module.
 Provides detailed version metadata from Apicurio Registry including
 creation timestamps and version-specific descriptions.