Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingStub

java.lang.Object

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

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

ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingStub

Enclosing class:

ConnectorIntakeServiceGrpc

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

A stub to allow clients to do limited 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.ConnectorIntakeServiceBlockingStub	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.ConnectorIntakeServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

uploadPipeDoc

public 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 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 StartCrawlSessionResponse startCrawlSession(StartCrawlSessionRequest request)

 Register a new crawl session (Async/Background only)
 

endCrawlSession

public EndCrawlSessionResponse endCrawlSession(EndCrawlSessionRequest request)

 End a crawl session (for cleanup, orphan detection)
 

heartbeat

public HeartbeatResponse heartbeat(HeartbeatRequest request)

 Heartbeat to keep session alive