Package ai.pipestream.data.module.v1

Class PipeStepProcessorServiceBean

java.lang.Object

ai.pipestream.data.module.v1.MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase

ai.pipestream.data.module.v1.PipeStepProcessorServiceBean

All Implemented Interfaces:

io.grpc.BindableService, io.quarkus.grpc.MutinyBean

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/data/module/v1/module_service.proto")
public class PipeStepProcessorServiceBean
extends MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase
implements io.grpc.BindableService, io.quarkus.grpc.MutinyBean

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.

Methods inherited from class ai.pipestream.data.module.v1.MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase

bindService, withCompression

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.grpc.BindableService

bindService

Method Details

processData

public io.smallrye.mutiny.Uni<ProcessDataResponse> processData(ProcessDataRequest request)

Description copied from class: MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase

  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.
 

Overrides:

processData in class MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase

getServiceRegistration

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

Description copied from class: MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase

  Returns static registration information about this module with optional health check
 

Overrides:

getServiceRegistration in class MutinyPipeStepProcessorServiceGrpc.PipeStepProcessorServiceImplBase