Package ai.pipestream.data.v1

Class PipeStream

java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
ai.pipestream.data.v1.PipeStream
All Implemented Interfaces:
PipeStreamOrBuilder, com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable
@Generated public final class PipeStream extends com.google.protobuf.GeneratedMessage implements PipeStreamOrBuilder
 TCP-like packet header for node-to-node document processing.

 Contains the document payload, routing information, processing history,
 and configuration for the current processing step.
Protobuf type ai.pipestream.data.v1.PipeStream
See Also:

  • Field Details

    • STREAM_ID_FIELD_NUMBER

      public static final int STREAM_ID_FIELD_NUMBER
      See Also:

    • METADATA_FIELD_NUMBER

      public static final int METADATA_FIELD_NUMBER
      See Also:

    • DOCUMENT_FIELD_NUMBER

      public static final int DOCUMENT_FIELD_NUMBER
      See Also:

    • DOCUMENT_REF_FIELD_NUMBER

      public static final int DOCUMENT_REF_FIELD_NUMBER
      See Also:

    • CLUSTER_ID_FIELD_NUMBER

      public static final int CLUSTER_ID_FIELD_NUMBER
      See Also:

    • CURRENT_NODE_ID_FIELD_NUMBER

      public static final int CURRENT_NODE_ID_FIELD_NUMBER
      See Also:

    • HOP_COUNT_FIELD_NUMBER

      public static final int HOP_COUNT_FIELD_NUMBER
      See Also:

    • PROCESSING_PATH_FIELD_NUMBER

      public static final int PROCESSING_PATH_FIELD_NUMBER
      See Also:

    • NODE_PROCESSING_CONFIG_FIELD_NUMBER

      public static final int NODE_PROCESSING_CONFIG_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

    • getDocumentPayloadCase

      public PipeStream.DocumentPayloadCase getDocumentPayloadCase()
      Specified by:
      getDocumentPayloadCase in interface PipeStreamOrBuilder

    • getStreamId

      public String getStreamId()
       Unique identifier for this processing stream.
      string stream_id = 1 [json_name = "streamId"];
      Specified by:
      getStreamId in interface PipeStreamOrBuilder
      Returns:
      The streamId.

    • getStreamIdBytes

      public com.google.protobuf.ByteString getStreamIdBytes()
       Unique identifier for this processing stream.
      string stream_id = 1 [json_name = "streamId"];
      Specified by:
      getStreamIdBytes in interface PipeStreamOrBuilder
      Returns:
      The bytes for streamId.

    • hasMetadata

      public boolean hasMetadata()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];
      Specified by:
      hasMetadata in interface PipeStreamOrBuilder
      Returns:
      Whether the metadata field is set.

    • getMetadata

      public StreamMetadata getMetadata()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];
      Specified by:
      getMetadata in interface PipeStreamOrBuilder
      Returns:
      The metadata.

    • getMetadataOrBuilder

      public StreamMetadataOrBuilder getMetadataOrBuilder()
       Stream metadata including history and tracing.
      .ai.pipestream.data.v1.StreamMetadata metadata = 2 [json_name = "metadata"];
      Specified by:
      getMetadataOrBuilder in interface PipeStreamOrBuilder

    • hasDocument

      public boolean hasDocument()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];
      Specified by:
      hasDocument in interface PipeStreamOrBuilder
      Returns:
      Whether the document field is set.

    • getDocument

      public PipeDoc getDocument()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];
      Specified by:
      getDocument in interface PipeStreamOrBuilder
      Returns:
      The document.

    • getDocumentOrBuilder

      public PipeDocOrBuilder getDocumentOrBuilder()
       Inline document (typically for gRPC direct path or small documents).
      .ai.pipestream.data.v1.PipeDoc document = 3 [json_name = "document"];
      Specified by:
      getDocumentOrBuilder in interface PipeStreamOrBuilder

    • hasDocumentRef

      public boolean hasDocumentRef()
       Reference to document stored in repository (typically for Kafka path or large documents).
      .ai.pipestream.data.v1.DocumentReference document_ref = 9 [json_name = "documentRef"];
      Specified by:
      hasDocumentRef in interface PipeStreamOrBuilder
      Returns:
      Whether the documentRef field is set.

    • getDocumentRef

      public DocumentReference getDocumentRef()
       Reference to document stored in repository (typically for Kafka path or large documents).
      .ai.pipestream.data.v1.DocumentReference document_ref = 9 [json_name = "documentRef"];
      Specified by:
      getDocumentRef in interface PipeStreamOrBuilder
      Returns:
      The documentRef.

    • getDocumentRefOrBuilder

      public DocumentReferenceOrBuilder getDocumentRefOrBuilder()
       Reference to document stored in repository (typically for Kafka path or large documents).
      .ai.pipestream.data.v1.DocumentReference document_ref = 9 [json_name = "documentRef"];
      Specified by:
      getDocumentRefOrBuilder in interface PipeStreamOrBuilder

    • getClusterId

      public String getClusterId()
       Cluster where processing is occurring.
      string cluster_id = 4 [json_name = "clusterId"];
      Specified by:
      getClusterId in interface PipeStreamOrBuilder
      Returns:
      The clusterId.

    • getClusterIdBytes

      public com.google.protobuf.ByteString getClusterIdBytes()
       Cluster where processing is occurring.
      string cluster_id = 4 [json_name = "clusterId"];
      Specified by:
      getClusterIdBytes in interface PipeStreamOrBuilder
      Returns:
      The bytes for clusterId.

    • getCurrentNodeId

      public String getCurrentNodeId()
       Current node processing this stream.
      string current_node_id = 5 [json_name = "currentNodeId"];
      Specified by:
      getCurrentNodeId in interface PipeStreamOrBuilder
      Returns:
      The currentNodeId.

    • getCurrentNodeIdBytes

      public com.google.protobuf.ByteString getCurrentNodeIdBytes()
       Current node processing this stream.
      string current_node_id = 5 [json_name = "currentNodeId"];
      Specified by:
      getCurrentNodeIdBytes in interface PipeStreamOrBuilder
      Returns:
      The bytes for currentNodeId.

    • getHopCount

      public long getHopCount()
       Number of processing hops taken.
      int64 hop_count = 6 [json_name = "hopCount"];
      Specified by:
      getHopCount in interface PipeStreamOrBuilder
      Returns:
      The hopCount.

    • getProcessingPathList

      public com.google.protobuf.ProtocolStringList getProcessingPathList()
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPathList in interface PipeStreamOrBuilder
      Returns:
      A list containing the processingPath.

    • getProcessingPathCount

      public int getProcessingPathCount()
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPathCount in interface PipeStreamOrBuilder
      Returns:
      The count of processingPath.

    • getProcessingPath

      public String getProcessingPath(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPath in interface PipeStreamOrBuilder
      Parameters:
      index - The index of the element to return.
      Returns:
      The processingPath at the given index.

    • getProcessingPathBytes

      public com.google.protobuf.ByteString getProcessingPathBytes(int index)
       Ordered list of node IDs traversed during processing.
      repeated string processing_path = 7 [json_name = "processingPath"];
      Specified by:
      getProcessingPathBytes in interface PipeStreamOrBuilder
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the processingPath at the given index.

    • hasNodeProcessingConfig

      public boolean hasNodeProcessingConfig()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];
      Specified by:
      hasNodeProcessingConfig in interface PipeStreamOrBuilder
      Returns:
      Whether the nodeProcessingConfig field is set.

    • getNodeProcessingConfig

      public NodeProcessingConfig getNodeProcessingConfig()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];
      Specified by:
      getNodeProcessingConfig in interface PipeStreamOrBuilder
      Returns:
      The nodeProcessingConfig.

    • getNodeProcessingConfigOrBuilder

      public NodeProcessingConfigOrBuilder getNodeProcessingConfigOrBuilder()
       Configuration for the current node's processing step.
      .ai.pipestream.data.v1.NodeProcessingConfig node_processing_config = 8 [json_name = "nodeProcessingConfig"];
      Specified by:
      getNodeProcessingConfigOrBuilder in interface PipeStreamOrBuilder

    • 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 PipeStream parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • parseFrom

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

    • parseFrom

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

    • parseFrom

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

    • parseFrom

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

    • parseFrom

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

    • parseFrom

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

    • parseFrom

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

    • parseDelimitedFrom

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

    • parseDelimitedFrom

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

    • parseFrom

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

    • parseFrom

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

    • newBuilderForType

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

    • newBuilder

      public static PipeStream.Builder newBuilder()

    • newBuilder

      public static PipeStream.Builder newBuilder(PipeStream prototype)

    • toBuilder

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

    • newBuilderForType

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

    • getDefaultInstance

      public static PipeStream getDefaultInstance()

    • parser

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

    • getParserForType

      public com.google.protobuf.Parser<PipeStream> 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 PipeStream getDefaultInstanceForType()
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
      Specified by:
      getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder