Class S3DispatchSubscriber.S3DispatchState

java.lang.Object
ai.pipestream.module.pipelineprobe.pipelinecrawl.S3DispatchSubscriber.S3DispatchState
Enclosing class:
S3DispatchSubscriber
public static final class S3DispatchSubscriber.S3DispatchState extends Object
Live mirror of one crawl's connector-side state. Volatile fields, read per tick.

  • Constructor Summary

    Constructors
    Constructor
    Description
    S3DispatchState()
    Creates an empty state in the initial (unspecified phase, no total) condition.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    dispatched()
    Number of objects the connector has dispatched so far.
    String
    error()
    The last error message reported on the status stream, if any.
    boolean
    isComplete()
    Whether the crawl has reached the COMPLETED phase.
    boolean
    isFailed()
    Whether the crawl has reached the FAILED phase.
    ai.pipestream.connector.s3.v1.S3CrawlPhase
    phase()
    Current crawl phase last reported by the connector.
    long
    total()
    Final object count; -1 until the connector reports COMPLETED.
    boolean
    unavailable()
    True when the status stream could not be established — fall back to stability gating.

    Methods inherited from class Object

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

  • Constructor Details

    • S3DispatchState

      public S3DispatchState()
      Creates an empty state in the initial (unspecified phase, no total) condition.

  • Method Details

    • phase

      public ai.pipestream.connector.s3.v1.S3CrawlPhase phase()
      Current crawl phase last reported by the connector.
      Returns:
      the latest phase, or S3_CRAWL_PHASE_UNSPECIFIED if none seen yet

    • dispatched

      public long dispatched()
      Number of objects the connector has dispatched so far.
      Returns:
      the latest dispatched-object count

    • total

      public long total()
      Final object count; -1 until the connector reports COMPLETED.
      Returns:
      the final object total, or -1 if the crawl has not yet completed

    • error

      public String error()
      The last error message reported on the status stream, if any.
      Returns:
      the error message, or null if no error has been reported

    • isComplete

      public boolean isComplete()
      Whether the crawl has reached the COMPLETED phase.
      Returns:
      true if the latest phase is COMPLETED

    • isFailed

      public boolean isFailed()
      Whether the crawl has reached the FAILED phase.
      Returns:
      true if the latest phase is FAILED

    • unavailable

      public boolean unavailable()
      True when the status stream could not be established — fall back to stability gating.
      Returns:
      true if no status ground truth is available for this crawl