Class CrawlSessionRpcService

java.lang.Object
ai.pipeline.connector.intake.session.CrawlSessionRpcService
@ApplicationScoped public class CrawlSessionRpcService extends Object
RPC service for managing crawl session lifecycle and heartbeats.

  • Constructor Summary

    Constructors
    Constructor
    Description
    CrawlSessionRpcService()
    Default constructor for CDI proxying.

  • 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)
    Ends an existing crawl session.
    void
    heartbeat(ai.pipestream.connector.intake.v1.HeartbeatRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.HeartbeatResponse> responseObserver)
    Sends a heartbeat to keep a crawl session alive.
    void
    startCrawlSession(ai.pipestream.connector.intake.v1.StartCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.StartCrawlSessionResponse> responseObserver)
    Starts a new crawl session.

    Methods inherited from class Object

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

  • Constructor Details

    • CrawlSessionRpcService

      public CrawlSessionRpcService()
      Default constructor for CDI proxying.

  • Method Details

    • startCrawlSession

      public void startCrawlSession(ai.pipestream.connector.intake.v1.StartCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.StartCrawlSessionResponse> responseObserver)
      Starts a new crawl session.
      Parameters:
      request - The request to start a new session
      responseObserver - Stream observer for the response

    • endCrawlSession

      public void endCrawlSession(ai.pipestream.connector.intake.v1.EndCrawlSessionRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.EndCrawlSessionResponse> responseObserver)
      Ends an existing crawl session.
      Parameters:
      request - The request to end the session
      responseObserver - Stream observer for the response

    • heartbeat

      public void heartbeat(ai.pipestream.connector.intake.v1.HeartbeatRequest request, io.grpc.stub.StreamObserver<ai.pipestream.connector.intake.v1.HeartbeatResponse> responseObserver)
      Sends a heartbeat to keep a crawl session alive.
      Parameters:
      request - The heartbeat request
      responseObserver - Stream observer for the response