Class ConnectorIntakeServiceImpl

java.lang.Object
ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase
ai.pipestream.connector.intake.service.ConnectorIntakeServiceImpl
All Implemented Interfaces:
ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.AsyncService, io.grpc.BindableService
@Singleton @RolesAllowed("intake-client") public class ConnectorIntakeServiceImpl extends ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase
Thin gRPC adapter for connector intake endpoints.

Endpoint implementations live in focused services/packages so transport wiring stays separate from intake behavior.

The class-level @RolesAllowed secures every RPC uniformly (and makes any future RPC secure-by-default). The role check is enforced only when OIDC is enabled; while it is off — the default — OidcBypassAugmentor grants the role on every call, so the existing x-api-key metadata gate (and the tracking token on getUploadStatus) remains the sole authority and behavior is unchanged. When OIDC is enabled, callers must additionally present a bearer token (in Authorization metadata) carrying the intake-client role.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConnectorIntakeServiceImpl()
    Default constructor for gRPC service instantiation.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    endCrawlSession(ai.pipestream.connector.intake.v1.EndCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.EndCrawlSessionResponse> responseObserver)
     
    void
    getUploadStatus(ai.pipestream.connector.intake.v1.GetUploadStatusRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.GetUploadStatusResponse> responseObserver)
     
    void
    heartbeat(ai.pipestream.connector.intake.v1.HeartbeatRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.HeartbeatResponse> responseObserver)
     
    void
    startCrawlSession(ai.pipestream.connector.intake.v1.StartCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.StartCrawlSessionResponse> responseObserver)
     
    void
    uploadBlob(ai.pipestream.connector.intake.v1.UploadBlobRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadBlobResponse> responseObserver)
     
    void
    uploadPipeDoc(ai.pipestream.connector.intake.v1.UploadPipeDocRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocResponse> responseObserver)
     
    io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest>
    uploadPipeDocStream(io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamResponse> responseObserver)
     

    Methods inherited from class ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.ConnectorIntakeServiceImplBase

    bindService

    Methods inherited from class Object

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

    Methods inherited from interface ai.pipestream.connector.intake.v1.ConnectorIntakeServiceGrpc.AsyncService

    deletePipeDoc

  • Constructor Details

    • ConnectorIntakeServiceImpl

      public ConnectorIntakeServiceImpl()
      Default constructor for gRPC service instantiation.

  • Method Details

    • uploadPipeDoc

      public void uploadPipeDoc(ai.pipestream.connector.intake.v1.UploadPipeDocRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocResponse> responseObserver)

    • uploadBlob

      public void uploadBlob(ai.pipestream.connector.intake.v1.UploadBlobRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadBlobResponse> responseObserver)

    • getUploadStatus

      public void getUploadStatus(ai.pipestream.connector.intake.v1.GetUploadStatusRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.GetUploadStatusResponse> responseObserver)

    • startCrawlSession

      public void startCrawlSession(ai.pipestream.connector.intake.v1.StartCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.StartCrawlSessionResponse> responseObserver)

    • endCrawlSession

      public void endCrawlSession(ai.pipestream.connector.intake.v1.EndCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.EndCrawlSessionResponse> responseObserver)

    • heartbeat

      public void heartbeat(ai.pipestream.connector.intake.v1.HeartbeatRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.HeartbeatResponse> responseObserver)

    • uploadPipeDocStream

      public io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamRequest> uploadPipeDocStream(io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.UploadPipeDocStreamResponse> responseObserver)