Interface PollNexusTaskQueueResponseOrBuilder

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

  • Method Details

    • getTaskToken

      com.google.protobuf.ByteString getTaskToken()
       An opaque unique identifier for this task for correlating a completion request the embedded request.
      bytes task_token = 1;
      Returns:
      The taskToken.

    • hasRequest

      boolean hasRequest()
       Embedded request as translated from the incoming frontend request.
      .temporal.api.nexus.v1.Request request = 2;
      Returns:
      Whether the request field is set.

    • getRequest

      Request getRequest()
       Embedded request as translated from the incoming frontend request.
      .temporal.api.nexus.v1.Request request = 2;
      Returns:
      The request.

    • getRequestOrBuilder

      RequestOrBuilder getRequestOrBuilder()
       Embedded request as translated from the incoming frontend request.
      .temporal.api.nexus.v1.Request request = 2;

    • hasPollerScalingDecision

      boolean hasPollerScalingDecision()
       Server-advised information the SDK may use to adjust its poller count.
      .temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 3;
      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 = 3;
      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 = 3;

    • getPollerGroupId

      String getPollerGroupId()
       This poller group ID identifies the owner of the nexus task awaiting for synchronous
 response.
 Corresponding `RespondNexusTaskCompleted` and `RespondNexusTaskFailed` calls should pass this
 value for proper response routing.
      string poller_group_id = 4;
      Returns:
      The pollerGroupId.

    • getPollerGroupIdBytes

      com.google.protobuf.ByteString getPollerGroupIdBytes()
       This poller group ID identifies the owner of the nexus task awaiting for synchronous
 response.
 Corresponding `RespondNexusTaskCompleted` and `RespondNexusTaskFailed` calls should pass this
 value for proper response routing.
      string poller_group_id = 4;
      Returns:
      The bytes for pollerGroupId.

    • 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 = 5 [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 = 5 [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 = 5 [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 = 5 [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 = 5 [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 = 6;
      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 = 6;
      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 = 6;