Package ai.pipestream.platform.registration.v1

Class PlatformRegistrationServiceClient

java.lang.Object

ai.pipestream.platform.registration.v1.PlatformRegistrationServiceClient

All Implemented Interfaces:

PlatformRegistrationService, io.quarkus.grpc.MutinyClient<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/platform/registration/v1/platform_registration.proto")
public class PlatformRegistrationServiceClient
extends Object
implements PlatformRegistrationService, io.quarkus.grpc.MutinyClient<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>

Constructor Summary

Constructors

Constructor	Description
PlatformRegistrationServiceClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub,MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub> stubConfigurator)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<GetConnectorSchemaResponse>	getConnectorSchema(GetConnectorSchemaRequest request)	Get connector schema from Apicurio Registry.
io.smallrye.mutiny.Uni<GetModuleResponse>	getModule(GetModuleRequest request)	Get specific module details by name or Consul service ID.
io.smallrye.mutiny.Uni<GetModuleSchemaResponse>	getModuleSchema(GetModuleSchemaRequest request)	Get module schema from Apicurio Registry.
io.smallrye.mutiny.Uni<GetModuleSchemaVersionsResponse>	getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)	List all available schema versions for a module.
io.smallrye.mutiny.Uni<GetServiceResponse>	getService(GetServiceRequest request)	Get specific service details by name or Consul service ID.
MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub	getStub()
io.smallrye.mutiny.Uni<ListPlatformModulesResponse>	listPlatformModules(ListPlatformModulesRequest request)	List all registered modules with schema and capability information.
io.smallrye.mutiny.Uni<ListServicesResponse>	listServices(ListServicesRequest request)	List all registered services with health status and metadata.
PlatformRegistrationServiceClient	newInstanceWithStub(MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub stub)
io.smallrye.mutiny.Multi<RegisterResponse>	register(RegisterRequest request)	Register a service or module with streaming status updates.
io.smallrye.mutiny.Uni<ResolveServiceResponse>	resolveService(ResolveServiceRequest request)	Resolve service endpoint for dynamic routing.
io.smallrye.mutiny.Uni<UnregisterResponse>	unregister(UnregisterRequest request)	Unregister a service or module from Consul and the platform registry.
io.smallrye.mutiny.Multi<WatchModulesResponse>	watchModules(WatchModulesRequest request)	Watch for real-time updates to the list of all registered modules.
io.smallrye.mutiny.Multi<WatchServicesResponse>	watchServices(WatchServicesRequest request)	Watch for real-time updates to the list of all healthy services.

Methods inherited from class java.lang.Object

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

Constructor Details

PlatformRegistrationServiceClient

public PlatformRegistrationServiceClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub,MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub> stubConfigurator)

Method Details

newInstanceWithStub

public PlatformRegistrationServiceClient newInstanceWithStub(MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>

getStub

public MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyPlatformRegistrationServiceGrpc.MutinyPlatformRegistrationServiceStub>

unregister

public io.smallrye.mutiny.Uni<UnregisterResponse> unregister(UnregisterRequest request)

Description copied from interface: PlatformRegistrationService

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

Specified by:

unregister in interface PlatformRegistrationService

listServices

public io.smallrye.mutiny.Uni<ListServicesResponse> listServices(ListServicesRequest request)

Description copied from interface: PlatformRegistrationService

  List all registered services with health status and metadata.
 

Specified by:

listServices in interface PlatformRegistrationService

listPlatformModules

public io.smallrye.mutiny.Uni<ListPlatformModulesResponse> listPlatformModules(ListPlatformModulesRequest request)

Description copied from interface: PlatformRegistrationService

  List all registered modules with schema and capability information.
 

Specified by:

listPlatformModules in interface PlatformRegistrationService

getService

public io.smallrye.mutiny.Uni<GetServiceResponse> getService(GetServiceRequest request)

Description copied from interface: PlatformRegistrationService

  Get specific service details by name or Consul service ID.
 

Specified by:

getService in interface PlatformRegistrationService

getModule

public io.smallrye.mutiny.Uni<GetModuleResponse> getModule(GetModuleRequest request)

Description copied from interface: PlatformRegistrationService

  Get specific module details by name or Consul service ID.
 

Specified by:

getModule in interface PlatformRegistrationService

resolveService

public io.smallrye.mutiny.Uni<ResolveServiceResponse> resolveService(ResolveServiceRequest request)

Description copied from interface: PlatformRegistrationService

  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.
 

Specified by:

resolveService in interface PlatformRegistrationService

getModuleSchema

public io.smallrye.mutiny.Uni<GetModuleSchemaResponse> getModuleSchema(GetModuleSchemaRequest request)

Description copied from interface: PlatformRegistrationService

  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.
 

Specified by:

getModuleSchema in interface PlatformRegistrationService

getModuleSchemaVersions

public io.smallrye.mutiny.Uni<GetModuleSchemaVersionsResponse> getModuleSchemaVersions(GetModuleSchemaVersionsRequest request)

Description copied from interface: PlatformRegistrationService

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

Specified by:

getModuleSchemaVersions in interface PlatformRegistrationService

getConnectorSchema

public io.smallrye.mutiny.Uni<GetConnectorSchemaResponse> getConnectorSchema(GetConnectorSchemaRequest request)

Description copied from interface: PlatformRegistrationService

  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.
 

Specified by:

getConnectorSchema in interface PlatformRegistrationService

register

public io.smallrye.mutiny.Multi<RegisterResponse> register(RegisterRequest request)

Description copied from interface: PlatformRegistrationService

  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.
 

Specified by:

register in interface PlatformRegistrationService

watchServices

public io.smallrye.mutiny.Multi<WatchServicesResponse> watchServices(WatchServicesRequest request)

Description copied from interface: PlatformRegistrationService

  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.
 

Specified by:

watchServices in interface PlatformRegistrationService

watchModules

public io.smallrye.mutiny.Multi<WatchModulesResponse> watchModules(WatchModulesRequest request)

Description copied from interface: PlatformRegistrationService

  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.
 

Specified by:

watchModules in interface PlatformRegistrationService