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 Summary

    Modifier and Type
    Method
    Description
    String
    getPollerGroupId()
    This poller group ID identifies the owner of the nexus task awaiting for synchronous response.
    com.google.protobuf.ByteString
    getPollerGroupIdBytes()
    This poller group ID identifies the owner of the nexus task awaiting for synchronous response.
    PollerGroupInfo
    getPollerGroupInfos(int index)
    The weighted list of poller groups IDs that client should use for future polls to this task queue.
    int
    getPollerGroupInfosCount()
    The weighted list of poller groups IDs that client should use for future polls to this task queue.
    List<PollerGroupInfo>
    getPollerGroupInfosList()
    The weighted list of poller groups IDs that client should use for future polls to this task queue.
    PollerGroupInfoOrBuilder
    getPollerGroupInfosOrBuilder(int index)
    The weighted list of poller groups IDs that client should use for future polls to this task queue.
    List<? extends PollerGroupInfoOrBuilder>
    getPollerGroupInfosOrBuilderList()
    The weighted list of poller groups IDs that client should use for future polls to this task queue.
    PollerScalingDecision
    getPollerScalingDecision()
    Server-advised information the SDK may use to adjust its poller count.
    PollerScalingDecisionOrBuilder
    getPollerScalingDecisionOrBuilder()
    Server-advised information the SDK may use to adjust its poller count.
    Request
    getRequest()
    Embedded request as translated from the incoming frontend request.
    RequestOrBuilder
    getRequestOrBuilder()
    Embedded request as translated from the incoming frontend request.
    com.google.protobuf.ByteString
    getTaskToken()
    An opaque unique identifier for this task for correlating a completion request the embedded request.
    boolean
    hasPollerScalingDecision()
    Server-advised information the SDK may use to adjust its poller count.
    boolean
    hasRequest()
    Embedded request as translated from the incoming frontend request.

    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

    • 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

      List<PollerGroupInfo> getPollerGroupInfosList()
       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;

    • getPollerGroupInfos

      PollerGroupInfo getPollerGroupInfos(int index)
       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;

    • getPollerGroupInfosCount

      int getPollerGroupInfosCount()
       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;

    • getPollerGroupInfosOrBuilderList

      List<? extends PollerGroupInfoOrBuilder> getPollerGroupInfosOrBuilderList()
       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;

    • getPollerGroupInfosOrBuilder

      PollerGroupInfoOrBuilder getPollerGroupInfosOrBuilder(int index)
       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;