Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub

java.lang.Object

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

io.grpc.stub.AbstractFutureStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub>

ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub

Enclosing class:

ConnectorIntakeServiceGrpc

public static final class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.ConnectorIntakeServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<EndCrawlSessionResponse>	endCrawlSession(EndCrawlSessionRequest request)	End a crawl session (for cleanup, orphan detection)
com.google.common.util.concurrent.ListenableFuture<HeartbeatResponse>	heartbeat(HeartbeatRequest request)	Heartbeat to keep session alive
com.google.common.util.concurrent.ListenableFuture<StartCrawlSessionResponse>	startCrawlSession(StartCrawlSessionRequest request)	Register a new crawl session (Async/Background only)
com.google.common.util.concurrent.ListenableFuture<UploadBlobResponse>	uploadBlob(UploadBlobRequest request)	2.
com.google.common.util.concurrent.ListenableFuture<UploadPipeDocResponse>	uploadPipeDoc(UploadPipeDocRequest request)	1.

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.ConnectorIntakeServiceFutureStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

uploadPipeDoc

public com.google.common.util.concurrent.ListenableFuture<UploadPipeDocResponse> uploadPipeDoc(UploadPipeDocRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<UploadBlobResponse> uploadBlob(UploadBlobRequest request)

 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 com.google.common.util.concurrent.ListenableFuture<StartCrawlSessionResponse> startCrawlSession(StartCrawlSessionRequest request)

 Register a new crawl session (Async/Background only)
 

endCrawlSession

public com.google.common.util.concurrent.ListenableFuture<EndCrawlSessionResponse> endCrawlSession(EndCrawlSessionRequest request)

 End a crawl session (for cleanup, orphan detection)
 

heartbeat

public com.google.common.util.concurrent.ListenableFuture<HeartbeatResponse> heartbeat(HeartbeatRequest request)

 Heartbeat to keep session alive