Package ai.pipestream.platform.registration.v1
package ai.pipestream.platform.registration.v1
-
ClassDescriptionEvent metadata wrapper for key-value pairs.Event metadata wrapper for key-value pairs.Registration event types tracking lifecycle stages.Request to look up module details.Request to look up module details.Complete details for a registered module instance.Complete details for a registered module instance.Request to retrieve module configuration schema from Apicurio Registry.Request to retrieve module configuration schema from Apicurio Registry.Response containing module configuration schema.Response containing module configuration schema.Request to list all schema versions for a module.Request to list all schema versions for a module.Response containing all schema versions for a module.Response containing all schema versions for a module.Request to look up service details.Request to look up service details.Complete details for a registered service instance.Complete details for a registered service instance.Request to list all registered modules.Request to list all registered modules.Response containing list of all registered modules.Response containing list of all registered modules.Request to list all registered services.Request to list all registered services.Response containing list of all registered services.Response containing list of all registered services.Event published to Kafka when a module is registered.Event published to Kafka when a module is registered.Metadata for a single schema version.Metadata for a single schema version.Event published to Kafka when a module is unregistered.Event published to Kafka when a module is unregistered.Unified registration service for all platform services and modules.Unified registration service for all platform services and modules.Unified registration service for all platform services and modules.Unified registration service for all platform services and modules.A stub to allow clients to do limited synchronous rpc calls to service PlatformRegistrationService.A stub to allow clients to do synchronous rpc calls to service PlatformRegistrationService.A stub to allow clients to do ListenableFuture-style rpc calls to service PlatformRegistrationService.Base class for the server implementation of the service PlatformRegistrationService.A stub to allow clients to do asynchronous rpc calls to service PlatformRegistrationService.Request to register a module (document processor) with the platform.Request to register a module (document processor) with the platform.Response for RegisterModule RPC (streaming).Response for RegisterModule RPC (streaming).Request to register a service with the platform.Request to register a service with the platform.Response for RegisterService RPC (streaming).Response for RegisterService RPC (streaming).Streaming registration event tracking registration progress.Streaming registration event tracking registration progress.Request to resolve service endpoint for dynamic routing.Request to resolve service endpoint for dynamic routing.Response from service resolution containing the best available instance.Response from service resolution containing the best available instance.Event published to Kafka when a service is registered.Event published to Kafka when a service is registered.Event published to Kafka when a service is unregistered.Event published to Kafka when a service is unregistered.Request to unregister a module.Request to unregister a module.Response from module unregistration operation.Response from module unregistration operation.Request to unregister a service.Request to unregister a service.Response from service unregistration operation.Response from service unregistration operation.Request to watch for module registration changes.Request to watch for module registration changes.Response for WatchModules RPC (streaming).Response for WatchModules RPC (streaming).Request to watch for service registration changes.Request to watch for service registration changes.Response for WatchServices RPC (streaming).Response for WatchServices RPC (streaming).