Package ai.pipestream.data.v1

Interface StreamMetadataOrBuilder

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

  • Method Details

    • getSourceId

      String getSourceId()
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Returns:
      The sourceId.

    • getSourceIdBytes

      com.google.protobuf.ByteString getSourceIdBytes()
       Source identifier for validation and tracking.
      string source_id = 2 [json_name = "sourceId"];
      Returns:
      The bytes for sourceId.

    • hasCreatedAt

      boolean hasCreatedAt()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];
      Returns:
      Whether the createdAt field is set.

    • getCreatedAt

      com.google.protobuf.Timestamp getCreatedAt()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];
      Returns:
      The createdAt.

    • getCreatedAtOrBuilder

      com.google.protobuf.TimestampOrBuilder getCreatedAtOrBuilder()
       Timestamp when the stream was created.
      .google.protobuf.Timestamp created_at = 3 [json_name = "createdAt"];

    • hasLastProcessedAt

      boolean hasLastProcessedAt()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];
      Returns:
      Whether the lastProcessedAt field is set.

    • getLastProcessedAt

      com.google.protobuf.Timestamp getLastProcessedAt()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];
      Returns:
      The lastProcessedAt.

    • getLastProcessedAtOrBuilder

      com.google.protobuf.TimestampOrBuilder getLastProcessedAtOrBuilder()
       Timestamp when the stream was last processed.
      .google.protobuf.Timestamp last_processed_at = 4 [json_name = "lastProcessedAt"];

    • getTraceId

      String getTraceId()
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Returns:
      The traceId.

    • getTraceIdBytes

      com.google.protobuf.ByteString getTraceIdBytes()
       Distributed tracing identifier.
      string trace_id = 5 [json_name = "traceId"];
      Returns:
      The bytes for traceId.

    • getHistoryList

      List<StepExecutionRecord> getHistoryList()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistory

      StepExecutionRecord getHistory(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistoryCount

      int getHistoryCount()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistoryOrBuilderList

      List<? extends StepExecutionRecordOrBuilder> getHistoryOrBuilderList()
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • getHistoryOrBuilder

      StepExecutionRecordOrBuilder getHistoryOrBuilder(int index)
       Complete execution history of all processing steps.
      repeated .ai.pipestream.data.v1.StepExecutionRecord history = 6 [json_name = "history"];

    • hasStreamError

      boolean hasStreamError()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];
      Returns:
      Whether the streamError field is set.

    • getStreamError

      ErrorData getStreamError()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];
      Returns:
      The streamError.

    • getStreamErrorOrBuilder

      ErrorDataOrBuilder getStreamErrorOrBuilder()
       Critical stream-level errors if any occurred.
      optional .ai.pipestream.data.v1.ErrorData stream_error = 7 [json_name = "streamError"];

    • getContextParamsCount

      int getContextParamsCount()
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • containsContextParams

      boolean containsContextParams(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • getContextParams

      @Deprecated Map<String,String> getContextParams()
      Deprecated.
      Use getContextParamsMap() instead.

    • getContextParamsMap

      Map<String,String> getContextParamsMap()
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • getContextParamsOrDefault

      String getContextParamsOrDefault(String key, String defaultValue)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];

    • getContextParamsOrThrow

      String getContextParamsOrThrow(String key)
       Stream-level context parameters for processing.
      map<string, string> context_params = 8 [json_name = "contextParams"];