Package ai.pipestream.data.module.v1

Interface PipeStepProcessorService

All Superinterfaces:

io.quarkus.grpc.MutinyService

All Known Implementing Classes:

PipeStepProcessorServiceClient

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/data/module/v1/module_service.proto")
public interface PipeStepProcessorService
extends io.quarkus.grpc.MutinyService

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<GetServiceRegistrationResponse>	getServiceRegistration(GetServiceRegistrationRequest request)	Returns static registration information about this module with optional health check
io.smallrye.mutiny.Uni<ProcessDataResponse>	processData(ProcessDataRequest request)	Processes a document according to the step's configuration and logic.

Method Details

processData

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

io.smallrye.mutiny.Uni<GetServiceRegistrationResponse> getServiceRegistration(GetServiceRegistrationRequest request)

  Returns static registration information about this module with optional health check