Package ai.pipestream.data.v1

Class DlqMessage

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
ai.pipestream.data.v1.DlqMessage
All Implemented Interfaces:
DlqMessageOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable
@Generated public final class DlqMessage extends com.google.protobuf.GeneratedMessage implements DlqMessageOrBuilder
 Dead Letter Queue message for failed processing attempts.

 Published by Sidecar when Engine returns error after retry exhaustion.
 Contains the failed stream, error context, and Kafka offset information for replay.
Protobuf type ai.pipestream.data.v1.DlqMessage
See Also:

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static final class 
    DlqMessage.Builder
    Dead Letter Queue message for failed processing attempts.

    Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage

    com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T>, com.google.protobuf.GeneratedMessage.UnusedPrivateParameter

    Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessage

    com.google.protobuf.AbstractMessage.BuilderParent

    Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite

    com.google.protobuf.AbstractMessageLite.InternalOneOfEnum

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final int
    DLQ_REPROCESS_COUNT_FIELD_NUMBER
     
    static final int
    ERROR_MESSAGE_FIELD_NUMBER
     
    static final int
    ERROR_TYPE_FIELD_NUMBER
     
    static final int
    FAILED_AT_FIELD_NUMBER
     
    static final int
    FAILED_NODE_ID_FIELD_NUMBER
     
    static final int
    ORIGINAL_OFFSET_FIELD_NUMBER
     
    static final int
    ORIGINAL_PARTITION_FIELD_NUMBER
     
    static final int
    ORIGINAL_TOPIC_FIELD_NUMBER
     
    static final int
    QUARANTINED_AT_FIELD_NUMBER
     
    static final int
    QUARANTINED_FIELD_NUMBER
     
    static final int
    RETRY_COUNT_FIELD_NUMBER
     
    static final int
    STREAM_FIELD_NUMBER
     

    Fields inherited from class com.google.protobuf.GeneratedMessage

    alwaysUseFieldBuilders, loggedPre22TypeNames, unknownFields

    Fields inherited from class com.google.protobuf.AbstractMessage

    memoizedSize

    Fields inherited from class com.google.protobuf.AbstractMessageLite

    memoizedHashCode

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    equals(Object obj)
     
    static DlqMessage
    getDefaultInstance()
     
    DlqMessage
    getDefaultInstanceForType()
     
    static final com.google.protobuf.Descriptors.Descriptor
    getDescriptor()
     
    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.
    com.google.protobuf.Parser<DlqMessage>
    getParserForType()
     
    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.
    int
    getSerializedSize()
     
    PipeStream
    getStream()
    The failed stream (contains document reference).
    PipeStreamOrBuilder
    getStreamOrBuilder()
    The failed stream (contains document reference).
    boolean
    hasFailedAt()
    Timestamp when the failure occurred.
    int
    hashCode()
     
    boolean
    hasQuarantinedAt()
    Timestamp when the message was quarantined (if applicable).
    boolean
    hasStream()
    The failed stream (contains document reference).
    protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
    internalGetFieldAccessorTable()
     
    final boolean
    isInitialized()
     
    static DlqMessage.Builder
    newBuilder()
     
    static DlqMessage.Builder
    newBuilder(DlqMessage prototype)
     
    DlqMessage.Builder
    newBuilderForType()
     
    protected DlqMessage.Builder
    newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
     
    static DlqMessage
    parseDelimitedFrom(InputStream input)
     
    static DlqMessage
    parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
     
    static DlqMessage
    parseFrom(byte[] data)
     
    static DlqMessage
    parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
     
    static DlqMessage
    parseFrom(com.google.protobuf.ByteString data)
     
    static DlqMessage
    parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
     
    static DlqMessage
    parseFrom(com.google.protobuf.CodedInputStream input)
     
    static DlqMessage
    parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
     
    static DlqMessage
    parseFrom(InputStream input)
     
    static DlqMessage
    parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
     
    static DlqMessage
    parseFrom(ByteBuffer data)
     
    static DlqMessage
    parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
     
    static com.google.protobuf.Parser<DlqMessage>
    parser()
     
    DlqMessage.Builder
    toBuilder()
     
    void
    writeTo(com.google.protobuf.CodedOutputStream output)
     

    Methods inherited from class com.google.protobuf.GeneratedMessage

    canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, newFileScopedGeneratedExtension, newInstance, newMessageScopedGeneratedExtension, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag

    Methods inherited from class com.google.protobuf.AbstractMessage

    findInitializationErrors, getInitializationErrorString, hashFields, toString

    Methods inherited from class com.google.protobuf.AbstractMessageLite

    addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface com.google.protobuf.MessageLite

    toByteArray, toByteString, writeDelimitedTo, writeTo

    Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

  • Field Details

    • STREAM_FIELD_NUMBER

      public static final int STREAM_FIELD_NUMBER
      See Also:

    • ERROR_TYPE_FIELD_NUMBER

      public static final int ERROR_TYPE_FIELD_NUMBER
      See Also:

    • ERROR_MESSAGE_FIELD_NUMBER

      public static final int ERROR_MESSAGE_FIELD_NUMBER
      See Also:

    • FAILED_AT_FIELD_NUMBER

      public static final int FAILED_AT_FIELD_NUMBER
      See Also:

    • RETRY_COUNT_FIELD_NUMBER

      public static final int RETRY_COUNT_FIELD_NUMBER
      See Also:

    • FAILED_NODE_ID_FIELD_NUMBER

      public static final int FAILED_NODE_ID_FIELD_NUMBER
      See Also:

    • ORIGINAL_TOPIC_FIELD_NUMBER

      public static final int ORIGINAL_TOPIC_FIELD_NUMBER
      See Also:

    • ORIGINAL_PARTITION_FIELD_NUMBER

      public static final int ORIGINAL_PARTITION_FIELD_NUMBER
      See Also:

    • ORIGINAL_OFFSET_FIELD_NUMBER

      public static final int ORIGINAL_OFFSET_FIELD_NUMBER
      See Also:

    • DLQ_REPROCESS_COUNT_FIELD_NUMBER

      public static final int DLQ_REPROCESS_COUNT_FIELD_NUMBER
      See Also:

    • QUARANTINED_FIELD_NUMBER

      public static final int QUARANTINED_FIELD_NUMBER
      See Also:

    • QUARANTINED_AT_FIELD_NUMBER

      public static final int QUARANTINED_AT_FIELD_NUMBER
      See Also:

  • Method Details

    • getDescriptor

      public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

    • internalGetFieldAccessorTable

      protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
      Specified by:
      internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

    • hasStream

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

    • getStream

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

    • getStreamOrBuilder

      public PipeStreamOrBuilder getStreamOrBuilder()
       The failed stream (contains document reference).
      .ai.pipestream.data.v1.PipeStream stream = 1 [json_name = "stream"];
      Specified by:
      getStreamOrBuilder in interface DlqMessageOrBuilder

    • getErrorType

      public String getErrorType()
       Error classification.

 Examples: "TIMEOUT", "CONNECTION_REFUSED", "UNAVAILABLE", "MODULE_UNAVAILABLE"
      string error_type = 2 [json_name = "errorType"];
      Specified by:
      getErrorType in interface DlqMessageOrBuilder
      Returns:
      The errorType.

    • getErrorTypeBytes

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

 Examples: "TIMEOUT", "CONNECTION_REFUSED", "UNAVAILABLE", "MODULE_UNAVAILABLE"
      string error_type = 2 [json_name = "errorType"];
      Specified by:
      getErrorTypeBytes in interface DlqMessageOrBuilder
      Returns:
      The bytes for errorType.

    • getErrorMessage

      public String getErrorMessage()
       Human-readable error message.
      string error_message = 3 [json_name = "errorMessage"];
      Specified by:
      getErrorMessage in interface DlqMessageOrBuilder
      Returns:
      The errorMessage.

    • getErrorMessageBytes

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

    • hasFailedAt

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

    • getFailedAt

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

    • getFailedAtOrBuilder

      public com.google.protobuf.TimestampOrBuilder getFailedAtOrBuilder()
       Timestamp when the failure occurred.
      .google.protobuf.Timestamp failed_at = 4 [json_name = "failedAt"];
      Specified by:
      getFailedAtOrBuilder in interface DlqMessageOrBuilder

    • getRetryCount

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

    • getFailedNodeId

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

    • getFailedNodeIdBytes

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

    • getOriginalTopic

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

    • getOriginalTopicBytes

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

    • getOriginalPartition

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

    • getOriginalOffset

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

    • getDlqReprocessCount

      public 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"];
      Specified by:
      getDlqReprocessCount in interface DlqMessageOrBuilder
      Returns:
      The dlqReprocessCount.

    • getQuarantined

      public 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"];
      Specified by:
      getQuarantined in interface DlqMessageOrBuilder
      Returns:
      The quarantined.

    • hasQuarantinedAt

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

    • getQuarantinedAt

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

    • getQuarantinedAtOrBuilder

      public com.google.protobuf.TimestampOrBuilder getQuarantinedAtOrBuilder()
       Timestamp when the message was quarantined (if applicable).
      .google.protobuf.Timestamp quarantined_at = 12 [json_name = "quarantinedAt"];
      Specified by:
      getQuarantinedAtOrBuilder in interface DlqMessageOrBuilder

    • isInitialized

      public final boolean isInitialized()
      Specified by:
      isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
      Overrides:
      isInitialized in class com.google.protobuf.GeneratedMessage

    • writeTo

      public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
      Specified by:
      writeTo in interface com.google.protobuf.MessageLite
      Overrides:
      writeTo in class com.google.protobuf.GeneratedMessage
      Throws:
      IOException

    • getSerializedSize

      public int getSerializedSize()
      Specified by:
      getSerializedSize in interface com.google.protobuf.MessageLite
      Overrides:
      getSerializedSize in class com.google.protobuf.GeneratedMessage

    • equals

      public boolean equals(Object obj)
      Specified by:
      equals in interface com.google.protobuf.Message
      Overrides:
      equals in class com.google.protobuf.AbstractMessage

    • hashCode

      public int hashCode()
      Specified by:
      hashCode in interface com.google.protobuf.Message
      Overrides:
      hashCode in class com.google.protobuf.AbstractMessage

    • parseFrom

      public static DlqMessage parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static DlqMessage parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static DlqMessage parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static DlqMessage parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static DlqMessage parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static DlqMessage parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

      public static DlqMessage parseFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static DlqMessage parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static DlqMessage parseDelimitedFrom(InputStream input) throws IOException
      Throws:
      IOException

    • parseDelimitedFrom

      public static DlqMessage parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • parseFrom

      public static DlqMessage parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
      Throws:
      IOException

    • parseFrom

      public static DlqMessage parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
      Throws:
      IOException

    • newBuilderForType

      public DlqMessage.Builder newBuilderForType()
      Specified by:
      newBuilderForType in interface com.google.protobuf.Message
      Specified by:
      newBuilderForType in interface com.google.protobuf.MessageLite

    • newBuilder

      public static DlqMessage.Builder newBuilder()

    • newBuilder

      public static DlqMessage.Builder newBuilder(DlqMessage prototype)

    • toBuilder

      public DlqMessage.Builder toBuilder()
      Specified by:
      toBuilder in interface com.google.protobuf.Message
      Specified by:
      toBuilder in interface com.google.protobuf.MessageLite

    • newBuilderForType

      protected DlqMessage.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
      Overrides:
      newBuilderForType in class com.google.protobuf.AbstractMessage

    • getDefaultInstance

      public static DlqMessage getDefaultInstance()

    • parser

      public static com.google.protobuf.Parser<DlqMessage> parser()

    • getParserForType

      public com.google.protobuf.Parser<DlqMessage> getParserForType()
      Specified by:
      getParserForType in interface com.google.protobuf.Message
      Specified by:
      getParserForType in interface com.google.protobuf.MessageLite
      Overrides:
      getParserForType in class com.google.protobuf.GeneratedMessage

    • getDefaultInstanceForType

      public DlqMessage getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder