Record Class IndexPushDriver.PushSnapshot

java.lang.Object
java.lang.Record
ai.pipestream.module.pipelineprobe.opensearch.IndexPushDriver.PushSnapshot
Record Components:
jobId - the job's id
planIds - plan ids OSS fans the docs out to
opensearchInstance - Consul service name of the target OS cluster
stage - which court-1000 corpus is being pushed
concurrency - the effective in-flight permit cap
totalRequested - number of docs the job was asked to push
sent - docs sent on the stream so far
ackedOk - docs acknowledged successfully
ackedFail - docs acknowledged with a failure outcome
inFlight - docs sent but not yet acknowledged
startedAt - epoch millis when the job started, or null
finishedAt - epoch millis when the job finished, or null
state - the job's lifecycle state
error - a fatal job-level error message, or null
firstNackReason - first per-doc failure reason, or null
firstGrpcError - first gRPC status error, or null
throughputDocsPerSec - measured throughput in docs per second
Enclosing class:
IndexPushDriver
public static record IndexPushDriver.PushSnapshot(String jobId, List<String> planIds, String opensearchInstance, String stage, int concurrency, int totalRequested, long sent, long ackedOk, long ackedFail, long inFlight, Long startedAt, Long finishedAt, String state, String error, String firstNackReason, String firstGrpcError, double throughputDocsPerSec) extends Record
Snapshot of a push job's progress. Counters read off the IndexPushDriver.PushJob's atomics so the view is consistent within a single field but may skew slightly across fields under load.

Failure-visibility fields: firstNackReason captures the first non-success outcome's log_entries concatenation (the actual server-side reason — usually "OpenSearch sink requires JSON config carrying plan_ids" etc.); firstGrpcError captures the first non-RuntimeException-wrapped gRPC status. Both stay null until something fails; populated with the first failure only so users see a stable reason instead of a moving target.

  • Constructor Details

    • PushSnapshot

      public PushSnapshot(String jobId, List<String> planIds, String opensearchInstance, String stage, int concurrency, int totalRequested, long sent, long ackedOk, long ackedFail, long inFlight, Long startedAt, Long finishedAt, String state, String error, String firstNackReason, String firstGrpcError, double throughputDocsPerSec)
      Creates an instance of a PushSnapshot record class.
      Parameters:
      jobId - the value for the jobId record component
      planIds - the value for the planIds record component
      opensearchInstance - the value for the opensearchInstance record component
      stage - the value for the stage record component
      concurrency - the value for the concurrency record component
      totalRequested - the value for the totalRequested record component
      sent - the value for the sent record component
      ackedOk - the value for the ackedOk record component
      ackedFail - the value for the ackedFail record component
      inFlight - the value for the inFlight record component
      startedAt - the value for the startedAt record component
      finishedAt - the value for the finishedAt record component
      state - the value for the state record component
      error - the value for the error record component
      firstNackReason - the value for the firstNackReason record component
      firstGrpcError - the value for the firstGrpcError record component
      throughputDocsPerSec - the value for the throughputDocsPerSec record component

  • Method Details

    • toString

      public final String toString()
      Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.
      Specified by:
      toString in class Record
      Returns:
      a string representation of this object

    • hashCode

      public final int hashCode()
      Returns a hash code value for this object. The value is derived from the hash code of each of the record components.
      Specified by:
      hashCode in class Record
      Returns:
      a hash code value for this object

    • equals

      public final boolean equals(Object o)
      Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared with Objects::equals(Object,Object); primitive components are compared with the compare method from their corresponding wrapper classes.
      Specified by:
      equals in class Record
      Parameters:
      o - the object with which to compare
      Returns:
      true if this object is the same as the o argument; false otherwise.

    • jobId

      public String jobId()
      Returns the value of the jobId record component.
      Returns:
      the value of the jobId record component

    • planIds

      public List<String> planIds()
      Returns the value of the planIds record component.
      Returns:
      the value of the planIds record component

    • opensearchInstance

      public String opensearchInstance()
      Returns the value of the opensearchInstance record component.
      Returns:
      the value of the opensearchInstance record component

    • stage

      public String stage()
      Returns the value of the stage record component.
      Returns:
      the value of the stage record component

    • concurrency

      public int concurrency()
      Returns the value of the concurrency record component.
      Returns:
      the value of the concurrency record component

    • totalRequested

      public int totalRequested()
      Returns the value of the totalRequested record component.
      Returns:
      the value of the totalRequested record component

    • sent

      public long sent()
      Returns the value of the sent record component.
      Returns:
      the value of the sent record component

    • ackedOk

      public long ackedOk()
      Returns the value of the ackedOk record component.
      Returns:
      the value of the ackedOk record component

    • ackedFail

      public long ackedFail()
      Returns the value of the ackedFail record component.
      Returns:
      the value of the ackedFail record component

    • inFlight

      public long inFlight()
      Returns the value of the inFlight record component.
      Returns:
      the value of the inFlight record component

    • startedAt

      public Long startedAt()
      Returns the value of the startedAt record component.
      Returns:
      the value of the startedAt record component

    • finishedAt

      public Long finishedAt()
      Returns the value of the finishedAt record component.
      Returns:
      the value of the finishedAt record component

    • state

      public String state()
      Returns the value of the state record component.
      Returns:
      the value of the state record component

    • error

      public String error()
      Returns the value of the error record component.
      Returns:
      the value of the error record component

    • firstNackReason

      public String firstNackReason()
      Returns the value of the firstNackReason record component.
      Returns:
      the value of the firstNackReason record component

    • firstGrpcError

      public String firstGrpcError()
      Returns the value of the firstGrpcError record component.
      Returns:
      the value of the firstGrpcError record component

    • throughputDocsPerSec

      public double throughputDocsPerSec()
      Returns the value of the throughputDocsPerSec record component.
      Returns:
      the value of the throughputDocsPerSec record component