Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub>

io.grpc.stub.AbstractAsyncStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub>

ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub

Enclosing class:

ConnectorIntakeServiceGrpc

public static final class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub
extends io.grpc.stub.AbstractAsyncStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub>

A stub to allow clients to do asynchronous rpc calls to service ConnectorIntakeService.

 High-throughput document ingestion service for all connector types.
 This service provides the main entry point for document ingestion into the AI Pipestream platform.
 It handles authentication, account verification, metadata enrichment, and routing to the repository layer.
 Supports both structured PipeDoc uploads and raw blob uploads with automatic wrapping.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	endCrawlSession(EndCrawlSessionRequest request, io.grpc.stub.StreamObserver<EndCrawlSessionResponse> responseObserver)	End a crawl session (for cleanup, orphan detection)
void	heartbeat(HeartbeatRequest request, io.grpc.stub.StreamObserver<HeartbeatResponse> responseObserver)	Heartbeat to keep session alive
void	startCrawlSession(StartCrawlSessionRequest request, io.grpc.stub.StreamObserver<StartCrawlSessionResponse> responseObserver)	Register a new crawl session (Async/Background only)
void	uploadBlob(UploadBlobRequest request, io.grpc.stub.StreamObserver<UploadBlobResponse> responseObserver)	2.
void	uploadPipeDoc(UploadPipeDocRequest request, io.grpc.stub.StreamObserver<UploadPipeDocResponse> responseObserver)	1.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Details

build

protected ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub>

uploadPipeDoc

public void uploadPipeDoc(UploadPipeDocRequest request,
 io.grpc.stub.StreamObserver<UploadPipeDocResponse> responseObserver)

 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.
 

uploadBlob

public void uploadBlob(UploadBlobRequest request,
 io.grpc.stub.StreamObserver<UploadBlobResponse> responseObserver)

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

startCrawlSession

public void startCrawlSession(StartCrawlSessionRequest request,
 io.grpc.stub.StreamObserver<StartCrawlSessionResponse> responseObserver)

 Register a new crawl session (Async/Background only)
 

endCrawlSession

public void endCrawlSession(EndCrawlSessionRequest request,
 io.grpc.stub.StreamObserver<EndCrawlSessionResponse> responseObserver)

 End a crawl session (for cleanup, orphan detection)
 

heartbeat

public void heartbeat(HeartbeatRequest request,
 io.grpc.stub.StreamObserver<HeartbeatResponse> responseObserver)

 Heartbeat to keep session alive