Package ai.pipestream.connector.intake.v1

Class MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>

ai.pipestream.connector.intake.v1.MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub

All Implemented Interfaces:

io.quarkus.grpc.MutinyStub

Enclosing class:

MutinyConnectorIntakeServiceGrpc

public static final class MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub
extends io.grpc.stub.AbstractStub<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>
implements io.quarkus.grpc.MutinyStub

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

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, newStub, newStub, 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 MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<MutinyConnectorIntakeServiceGrpc.MutinyConnectorIntakeServiceStub>

uploadPipeDoc

public io.smallrye.mutiny.Uni<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 io.smallrye.mutiny.Uni<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 io.smallrye.mutiny.Uni<StartCrawlSessionResponse> startCrawlSession(StartCrawlSessionRequest request)

  Register a new crawl session (Async/Background only)
 

endCrawlSession

public io.smallrye.mutiny.Uni<EndCrawlSessionResponse> endCrawlSession(EndCrawlSessionRequest request)

  End a crawl session (for cleanup, orphan detection)
 

heartbeat

public io.smallrye.mutiny.Uni<HeartbeatResponse> heartbeat(HeartbeatRequest request)

  Heartbeat to keep session alive