Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceGrpc

java.lang.Object

ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc

public final class ConnectorIntakeServiceGrpc
extends Object

 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

Modifier and Type	Class	Description
static interface	ConnectorIntakeServiceGrpc.AsyncService	High-throughput document ingestion service for all connector types.
static final class	ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingStub	A stub to allow clients to do limited synchronous rpc calls to service ConnectorIntakeService.
static final class	ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub	A stub to allow clients to do synchronous rpc calls to service ConnectorIntakeService.
static final class	ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub	A stub to allow clients to do ListenableFuture-style rpc calls to service ConnectorIntakeService.
static class	ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase	Base class for the server implementation of the service ConnectorIntakeService.
static final class	ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub	A stub to allow clients to do asynchronous rpc calls to service ConnectorIntakeService.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
static final io.grpc.ServerServiceDefinition	bindService(ConnectorIntakeServiceGrpc.AsyncService service)
static io.grpc.MethodDescriptor<EndCrawlSessionRequest,EndCrawlSessionResponse>	getEndCrawlSessionMethod()
static io.grpc.MethodDescriptor<HeartbeatRequest,HeartbeatResponse>	getHeartbeatMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<StartCrawlSessionRequest,StartCrawlSessionResponse>	getStartCrawlSessionMethod()
static io.grpc.MethodDescriptor<UploadBlobRequest,UploadBlobResponse>	getUploadBlobMethod()
static io.grpc.MethodDescriptor<UploadPipeDocRequest,UploadPipeDocResponse>	getUploadPipeDocMethod()
static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingStub	newBlockingStub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports unary and streaming output calls on the service
static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub	newBlockingV2Stub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports all types of calls on the service
static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub	newFutureStub(io.grpc.Channel channel)	Creates a new ListenableFuture-style stub that supports unary calls on the service
static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub	newStub(io.grpc.Channel channel)	Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Details

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

• Constant Field Values

Method Details

getUploadPipeDocMethod

public static io.grpc.MethodDescriptor<UploadPipeDocRequest,UploadPipeDocResponse> getUploadPipeDocMethod()

getUploadBlobMethod

public static io.grpc.MethodDescriptor<UploadBlobRequest,UploadBlobResponse> getUploadBlobMethod()

getStartCrawlSessionMethod

public static io.grpc.MethodDescriptor<StartCrawlSessionRequest,StartCrawlSessionResponse> getStartCrawlSessionMethod()

getEndCrawlSessionMethod

public static io.grpc.MethodDescriptor<EndCrawlSessionRequest,EndCrawlSessionResponse> getEndCrawlSessionMethod()

getHeartbeatMethod

public static io.grpc.MethodDescriptor<HeartbeatRequest,HeartbeatResponse> getHeartbeatMethod()

newStub

public static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingV2Stub

public static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports all types of calls on the service

newBlockingStub

public static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static ConnectorIntakeServiceGrpc.ConnectorIntakeServiceFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(ConnectorIntakeServiceGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()