Interface PollActivityTaskQueueResponseOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
PollActivityTaskQueueResponse, PollActivityTaskQueueResponse.Builder
@Generated(value="protoc", comments="annotations:PollActivityTaskQueueResponseOrBuilder.java.pb.meta") public interface PollActivityTaskQueueResponseOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getTaskToken

      com.google.protobuf.ByteString getTaskToken()
       A unique identifier for this task
      bytes task_token = 1;
      Returns:
      The taskToken.

    • getWorkflowNamespace

      String getWorkflowNamespace()
       The namespace of the activity. If this is a workflow activity then this is the namespace of
 the workflow also. If this is a standalone activity then the name of this field is
 misleading, but retained for compatibility with workflow activities.
      string workflow_namespace = 2;
      Returns:
      The workflowNamespace.

    • getWorkflowNamespaceBytes

      com.google.protobuf.ByteString getWorkflowNamespaceBytes()
       The namespace of the activity. If this is a workflow activity then this is the namespace of
 the workflow also. If this is a standalone activity then the name of this field is
 misleading, but retained for compatibility with workflow activities.
      string workflow_namespace = 2;
      Returns:
      The bytes for workflowNamespace.

    • hasWorkflowType

      boolean hasWorkflowType()
       Type of the requesting workflow (if this is a workflow activity).
      .temporal.api.common.v1.WorkflowType workflow_type = 3;
      Returns:
      Whether the workflowType field is set.

    • getWorkflowType

      WorkflowType getWorkflowType()
       Type of the requesting workflow (if this is a workflow activity).
      .temporal.api.common.v1.WorkflowType workflow_type = 3;
      Returns:
      The workflowType.

    • getWorkflowTypeOrBuilder

      WorkflowTypeOrBuilder getWorkflowTypeOrBuilder()
       Type of the requesting workflow (if this is a workflow activity).
      .temporal.api.common.v1.WorkflowType workflow_type = 3;

    • hasWorkflowExecution

      boolean hasWorkflowExecution()
       Execution info of the requesting workflow (if this is a workflow activity)
      .temporal.api.common.v1.WorkflowExecution workflow_execution = 4;
      Returns:
      Whether the workflowExecution field is set.

    • getWorkflowExecution

      WorkflowExecution getWorkflowExecution()
       Execution info of the requesting workflow (if this is a workflow activity)
      .temporal.api.common.v1.WorkflowExecution workflow_execution = 4;
      Returns:
      The workflowExecution.

    • getWorkflowExecutionOrBuilder

      WorkflowExecutionOrBuilder getWorkflowExecutionOrBuilder()
       Execution info of the requesting workflow (if this is a workflow activity)
      .temporal.api.common.v1.WorkflowExecution workflow_execution = 4;

    • hasActivityType

      boolean hasActivityType()
      .temporal.api.common.v1.ActivityType activity_type = 5;
      Returns:
      Whether the activityType field is set.

    • getActivityType

      ActivityType getActivityType()
      .temporal.api.common.v1.ActivityType activity_type = 5;
      Returns:
      The activityType.

    • getActivityTypeOrBuilder

      ActivityTypeOrBuilder getActivityTypeOrBuilder()
      .temporal.api.common.v1.ActivityType activity_type = 5;

    • getActivityId

      String getActivityId()
       The autogenerated or user specified identifier of this activity. Can be used to complete the
 activity via `RespondActivityTaskCompletedById`. May be re-used as long as the last usage
 has resolved, but unique IDs for every activity invocation is a good idea.
 Note that only a workflow activity ID may be autogenerated.
      string activity_id = 6;
      Returns:
      The activityId.

    • getActivityIdBytes

      com.google.protobuf.ByteString getActivityIdBytes()
       The autogenerated or user specified identifier of this activity. Can be used to complete the
 activity via `RespondActivityTaskCompletedById`. May be re-used as long as the last usage
 has resolved, but unique IDs for every activity invocation is a good idea.
 Note that only a workflow activity ID may be autogenerated.
      string activity_id = 6;
      Returns:
      The bytes for activityId.

    • hasHeader

      boolean hasHeader()
       Headers specified by the scheduling workflow. Commonly used to propagate contextual info
 from the workflow to its activities. For example, tracing contexts.
      .temporal.api.common.v1.Header header = 7;
      Returns:
      Whether the header field is set.

    • getHeader

      Header getHeader()
       Headers specified by the scheduling workflow. Commonly used to propagate contextual info
 from the workflow to its activities. For example, tracing contexts.
      .temporal.api.common.v1.Header header = 7;
      Returns:
      The header.

    • getHeaderOrBuilder

      HeaderOrBuilder getHeaderOrBuilder()
       Headers specified by the scheduling workflow. Commonly used to propagate contextual info
 from the workflow to its activities. For example, tracing contexts.
      .temporal.api.common.v1.Header header = 7;

    • hasInput

      boolean hasInput()
       Arguments to the activity invocation
      .temporal.api.common.v1.Payloads input = 8;
      Returns:
      Whether the input field is set.

    • getInput

      Payloads getInput()
       Arguments to the activity invocation
      .temporal.api.common.v1.Payloads input = 8;
      Returns:
      The input.

    • getInputOrBuilder

      PayloadsOrBuilder getInputOrBuilder()
       Arguments to the activity invocation
      .temporal.api.common.v1.Payloads input = 8;

    • hasHeartbeatDetails

      boolean hasHeartbeatDetails()
       Details of the last heartbeat that was recorded for this activity as of the time this task
 was delivered.
      .temporal.api.common.v1.Payloads heartbeat_details = 9;
      Returns:
      Whether the heartbeatDetails field is set.

    • getHeartbeatDetails

      Payloads getHeartbeatDetails()
       Details of the last heartbeat that was recorded for this activity as of the time this task
 was delivered.
      .temporal.api.common.v1.Payloads heartbeat_details = 9;
      Returns:
      The heartbeatDetails.

    • getHeartbeatDetailsOrBuilder

      PayloadsOrBuilder getHeartbeatDetailsOrBuilder()
       Details of the last heartbeat that was recorded for this activity as of the time this task
 was delivered.
      .temporal.api.common.v1.Payloads heartbeat_details = 9;

    • hasScheduledTime

      boolean hasScheduledTime()
       When was this task first scheduled
      .google.protobuf.Timestamp scheduled_time = 10;
      Returns:
      Whether the scheduledTime field is set.

    • getScheduledTime

      com.google.protobuf.Timestamp getScheduledTime()
       When was this task first scheduled
      .google.protobuf.Timestamp scheduled_time = 10;
      Returns:
      The scheduledTime.

    • getScheduledTimeOrBuilder

      com.google.protobuf.TimestampOrBuilder getScheduledTimeOrBuilder()
       When was this task first scheduled
      .google.protobuf.Timestamp scheduled_time = 10;

    • hasCurrentAttemptScheduledTime

      boolean hasCurrentAttemptScheduledTime()
       When was this task attempt scheduled
      .google.protobuf.Timestamp current_attempt_scheduled_time = 11;
      Returns:
      Whether the currentAttemptScheduledTime field is set.

    • getCurrentAttemptScheduledTime

      com.google.protobuf.Timestamp getCurrentAttemptScheduledTime()
       When was this task attempt scheduled
      .google.protobuf.Timestamp current_attempt_scheduled_time = 11;
      Returns:
      The currentAttemptScheduledTime.

    • getCurrentAttemptScheduledTimeOrBuilder

      com.google.protobuf.TimestampOrBuilder getCurrentAttemptScheduledTimeOrBuilder()
       When was this task attempt scheduled
      .google.protobuf.Timestamp current_attempt_scheduled_time = 11;

    • hasStartedTime

      boolean hasStartedTime()
       When was this task started (this attempt)
      .google.protobuf.Timestamp started_time = 12;
      Returns:
      Whether the startedTime field is set.

    • getStartedTime

      com.google.protobuf.Timestamp getStartedTime()
       When was this task started (this attempt)
      .google.protobuf.Timestamp started_time = 12;
      Returns:
      The startedTime.

    • getStartedTimeOrBuilder

      com.google.protobuf.TimestampOrBuilder getStartedTimeOrBuilder()
       When was this task started (this attempt)
      .google.protobuf.Timestamp started_time = 12;

    • getAttempt

      int getAttempt()
       Starting at 1, the number of attempts to perform this activity
      int32 attempt = 13;
      Returns:
      The attempt.

    • hasScheduleToCloseTimeout

      boolean hasScheduleToCloseTimeout()
       First scheduled -> final result reported timeout

 (-- api-linter: core::0140::prepositions=disabled
     aip.dev/not-precedent: "to" is used to indicate interval. --)
      .google.protobuf.Duration schedule_to_close_timeout = 14;
      Returns:
      Whether the scheduleToCloseTimeout field is set.

    • getScheduleToCloseTimeout

      com.google.protobuf.Duration getScheduleToCloseTimeout()
       First scheduled -> final result reported timeout

 (-- api-linter: core::0140::prepositions=disabled
     aip.dev/not-precedent: "to" is used to indicate interval. --)
      .google.protobuf.Duration schedule_to_close_timeout = 14;
      Returns:
      The scheduleToCloseTimeout.

    • getScheduleToCloseTimeoutOrBuilder

      com.google.protobuf.DurationOrBuilder getScheduleToCloseTimeoutOrBuilder()
       First scheduled -> final result reported timeout

 (-- api-linter: core::0140::prepositions=disabled
     aip.dev/not-precedent: "to" is used to indicate interval. --)
      .google.protobuf.Duration schedule_to_close_timeout = 14;

    • hasStartToCloseTimeout

      boolean hasStartToCloseTimeout()
       Current attempt start -> final result reported timeout

 (-- api-linter: core::0140::prepositions=disabled
     aip.dev/not-precedent: "to" is used to indicate interval. --)
      .google.protobuf.Duration start_to_close_timeout = 15;
      Returns:
      Whether the startToCloseTimeout field is set.

    • getStartToCloseTimeout

      com.google.protobuf.Duration getStartToCloseTimeout()
       Current attempt start -> final result reported timeout

 (-- api-linter: core::0140::prepositions=disabled
     aip.dev/not-precedent: "to" is used to indicate interval. --)
      .google.protobuf.Duration start_to_close_timeout = 15;
      Returns:
      The startToCloseTimeout.

    • getStartToCloseTimeoutOrBuilder

      com.google.protobuf.DurationOrBuilder getStartToCloseTimeoutOrBuilder()
       Current attempt start -> final result reported timeout

 (-- api-linter: core::0140::prepositions=disabled
     aip.dev/not-precedent: "to" is used to indicate interval. --)
      .google.protobuf.Duration start_to_close_timeout = 15;

    • hasHeartbeatTimeout

      boolean hasHeartbeatTimeout()
       Window within which the activity must report a heartbeat, or be timed out.
      .google.protobuf.Duration heartbeat_timeout = 16;
      Returns:
      Whether the heartbeatTimeout field is set.

    • getHeartbeatTimeout

      com.google.protobuf.Duration getHeartbeatTimeout()
       Window within which the activity must report a heartbeat, or be timed out.
      .google.protobuf.Duration heartbeat_timeout = 16;
      Returns:
      The heartbeatTimeout.

    • getHeartbeatTimeoutOrBuilder

      com.google.protobuf.DurationOrBuilder getHeartbeatTimeoutOrBuilder()
       Window within which the activity must report a heartbeat, or be timed out.
      .google.protobuf.Duration heartbeat_timeout = 16;

    • hasRetryPolicy

      boolean hasRetryPolicy()
       This is the retry policy the service uses which may be different from the one provided
 (or not) during activity scheduling. The service can override the provided one if some
 values are not specified or exceed configured system limits.
      .temporal.api.common.v1.RetryPolicy retry_policy = 17;
      Returns:
      Whether the retryPolicy field is set.

    • getRetryPolicy

      RetryPolicy getRetryPolicy()
       This is the retry policy the service uses which may be different from the one provided
 (or not) during activity scheduling. The service can override the provided one if some
 values are not specified or exceed configured system limits.
      .temporal.api.common.v1.RetryPolicy retry_policy = 17;
      Returns:
      The retryPolicy.

    • getRetryPolicyOrBuilder

      RetryPolicyOrBuilder getRetryPolicyOrBuilder()
       This is the retry policy the service uses which may be different from the one provided
 (or not) during activity scheduling. The service can override the provided one if some
 values are not specified or exceed configured system limits.
      .temporal.api.common.v1.RetryPolicy retry_policy = 17;

    • hasPollerScalingDecision

      boolean hasPollerScalingDecision()
       Server-advised information the SDK may use to adjust its poller count.
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 18;
      Returns:
      Whether the pollerScalingDecision field is set.

    • getPollerScalingDecision

      PollerScalingDecision getPollerScalingDecision()
       Server-advised information the SDK may use to adjust its poller count.
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 18;
      Returns:
      The pollerScalingDecision.

    • getPollerScalingDecisionOrBuilder

      PollerScalingDecisionOrBuilder getPollerScalingDecisionOrBuilder()
       Server-advised information the SDK may use to adjust its poller count.
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 18;

    • hasPriority

      boolean hasPriority()
       Priority metadata
      .temporal.api.common.v1.Priority priority = 19;
      Returns:
      Whether the priority field is set.

    • getPriority

      Priority getPriority()
       Priority metadata
      .temporal.api.common.v1.Priority priority = 19;
      Returns:
      The priority.

    • getPriorityOrBuilder

      PriorityOrBuilder getPriorityOrBuilder()
       Priority metadata
      .temporal.api.common.v1.Priority priority = 19;

    • getActivityRunId

      String getActivityRunId()
       The run ID of the activity execution, only set for standalone activities.
      string activity_run_id = 20;
      Returns:
      The activityRunId.

    • getActivityRunIdBytes

      com.google.protobuf.ByteString getActivityRunIdBytes()
       The run ID of the activity execution, only set for standalone activities.
      string activity_run_id = 20;
      Returns:
      The bytes for activityRunId.

    • getPollerGroupInfosList

      @Deprecated List<PollerGroupInfo> getPollerGroupInfosList()
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
 queue. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];

    • getPollerGroupInfos

      @Deprecated PollerGroupInfo getPollerGroupInfos(int index)
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
 queue. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];

    • getPollerGroupInfosCount

      @Deprecated int getPollerGroupInfosCount()
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
 queue. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];

    • getPollerGroupInfosOrBuilderList

      @Deprecated List<? extends PollerGroupInfoOrBuilder> getPollerGroupInfosOrBuilderList()
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
 queue. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];

    • getPollerGroupInfosOrBuilder

      @Deprecated PollerGroupInfoOrBuilder getPollerGroupInfosOrBuilder(int index)
      Deprecated.
       The weighted list of poller groups IDs that client should use for future polls to this task
 queue. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      repeated .temporal.api.taskqueue.v1.PollerGroupInfo poller_group_infos = 21 [deprecated = true];

    • hasPollerGroupsInfo

      boolean hasPollerGroupsInfo()
       The weighted, versioned list of poller groups IDs that client should use for future polls to
 this task queue. Client should ignore this if it has already applied a snapshot with a
 version greater than or equal to `poller_groups_info.version`. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      .temporal.api.taskqueue.v1.PollerGroupsInfo poller_groups_info = 22;
      Returns:
      Whether the pollerGroupsInfo field is set.

    • getPollerGroupsInfo

      PollerGroupsInfo getPollerGroupsInfo()
       The weighted, versioned list of poller groups IDs that client should use for future polls to
 this task queue. Client should ignore this if it has already applied a snapshot with a
 version greater than or equal to `poller_groups_info.version`. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      .temporal.api.taskqueue.v1.PollerGroupsInfo poller_groups_info = 22;
      Returns:
      The pollerGroupsInfo.

    • getPollerGroupsInfoOrBuilder

      PollerGroupsInfoOrBuilder getPollerGroupsInfoOrBuilder()
       The weighted, versioned list of poller groups IDs that client should use for future polls to
 this task queue. Client should ignore this if it has already applied a snapshot with a
 version greater than or equal to `poller_groups_info.version`. Client is expected to:
   1. Maintain minimum number of pollers no less than the number of groups.
   2. Try to assign the next poll to a group without any pending polls,
   3. If every group has some pending polls, assign the next poll to a group randomly
     according to the weights.
      .temporal.api.taskqueue.v1.PollerGroupsInfo poller_groups_info = 22;