Package ai.pipestream.data.v1

Interface DlqMessageOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
DlqMessage, DlqMessage.Builder
@Generated public interface DlqMessageOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    getDlqReprocessCount()
    Number of times this message has been reprocessed from the DLQ.
    String
    getErrorMessage()
    Human-readable error message.
    com.google.protobuf.ByteString
    getErrorMessageBytes()
    Human-readable error message.
    String
    getErrorType()
    Error classification.
    com.google.protobuf.ByteString
    getErrorTypeBytes()
    Error classification.
    com.google.protobuf.Timestamp
    getFailedAt()
    Timestamp when the failure occurred.
    com.google.protobuf.TimestampOrBuilder
    getFailedAtOrBuilder()
    Timestamp when the failure occurred.
    String
    getFailedNodeId()
    Node ID where the failure occurred.
    com.google.protobuf.ByteString
    getFailedNodeIdBytes()
    Node ID where the failure occurred.
    long
    getOriginalOffset()
    Original Kafka offset for replay correlation.
    int
    getOriginalPartition()
    Original Kafka partition for replay correlation.
    String
    getOriginalTopic()
    Original Kafka topic for replay correlation.
    com.google.protobuf.ByteString
    getOriginalTopicBytes()
    Original Kafka topic for replay correlation.
    boolean
    getQuarantined()
    Whether this message has been quarantined (exceeded max reprocess attempts).
    com.google.protobuf.Timestamp
    getQuarantinedAt()
    Timestamp when the message was quarantined (if applicable).
    com.google.protobuf.TimestampOrBuilder
    getQuarantinedAtOrBuilder()
    Timestamp when the message was quarantined (if applicable).
    int
    getRetryCount()
    Number of retry attempts that were made before sending to DLQ.
    PipeStream
    getStream()
    The failed stream (contains document reference).
    PipeStreamOrBuilder
    getStreamOrBuilder()
    The failed stream (contains document reference).
    boolean
    hasFailedAt()
    Timestamp when the failure occurred.
    boolean
    hasQuarantinedAt()
    Timestamp when the message was quarantined (if applicable).
    boolean
    hasStream()
    The failed stream (contains document reference).

    Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

    isInitialized

    Methods inherited from interface com.google.protobuf.MessageOrBuilder

    findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

  • Method Details

    • hasStream

      boolean hasStream()
       The failed stream (contains document reference).
      .ai.pipestream.data.v1.PipeStream stream = 1 [json_name = "stream"];
      Returns:
      Whether the stream field is set.

    • getStream

      PipeStream getStream()
       The failed stream (contains document reference).
      .ai.pipestream.data.v1.PipeStream stream = 1 [json_name = "stream"];
      Returns:
      The stream.

    • getStreamOrBuilder

      PipeStreamOrBuilder getStreamOrBuilder()
       The failed stream (contains document reference).
      .ai.pipestream.data.v1.PipeStream stream = 1 [json_name = "stream"];

    • getErrorType

      String getErrorType()
       Error classification.

 Examples: "TIMEOUT", "CONNECTION_REFUSED", "UNAVAILABLE", "MODULE_UNAVAILABLE"
      string error_type = 2 [json_name = "errorType"];
      Returns:
      The errorType.

    • getErrorTypeBytes

      com.google.protobuf.ByteString getErrorTypeBytes()
       Error classification.

 Examples: "TIMEOUT", "CONNECTION_REFUSED", "UNAVAILABLE", "MODULE_UNAVAILABLE"
      string error_type = 2 [json_name = "errorType"];
      Returns:
      The bytes for errorType.

    • getErrorMessage

      String getErrorMessage()
       Human-readable error message.
      string error_message = 3 [json_name = "errorMessage"];
      Returns:
      The errorMessage.

    • getErrorMessageBytes

      com.google.protobuf.ByteString getErrorMessageBytes()
       Human-readable error message.
      string error_message = 3 [json_name = "errorMessage"];
      Returns:
      The bytes for errorMessage.

    • hasFailedAt

      boolean hasFailedAt()
       Timestamp when the failure occurred.
      .google.protobuf.Timestamp failed_at = 4 [json_name = "failedAt"];
      Returns:
      Whether the failedAt field is set.

    • getFailedAt

      com.google.protobuf.Timestamp getFailedAt()
       Timestamp when the failure occurred.
      .google.protobuf.Timestamp failed_at = 4 [json_name = "failedAt"];
      Returns:
      The failedAt.

    • getFailedAtOrBuilder

      com.google.protobuf.TimestampOrBuilder getFailedAtOrBuilder()
       Timestamp when the failure occurred.
      .google.protobuf.Timestamp failed_at = 4 [json_name = "failedAt"];

    • getRetryCount

      int getRetryCount()
       Number of retry attempts that were made before sending to DLQ.
      int32 retry_count = 5 [json_name = "retryCount"];
      Returns:
      The retryCount.

    • getFailedNodeId

      String getFailedNodeId()
       Node ID where the failure occurred.
      string failed_node_id = 6 [json_name = "failedNodeId"];
      Returns:
      The failedNodeId.

    • getFailedNodeIdBytes

      com.google.protobuf.ByteString getFailedNodeIdBytes()
       Node ID where the failure occurred.
      string failed_node_id = 6 [json_name = "failedNodeId"];
      Returns:
      The bytes for failedNodeId.

    • getOriginalTopic

      String getOriginalTopic()
       Original Kafka topic for replay correlation.
      string original_topic = 7 [json_name = "originalTopic"];
      Returns:
      The originalTopic.

    • getOriginalTopicBytes

      com.google.protobuf.ByteString getOriginalTopicBytes()
       Original Kafka topic for replay correlation.
      string original_topic = 7 [json_name = "originalTopic"];
      Returns:
      The bytes for originalTopic.

    • getOriginalPartition

      int getOriginalPartition()
       Original Kafka partition for replay correlation.
      int32 original_partition = 8 [json_name = "originalPartition"];
      Returns:
      The originalPartition.

    • getOriginalOffset

      long getOriginalOffset()
       Original Kafka offset for replay correlation.
      int64 original_offset = 9 [json_name = "originalOffset"];
      Returns:
      The originalOffset.

    • getDlqReprocessCount

      int getDlqReprocessCount()
       Number of times this message has been reprocessed from the DLQ.

 Incremented each time the message is replayed from DLQ and fails again.
 Used to prevent infinite retry loops for poison messages.
 When this exceeds the configured max_dlq_reprocess_count, the message
 should be quarantined or logged for manual review.
      int32 dlq_reprocess_count = 10 [json_name = "dlqReprocessCount"];
      Returns:
      The dlqReprocessCount.

    • getQuarantined

      boolean getQuarantined()
       Whether this message has been quarantined (exceeded max reprocess attempts).

 Quarantined messages should not be automatically reprocessed.
 Requires manual intervention to investigate and fix the root cause.
      bool quarantined = 11 [json_name = "quarantined"];
      Returns:
      The quarantined.

    • hasQuarantinedAt

      boolean hasQuarantinedAt()
       Timestamp when the message was quarantined (if applicable).
      .google.protobuf.Timestamp quarantined_at = 12 [json_name = "quarantinedAt"];
      Returns:
      Whether the quarantinedAt field is set.

    • getQuarantinedAt

      com.google.protobuf.Timestamp getQuarantinedAt()
       Timestamp when the message was quarantined (if applicable).
      .google.protobuf.Timestamp quarantined_at = 12 [json_name = "quarantinedAt"];
      Returns:
      The quarantinedAt.

    • getQuarantinedAtOrBuilder

      com.google.protobuf.TimestampOrBuilder getQuarantinedAtOrBuilder()
       Timestamp when the message was quarantined (if applicable).
      .google.protobuf.Timestamp quarantined_at = 12 [json_name = "quarantinedAt"];