Package ai.pipestream.data.module.v1

Class PipeStepProcessorServiceClient

java.lang.Object

ai.pipestream.data.module.v1.PipeStepProcessorServiceClient

All Implemented Interfaces:

PipeStepProcessorService, io.quarkus.grpc.MutinyClient<MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/data/module/v1/module_service.proto")
public class PipeStepProcessorServiceClient
extends Object
implements PipeStepProcessorService, io.quarkus.grpc.MutinyClient<MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub>

Constructor Summary

Constructors

Constructor	Description
PipeStepProcessorServiceClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub,MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub> stubConfigurator)

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
MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub	getStub()
PipeStepProcessorServiceClient	newInstanceWithStub(MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub stub)
io.smallrye.mutiny.Uni<ProcessDataResponse>	processData(ProcessDataRequest request)	Processes a document according to the step's configuration and logic.

Methods inherited from class java.lang.Object

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

Constructor Details

PipeStepProcessorServiceClient

public PipeStepProcessorServiceClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub,MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub> stubConfigurator)

Method Details

newInstanceWithStub

public PipeStepProcessorServiceClient newInstanceWithStub(MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub>

getStub

public MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyPipeStepProcessorServiceGrpc.MutinyPipeStepProcessorServiceStub>

processData

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

Description copied from interface: PipeStepProcessorService

  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.
 

Specified by:

processData in interface PipeStepProcessorService

getServiceRegistration

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

Description copied from interface: PipeStepProcessorService

  Returns static registration information about this module with optional health check
 

Specified by:

getServiceRegistration in interface PipeStepProcessorService