Package ai.pipestream.data.module.v1

Interface PipeStepProcessorServiceGrpc.AsyncService

All Known Implementing Classes:
PipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase
Enclosing class:
PipeStepProcessorServiceGrpc
public static interface PipeStepProcessorServiceGrpc.AsyncService
 Service definition for a pipeline step processor.
 This interface is implemented by developer-created gRPC modules/services.

  • Method Details

    • processData

      default void processData(ProcessDataRequest request, io.grpc.stub.StreamObserver<ProcessDataResponse> responseObserver)
       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

      default void getServiceRegistration(GetServiceRegistrationRequest request, io.grpc.stub.StreamObserver<GetServiceRegistrationResponse> responseObserver)
       Returns static registration information about this module with optional health check