Package ai.pipestream.connector.intake.v1

Class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

java.lang.Object
ai.pipestream.connector.intake.v1.MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase
All Implemented Interfaces:
io.grpc.BindableService
Direct Known Subclasses:
ConnectorIntakeServiceBean, ConnectorIntakeServiceImpl
Enclosing class:
MutinyConnectorIntakeServiceGrpc
public abstract static class MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase extends Object implements io.grpc.BindableService
  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.

  • Constructor Details

    • ConnectorIntakeServiceImplBase

      public ConnectorIntakeServiceImplBase()

  • Method Details

    • withCompression

      public MutinyConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase withCompression(String compression)
      Set whether the server will try to use a compressed response.
      Parameters:
      compression - the compression, e.g gzip

    • 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

    • bindService

      public final io.grpc.ServerServiceDefinition bindService()
      Specified by:
      bindService in interface io.grpc.BindableService