Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceClient

java.lang.Object

ai.pipestream.connector.intake.v1.ConnectorIntakeServiceClient

All Implemented Interfaces:

ConnectorIntakeService, io.quarkus.grpc.MutinyClient<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: ai/pipestream/connector/intake/v1/connector_intake_service.proto")
public class ConnectorIntakeServiceClient
extends Object
implements ConnectorIntakeService, io.quarkus.grpc.MutinyClient<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>

Constructor Summary

Constructors

Constructor	Description
ConnectorIntakeServiceClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub,MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub> stubConfigurator)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<EndCrawlSessionResponse>	endCrawlSession(EndCrawlSessionRequest request)	End a crawl session (for cleanup, orphan detection)
MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub	getStub()
io.smallrye.mutiny.Uni<HeartbeatResponse>	heartbeat(HeartbeatRequest request)	Heartbeat to keep session alive
ConnectorIntakeServiceClient	newInstanceWithStub(MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub stub)
io.smallrye.mutiny.Uni<StartCrawlSessionResponse>	startCrawlSession(StartCrawlSessionRequest request)	Register a new crawl session (Async/Background only)
io.smallrye.mutiny.Uni<UploadBlobResponse>	uploadBlob(UploadBlobRequest request)	2.
io.smallrye.mutiny.Uni<UploadPipeDocResponse>	uploadPipeDoc(UploadPipeDocRequest request)	1.

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectorIntakeServiceClient

public ConnectorIntakeServiceClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub,MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub> stubConfigurator)

Method Details

newInstanceWithStub

public ConnectorIntakeServiceClient newInstanceWithStub(MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>

getStub

public MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>

uploadPipeDoc

public io.smallrye.mutiny.Uni<UploadPipeDocResponse> uploadPipeDoc(UploadPipeDocRequest request)

Description copied from interface: ConnectorIntakeService

  1. The "Power User" path: Client sends a full PipeDoc
  Best for internal services, advanced connectors, or "Box.com" style integrations
  where the client already knows the structure.
 

Specified by:

uploadPipeDoc in interface ConnectorIntakeService

uploadBlob

public io.smallrye.mutiny.Uni<UploadBlobResponse> uploadBlob(UploadBlobRequest request)

Description copied from interface: ConnectorIntakeService

  2. The "Simple" path: Client sends raw bytes (Blob) + minimal metadata
  Best for "I just have a file" scenarios. Intake constructs the PipeDoc wrapper.
 

Specified by:

uploadBlob in interface ConnectorIntakeService

startCrawlSession

public io.smallrye.mutiny.Uni<StartCrawlSessionResponse> startCrawlSession(StartCrawlSessionRequest request)

Description copied from interface: ConnectorIntakeService

  Register a new crawl session (Async/Background only)
 

Specified by:

startCrawlSession in interface ConnectorIntakeService

endCrawlSession

public io.smallrye.mutiny.Uni<EndCrawlSessionResponse> endCrawlSession(EndCrawlSessionRequest request)

Description copied from interface: ConnectorIntakeService

  End a crawl session (for cleanup, orphan detection)
 

Specified by:

endCrawlSession in interface ConnectorIntakeService

heartbeat

public io.smallrye.mutiny.Uni<HeartbeatResponse> heartbeat(HeartbeatRequest request)

Description copied from interface: ConnectorIntakeService

  Heartbeat to keep session alive
 

Specified by:

heartbeat in interface ConnectorIntakeService