Package ai.pipestream.platform.registration.v1

Class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceFutureStub

java.lang.Object

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

io.grpc.stub.AbstractFutureStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceFutureStub>

ai.pipestream.platform.registration.v1.PlatformRegistrationServiceGrpc.PlatformRegistrationServiceFutureStub

Enclosing class:

PlatformRegistrationServiceGrpc

public static final class PlatformRegistrationServiceGrpc.PlatformRegistrationServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<PlatformRegistrationServiceGrpc.PlatformRegistrationServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.PlatformRegistrationServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<GetConnectorSchemaResponse>	getConnectorSchema(GetConnectorSchemaRequest request)	Get connector schema from Apicurio Registry.
com.google.common.util.concurrent.ListenableFuture<GetModuleResponse>	getModule(GetModuleRequest request)	Get specific module details by name or Consul service ID.
com.google.common.util.concurrent.ListenableFuture<GetModuleSchemaResponse>	getModuleSchema(GetModuleSchemaRequest request)	Get module schema from Apicurio Registry.
com.google.common.util.concurrent.ListenableFuture<GetModuleSchemaVersionsResponse>	getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)	List all available schema versions for a module.
com.google.common.util.concurrent.ListenableFuture<GetServiceResponse>	getService(GetServiceRequest request)	Get specific service details by name or Consul service ID.
com.google.common.util.concurrent.ListenableFuture<ListPlatformModulesResponse>	listPlatformModules(ListPlatformModulesRequest request)	List all registered modules with schema and capability information.
com.google.common.util.concurrent.ListenableFuture<ListServicesResponse>	listServices(ListServicesRequest request)	List all registered services with health status and metadata.
com.google.common.util.concurrent.ListenableFuture<ResolveServiceResponse>	resolveService(ResolveServiceRequest request)	Resolve service endpoint for dynamic routing.
com.google.common.util.concurrent.ListenableFuture<UnregisterResponse>	unregister(UnregisterRequest request)	Unregister a service or module from Consul and the platform registry.

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.PlatformRegistrationServiceFutureStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

unregister

public com.google.common.util.concurrent.ListenableFuture<UnregisterResponse> unregister(UnregisterRequest request)

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

listServices

public com.google.common.util.concurrent.ListenableFuture<ListServicesResponse> listServices(ListServicesRequest request)

 List all registered services with health status and metadata.
 

listPlatformModules

public com.google.common.util.concurrent.ListenableFuture<ListPlatformModulesResponse> listPlatformModules(ListPlatformModulesRequest request)

 List all registered modules with schema and capability information.
 

getService

public com.google.common.util.concurrent.ListenableFuture<GetServiceResponse> getService(GetServiceRequest request)

 Get specific service details by name or Consul service ID.
 

getModule

public com.google.common.util.concurrent.ListenableFuture<GetModuleResponse> getModule(GetModuleRequest request)

 Get specific module details by name or Consul service ID.
 

resolveService

public com.google.common.util.concurrent.ListenableFuture<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.
 

getModuleSchema

public com.google.common.util.concurrent.ListenableFuture<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 com.google.common.util.concurrent.ListenableFuture<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.
 

getConnectorSchema

public com.google.common.util.concurrent.ListenableFuture<GetConnectorSchemaResponse> getConnectorSchema(GetConnectorSchemaRequest request)

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