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"];

    • getDatasourceId

      String getDatasourceId()
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Returns:
      The datasourceId.

    • getDatasourceIdBytes

      com.google.protobuf.ByteString getDatasourceIdBytes()
       DataSource identifier for tracking document origin.

 Deterministically derived from account_id and connector type.
 Used to route documents to the correct pipeline graph entry point.
      string datasource_id = 9 [json_name = "datasourceId"];
      Returns:
      The bytes for datasourceId.

    • getAccountId

      String getAccountId()
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Returns:
      The accountId.

    • getAccountIdBytes

      com.google.protobuf.ByteString getAccountIdBytes()
       Account identifier for ownership and access control.

 Links this stream to a specific tenant/customer account.
      string account_id = 10 [json_name = "accountId"];
      Returns:
      The bytes for accountId.

    • getEntryNodeId

      String getEntryNodeId()
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Returns:
      The entryNodeId.

    • getEntryNodeIdBytes

      com.google.protobuf.ByteString getEntryNodeIdBytes()
       Entry node identifier where this stream entered the pipeline.

 Useful for tracking which connector/datasource initiated processing
 and for routing decisions in multi-entry-point graphs.
      string entry_node_id = 11 [json_name = "entryNodeId"];
      Returns:
      The bytes for entryNodeId.

    • hasIngestionConfig

      boolean hasIngestionConfig()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];
      Returns:
      Whether the ingestionConfig field is set.

    • getIngestionConfig

      IngestionConfig getIngestionConfig()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];
      Returns:
      The ingestionConfig.

    • getIngestionConfigOrBuilder

      IngestionConfigOrBuilder getIngestionConfigOrBuilder()
       Ingestion configuration from connector-intake-service.

 Contains the resolved 2-tier configuration (Tier 1 + Tier 2 merged)
 for hydration, routing, and custom connector settings.
 Only present for streams that entered via intake connectors.
      optional .ai.pipestream.data.v1.IngestionConfig ingestion_config = 12 [json_name = "ingestionConfig"];