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<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<ListModulesResponse>	listModules(ListModulesRequest 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<RegisterModuleResponse>	registerModule(RegisterModuleRequest request)	Register a module (document processor) with streaming status updates.
io.smallrye.mutiny.Multi<RegisterServiceResponse>	registerService(RegisterServiceRequest request)	Register a service with streaming status updates.
io.smallrye.mutiny.Uni<ResolveServiceResponse>	resolveService(ResolveServiceRequest request)	Resolve service endpoint for dynamic routing.
io.smallrye.mutiny.Uni<UnregisterModuleResponse>	unregisterModule(UnregisterModuleRequest request)	Unregister a module from Consul and the platform registry.
io.smallrye.mutiny.Uni<UnregisterServiceResponse>	unregisterService(UnregisterServiceRequest request)	Unregister a service 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>

unregisterService

public io.smallrye.mutiny.Uni<UnregisterServiceResponse> unregisterService(UnregisterServiceRequest request)

Description copied from interface: PlatformRegistrationService

  Unregister a service from Consul and the platform registry.
 

Specified by:

unregisterService in interface PlatformRegistrationService

unregisterModule

public io.smallrye.mutiny.Uni<UnregisterModuleResponse> unregisterModule(UnregisterModuleRequest request)

Description copied from interface: PlatformRegistrationService

  Unregister a module from Consul and the platform registry.
 

Specified by:

unregisterModule 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

listModules

public io.smallrye.mutiny.Uni<ListModulesResponse> listModules(ListModulesRequest request)

Description copied from interface: PlatformRegistrationService

  List all registered modules with schema and capability information.
 

Specified by:

listModules 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

registerService

public io.smallrye.mutiny.Multi<RegisterServiceResponse> registerService(RegisterServiceRequest request)

Description copied from interface: PlatformRegistrationService

  Register a service with streaming status updates.

  Returns a stream of RegistrationEvent messages tracking progress through
  validation, Consul registration, health check configuration, and completion.
 

Specified by:

registerService in interface PlatformRegistrationService

registerModule

public io.smallrye.mutiny.Multi<RegisterModuleResponse> registerModule(RegisterModuleRequest request)

Description copied from interface: PlatformRegistrationService

  Register a module (document processor) with streaming status updates.

  Extends service registration by adding schema validation, Apicurio registration,
  and module-specific metadata handling.
 

Specified by:

registerModule 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