Package ai.pipestream.data.v1

Interface StepExecutionRecordOrBuilder

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

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getAttemptedTargetStepName()
    Target step name if status is "DISPATCH_FAILURE".
    com.google.protobuf.ByteString
    getAttemptedTargetStepNameBytes()
    Target step name if status is "DISPATCH_FAILURE".
    com.google.protobuf.Timestamp
    getEndTime()
    Timestamp when step processing ended.
    com.google.protobuf.TimestampOrBuilder
    getEndTimeOrBuilder()
    Timestamp when step processing ended.
    ErrorData
    getErrorInfo()
    Error information if status is "FAILURE".
    ErrorDataOrBuilder
    getErrorInfoOrBuilder()
    Error information if status is "FAILURE".
    long
    getHopNumber()
    Sequential hop number for this step in the processing stream.
    String
    getProcessorLogs(int index)
    Logs from the processor for this step's execution.
    com.google.protobuf.ByteString
    getProcessorLogsBytes(int index)
    Logs from the processor for this step's execution.
    int
    getProcessorLogsCount()
    Logs from the processor for this step's execution.
    List<String>
    getProcessorLogsList()
    Logs from the processor for this step's execution.
    String
    getServiceInstanceId()
    Identifier of the service instance/pod that executed the step.
    com.google.protobuf.ByteString
    getServiceInstanceIdBytes()
    Identifier of the service instance/pod that executed the step.
    com.google.protobuf.Timestamp
    getStartTime()
    Timestamp when step processing began.
    com.google.protobuf.TimestampOrBuilder
    getStartTimeOrBuilder()
    Timestamp when step processing began.
    String
    getStatus()
    Execution outcome status.
    com.google.protobuf.ByteString
    getStatusBytes()
    Execution outcome status.
    String
    getStepName()
    Name of the pipeline step configuration that was executed.
    com.google.protobuf.ByteString
    getStepNameBytes()
    Name of the pipeline step configuration that was executed.
    boolean
    hasAttemptedTargetStepName()
    Target step name if status is "DISPATCH_FAILURE".
    boolean
    hasEndTime()
    Timestamp when step processing ended.
    boolean
    hasErrorInfo()
    Error information if status is "FAILURE".
    boolean
    hasServiceInstanceId()
    Identifier of the service instance/pod that executed the step.
    boolean
    hasStartTime()
    Timestamp when step processing began.

    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

    • getHopNumber

      long getHopNumber()
       Sequential hop number for this step in the processing stream.
      int64 hop_number = 1 [json_name = "hopNumber"];
      Returns:
      The hopNumber.

    • getStepName

      String getStepName()
       Name of the pipeline step configuration that was executed.
      string step_name = 2 [json_name = "stepName"];
      Returns:
      The stepName.

    • getStepNameBytes

      com.google.protobuf.ByteString getStepNameBytes()
       Name of the pipeline step configuration that was executed.
      string step_name = 2 [json_name = "stepName"];
      Returns:
      The bytes for stepName.

    • hasServiceInstanceId

      boolean hasServiceInstanceId()
       Identifier of the service instance/pod that executed the step.
      optional string service_instance_id = 3 [json_name = "serviceInstanceId"];
      Returns:
      Whether the serviceInstanceId field is set.

    • getServiceInstanceId

      String getServiceInstanceId()
       Identifier of the service instance/pod that executed the step.
      optional string service_instance_id = 3 [json_name = "serviceInstanceId"];
      Returns:
      The serviceInstanceId.

    • getServiceInstanceIdBytes

      com.google.protobuf.ByteString getServiceInstanceIdBytes()
       Identifier of the service instance/pod that executed the step.
      optional string service_instance_id = 3 [json_name = "serviceInstanceId"];
      Returns:
      The bytes for serviceInstanceId.

    • hasStartTime

      boolean hasStartTime()
       Timestamp when step processing began.
      .google.protobuf.Timestamp start_time = 4 [json_name = "startTime"];
      Returns:
      Whether the startTime field is set.

    • getStartTime

      com.google.protobuf.Timestamp getStartTime()
       Timestamp when step processing began.
      .google.protobuf.Timestamp start_time = 4 [json_name = "startTime"];
      Returns:
      The startTime.

    • getStartTimeOrBuilder

      com.google.protobuf.TimestampOrBuilder getStartTimeOrBuilder()
       Timestamp when step processing began.
      .google.protobuf.Timestamp start_time = 4 [json_name = "startTime"];

    • hasEndTime

      boolean hasEndTime()
       Timestamp when step processing ended.
      .google.protobuf.Timestamp end_time = 5 [json_name = "endTime"];
      Returns:
      Whether the endTime field is set.

    • getEndTime

      com.google.protobuf.Timestamp getEndTime()
       Timestamp when step processing ended.
      .google.protobuf.Timestamp end_time = 5 [json_name = "endTime"];
      Returns:
      The endTime.

    • getEndTimeOrBuilder

      com.google.protobuf.TimestampOrBuilder getEndTimeOrBuilder()
       Timestamp when step processing ended.
      .google.protobuf.Timestamp end_time = 5 [json_name = "endTime"];

    • getStatus

      String getStatus()
       Execution outcome status.

 Expected values: "SUCCESS", "FAILURE", "SKIPPED", "RETRYING", "DISPATCH_FAILURE"
      string status = 6 [json_name = "status"];
      Returns:
      The status.

    • getStatusBytes

      com.google.protobuf.ByteString getStatusBytes()
       Execution outcome status.

 Expected values: "SUCCESS", "FAILURE", "SKIPPED", "RETRYING", "DISPATCH_FAILURE"
      string status = 6 [json_name = "status"];
      Returns:
      The bytes for status.

    • getProcessorLogsList

      List<String> getProcessorLogsList()
       Logs from the processor for this step's execution.
      repeated string processor_logs = 7 [json_name = "processorLogs"];
      Returns:
      A list containing the processorLogs.

    • getProcessorLogsCount

      int getProcessorLogsCount()
       Logs from the processor for this step's execution.
      repeated string processor_logs = 7 [json_name = "processorLogs"];
      Returns:
      The count of processorLogs.

    • getProcessorLogs

      String getProcessorLogs(int index)
       Logs from the processor for this step's execution.
      repeated string processor_logs = 7 [json_name = "processorLogs"];
      Parameters:
      index - The index of the element to return.
      Returns:
      The processorLogs at the given index.

    • getProcessorLogsBytes

      com.google.protobuf.ByteString getProcessorLogsBytes(int index)
       Logs from the processor for this step's execution.
      repeated string processor_logs = 7 [json_name = "processorLogs"];
      Parameters:
      index - The index of the value to return.
      Returns:
      The bytes of the processorLogs at the given index.

    • hasErrorInfo

      boolean hasErrorInfo()
       Error information if status is "FAILURE".
      optional .ai.pipestream.data.v1.ErrorData error_info = 8 [json_name = "errorInfo"];
      Returns:
      Whether the errorInfo field is set.

    • getErrorInfo

      ErrorData getErrorInfo()
       Error information if status is "FAILURE".
      optional .ai.pipestream.data.v1.ErrorData error_info = 8 [json_name = "errorInfo"];
      Returns:
      The errorInfo.

    • getErrorInfoOrBuilder

      ErrorDataOrBuilder getErrorInfoOrBuilder()
       Error information if status is "FAILURE".
      optional .ai.pipestream.data.v1.ErrorData error_info = 8 [json_name = "errorInfo"];

    • hasAttemptedTargetStepName

      boolean hasAttemptedTargetStepName()
       Target step name if status is "DISPATCH_FAILURE".
      optional string attempted_target_step_name = 9 [json_name = "attemptedTargetStepName"];
      Returns:
      Whether the attemptedTargetStepName field is set.

    • getAttemptedTargetStepName

      String getAttemptedTargetStepName()
       Target step name if status is "DISPATCH_FAILURE".
      optional string attempted_target_step_name = 9 [json_name = "attemptedTargetStepName"];
      Returns:
      The attemptedTargetStepName.

    • getAttemptedTargetStepNameBytes

      com.google.protobuf.ByteString getAttemptedTargetStepNameBytes()
       Target step name if status is "DISPATCH_FAILURE".
      optional string attempted_target_step_name = 9 [json_name = "attemptedTargetStepName"];
      Returns:
      The bytes for attemptedTargetStepName.