Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub

java.lang.Object

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

io.grpc.stub.AbstractBlockingStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub>

ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub

Enclosing class:

ConnectorIntakeServiceGrpc

public static final class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub>

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

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

uploadPipeDoc

public UploadPipeDocResponse uploadPipeDoc(UploadPipeDocRequest request)
                                    throws io.grpc.StatusException

 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.
 

Throws:

io.grpc.StatusException

uploadBlob

public UploadBlobResponse uploadBlob(UploadBlobRequest request)
                              throws io.grpc.StatusException

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

Throws:

io.grpc.StatusException

startCrawlSession

public StartCrawlSessionResponse startCrawlSession(StartCrawlSessionRequest request)
                                            throws io.grpc.StatusException

 Register a new crawl session (Async/Background only)
 

Throws:

io.grpc.StatusException

endCrawlSession

public EndCrawlSessionResponse endCrawlSession(EndCrawlSessionRequest request)
                                        throws io.grpc.StatusException

 End a crawl session (for cleanup, orphan detection)
 

Throws:

io.grpc.StatusException

heartbeat

public HeartbeatResponse heartbeat(HeartbeatRequest request)
                            throws io.grpc.StatusException

 Heartbeat to keep session alive
 

Throws:

io.grpc.StatusException