Package ai.pipestream.connector.intake.v1

Class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

java.lang.Object
ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase
All Implemented Interfaces:
ConnectorIntakeServiceGrpc.AsyncService, io.grpc.BindableService
Enclosing class:
ConnectorIntakeServiceGrpc
public abstract static class ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase extends Object implements io.grpc.BindableService, ConnectorIntakeServiceGrpc.AsyncService
Base class for the server implementation of the 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.

  • Constructor Details

    • ConnectorIntakeServiceImplBase

      public ConnectorIntakeServiceImplBase()

  • Method Details

    • bindService

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