Package ai.pipestream.data.module.v1

Class MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase

java.lang.Object
ai.pipestream.data.module.v1.MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase
All Implemented Interfaces:
io.grpc.BindableService
Direct Known Subclasses:
PipeStepProcessorServiceBean
Enclosing class:
MutinyPipeStepProcessorServiceGrpc
public abstract static class MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase extends Object implements io.grpc.BindableService
  Service definition for a pipeline step processor.
  This interface is implemented by developer-created gRPC modules/services.

  • Constructor Details

    • PipeStepProcessorServiceImplBase

      public PipeStepProcessorServiceImplBase()

  • Method Details

    • withCompression

      public MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase withCompression(String compression)
      Set whether the server will try to use a compressed response.
      Parameters:
      compression - the compression, e.g gzip

    • processData

      public io.smallrye.mutiny.Uni<ProcessDataResponse> processData(ProcessDataRequest request)
        Processes a document according to the step's configuration and logic.
  Set is_test=true in the request for test calls that don't count as legitimate processing.

    • getServiceRegistration

      public io.smallrye.mutiny.Uni<GetServiceRegistrationResponse> getServiceRegistration(GetServiceRegistrationRequest request)
        Returns static registration information about this module with optional health check

    • bindService

      public final io.grpc.ServerServiceDefinition bindService()
      Specified by:
      bindService in interface io.grpc.BindableService