Class PollWorkflowTaskQueueResponse.Builder
java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<PollWorkflowTaskQueueResponse.Builder>
com.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,PollWorkflowTaskQueueResponseOrBuilder,Cloneable
- Enclosing class:
PollWorkflowTaskQueueResponse
public static final class PollWorkflowTaskQueueResponse.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
implements PollWorkflowTaskQueueResponseOrBuilder
Protobuf type
temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse-
Method Summary
Modifier and TypeMethodDescriptionaddAllMessages(Iterable<? extends Message> values) Protocol messages piggybacking on a WFT as a transportaddAllPollerGroupInfos(Iterable<? extends PollerGroupInfo> values) Deprecated.addMessages(int index, Message value) Protocol messages piggybacking on a WFT as a transportaddMessages(int index, Message.Builder builderForValue) Protocol messages piggybacking on a WFT as a transportaddMessages(Message value) Protocol messages piggybacking on a WFT as a transportaddMessages(Message.Builder builderForValue) Protocol messages piggybacking on a WFT as a transportProtocol messages piggybacking on a WFT as a transportaddMessagesBuilder(int index) Protocol messages piggybacking on a WFT as a transportaddPollerGroupInfos(int index, PollerGroupInfo value) Deprecated.addPollerGroupInfos(int index, PollerGroupInfo.Builder builderForValue) Deprecated.Deprecated.addPollerGroupInfos(PollerGroupInfo.Builder builderForValue) Deprecated.Deprecated.addPollerGroupInfosBuilder(int index) Deprecated.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) build()clear()Starting at 1, the number of attempts to complete this task by any worker.A hint that there are more tasks already present in this task queue partition.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) The history for this workflow, which will either be complete or partial.Protocol messages piggybacking on a WFT as a transportWill be set if there are more history events than were included in this response.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) This poller group ID identifies the owner of the workflow task awaiting for query response.Deprecated.The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.Server-advised information the SDK may use to adjust its poller count.The last workflow task started event which was processed by some worker for this execution.Legacy queries appear in this field.When this task was scheduled by the serverThe id of the most recent workflow task started event, which will have been generated as a result of this poll request being served.When the current workflow task started event was generated, meaning the current attempt.A unique identifier for this task.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue..temporal.api.common.v1.WorkflowType workflow_type = 3;clone()booleancontainsQueries(String key) Queries that should be executed after applying the history in this task.intStarting at 1, the number of attempts to complete this task by any worker.longA hint that there are more tasks already present in this task queue partition.static final com.google.protobuf.Descriptors.Descriptorcom.google.protobuf.Descriptors.DescriptorThe history for this workflow, which will either be complete or partial.The history for this workflow, which will either be complete or partial.The history for this workflow, which will either be complete or partial.getMessages(int index) Protocol messages piggybacking on a WFT as a transportgetMessagesBuilder(int index) Protocol messages piggybacking on a WFT as a transportProtocol messages piggybacking on a WFT as a transportintProtocol messages piggybacking on a WFT as a transportProtocol messages piggybacking on a WFT as a transportgetMessagesOrBuilder(int index) Protocol messages piggybacking on a WFT as a transportList<? extends MessageOrBuilder> Protocol messages piggybacking on a WFT as a transportDeprecated.com.google.protobuf.ByteStringWill be set if there are more history events than were included in this response.This poller group ID identifies the owner of the workflow task awaiting for query response.com.google.protobuf.ByteStringThis poller group ID identifies the owner of the workflow task awaiting for query response.getPollerGroupInfos(int index) Deprecated.getPollerGroupInfosBuilder(int index) Deprecated.Deprecated.intDeprecated.Deprecated.getPollerGroupInfosOrBuilder(int index) Deprecated.List<? extends PollerGroupInfoOrBuilder> Deprecated.The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.Server-advised information the SDK may use to adjust its poller count.Server-advised information the SDK may use to adjust its poller count.Server-advised information the SDK may use to adjust its poller count.longThe last workflow task started event which was processed by some worker for this execution.Deprecated.intQueries that should be executed after applying the history in this task.Queries that should be executed after applying the history in this task.getQueriesOrDefault(String key, WorkflowQuery defaultValue) Queries that should be executed after applying the history in this task.getQueriesOrThrow(String key) Queries that should be executed after applying the history in this task.getQuery()Legacy queries appear in this field.Legacy queries appear in this field.Legacy queries appear in this field.com.google.protobuf.TimestampWhen this task was scheduled by the servercom.google.protobuf.Timestamp.BuilderWhen this task was scheduled by the servercom.google.protobuf.TimestampOrBuilderWhen this task was scheduled by the serverlongThe id of the most recent workflow task started event, which will have been generated as a result of this poll request being served.com.google.protobuf.TimestampWhen the current workflow task started event was generated, meaning the current attempt.com.google.protobuf.Timestamp.BuilderWhen the current workflow task started event was generated, meaning the current attempt.com.google.protobuf.TimestampOrBuilderWhen the current workflow task started event was generated, meaning the current attempt.com.google.protobuf.ByteStringA unique identifier for this task.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue..temporal.api.common.v1.WorkflowType workflow_type = 3;.temporal.api.common.v1.WorkflowType workflow_type = 3;.temporal.api.common.v1.WorkflowType workflow_type = 3;booleanThe history for this workflow, which will either be complete or partial.booleanThe weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.booleanServer-advised information the SDK may use to adjust its poller count.booleanhasQuery()Legacy queries appear in this field.booleanWhen this task was scheduled by the serverbooleanWhen the current workflow task started event was generated, meaning the current attempt.boolean.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;booleanThe task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.boolean.temporal.api.common.v1.WorkflowType workflow_type = 3;protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableprotected com.google.protobuf.MapFieldReflectionAccessorinternalGetMapFieldReflection(int number) protected com.google.protobuf.MapFieldReflectionAccessorinternalGetMutableMapFieldReflection(int number) final booleanmergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom(com.google.protobuf.Message other) mergeHistory(History value) The history for this workflow, which will either be complete or partial.The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.Server-advised information the SDK may use to adjust its poller count.mergeQuery(WorkflowQuery value) Legacy queries appear in this field.mergeScheduledTime(com.google.protobuf.Timestamp value) When this task was scheduled by the servermergeStartedTime(com.google.protobuf.Timestamp value) When the current workflow task started event was generated, meaning the current attempt.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) .temporal.api.common.v1.WorkflowExecution workflow_execution = 2;The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.mergeWorkflowType(WorkflowType value) .temporal.api.common.v1.WorkflowType workflow_type = 3;putAllQueries(Map<String, WorkflowQuery> values) Queries that should be executed after applying the history in this task.putQueries(String key, WorkflowQuery value) Queries that should be executed after applying the history in this task.Queries that should be executed after applying the history in this task.removeMessages(int index) Protocol messages piggybacking on a WFT as a transportremovePollerGroupInfos(int index) Deprecated.removeQueries(String key) Queries that should be executed after applying the history in this task.setAttempt(int value) Starting at 1, the number of attempts to complete this task by any worker.setBacklogCountHint(long value) A hint that there are more tasks already present in this task queue partition.setHistory(History value) The history for this workflow, which will either be complete or partial.setHistory(History.Builder builderForValue) The history for this workflow, which will either be complete or partial.setMessages(int index, Message value) Protocol messages piggybacking on a WFT as a transportsetMessages(int index, Message.Builder builderForValue) Protocol messages piggybacking on a WFT as a transportsetNextPageToken(com.google.protobuf.ByteString value) Will be set if there are more history events than were included in this response.setPollerGroupId(String value) This poller group ID identifies the owner of the workflow task awaiting for query response.setPollerGroupIdBytes(com.google.protobuf.ByteString value) This poller group ID identifies the owner of the workflow task awaiting for query response.setPollerGroupInfos(int index, PollerGroupInfo value) Deprecated.setPollerGroupInfos(int index, PollerGroupInfo.Builder builderForValue) Deprecated.The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.setPollerGroupsInfo(PollerGroupsInfo.Builder builderForValue) The weighted, versioned list of poller groups IDs that client should use for future polls to this task queue.Server-advised information the SDK may use to adjust its poller count.setPollerScalingDecision(PollerScalingDecision.Builder builderForValue) Server-advised information the SDK may use to adjust its poller count.setPreviousStartedEventId(long value) The last workflow task started event which was processed by some worker for this execution.setQuery(WorkflowQuery value) Legacy queries appear in this field.setQuery(WorkflowQuery.Builder builderForValue) Legacy queries appear in this field.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) setScheduledTime(com.google.protobuf.Timestamp value) When this task was scheduled by the serversetScheduledTime(com.google.protobuf.Timestamp.Builder builderForValue) When this task was scheduled by the serversetStartedEventId(long value) The id of the most recent workflow task started event, which will have been generated as a result of this poll request being served.setStartedTime(com.google.protobuf.Timestamp value) When the current workflow task started event was generated, meaning the current attempt.setStartedTime(com.google.protobuf.Timestamp.Builder builderForValue) When the current workflow task started event was generated, meaning the current attempt.setTaskToken(com.google.protobuf.ByteString value) A unique identifier for this tasksetUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) .temporal.api.common.v1.WorkflowExecution workflow_execution = 2;setWorkflowExecution(WorkflowExecution.Builder builderForValue) .temporal.api.common.v1.WorkflowExecution workflow_execution = 2;The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.setWorkflowExecutionTaskQueue(TaskQueue.Builder builderForValue) The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.setWorkflowType(WorkflowType value) .temporal.api.common.v1.WorkflowType workflow_type = 3;setWorkflowType(WorkflowType.Builder builderForValue) .temporal.api.common.v1.WorkflowType workflow_type = 3;Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageExceptionMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFromMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
internalGetMapFieldReflection
protected com.google.protobuf.MapFieldReflectionAccessor internalGetMapFieldReflection(int number) - Overrides:
internalGetMapFieldReflectionin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
internalGetMutableMapFieldReflection
protected com.google.protobuf.MapFieldReflectionAccessor internalGetMutableMapFieldReflection(int number) - Overrides:
internalGetMutableMapFieldReflectionin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
clear
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
clone
- Specified by:
clonein interfacecom.google.protobuf.Message.Builder- Specified by:
clonein interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clonein classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
setField
public PollWorkflowTaskQueueResponse.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
setFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
clearField
public PollWorkflowTaskQueueResponse.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) - Specified by:
clearFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
clearFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
clearOneof
public PollWorkflowTaskQueueResponse.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) - Specified by:
clearOneofin interfacecom.google.protobuf.Message.Builder- Overrides:
clearOneofin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
setRepeatedField
public PollWorkflowTaskQueueResponse.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) - Specified by:
setRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
addRepeatedField
public PollWorkflowTaskQueueResponse.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
addRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
addRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
mergeFrom
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<PollWorkflowTaskQueueResponse.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
mergeFrom
public PollWorkflowTaskQueueResponse.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<PollWorkflowTaskQueueResponse.Builder>- Throws:
IOException
-
getTaskToken
public com.google.protobuf.ByteString getTaskToken()A unique identifier for this task
bytes task_token = 1;- Specified by:
getTaskTokenin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The taskToken.
-
setTaskToken
A unique identifier for this task
bytes task_token = 1;- Parameters:
value- The taskToken to set.- Returns:
- This builder for chaining.
-
clearTaskToken
A unique identifier for this task
bytes task_token = 1;- Returns:
- This builder for chaining.
-
hasWorkflowExecution
public boolean hasWorkflowExecution().temporal.api.common.v1.WorkflowExecution workflow_execution = 2;- Specified by:
hasWorkflowExecutionin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the workflowExecution field is set.
-
getWorkflowExecution
.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;- Specified by:
getWorkflowExecutionin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The workflowExecution.
-
setWorkflowExecution
.temporal.api.common.v1.WorkflowExecution workflow_execution = 2; -
setWorkflowExecution
public PollWorkflowTaskQueueResponse.Builder setWorkflowExecution(WorkflowExecution.Builder builderForValue) .temporal.api.common.v1.WorkflowExecution workflow_execution = 2; -
mergeWorkflowExecution
.temporal.api.common.v1.WorkflowExecution workflow_execution = 2; -
clearWorkflowExecution
.temporal.api.common.v1.WorkflowExecution workflow_execution = 2; -
getWorkflowExecutionBuilder
.temporal.api.common.v1.WorkflowExecution workflow_execution = 2; -
getWorkflowExecutionOrBuilder
.temporal.api.common.v1.WorkflowExecution workflow_execution = 2;- Specified by:
getWorkflowExecutionOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
hasWorkflowType
public boolean hasWorkflowType().temporal.api.common.v1.WorkflowType workflow_type = 3;- Specified by:
hasWorkflowTypein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the workflowType field is set.
-
getWorkflowType
.temporal.api.common.v1.WorkflowType workflow_type = 3;- Specified by:
getWorkflowTypein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The workflowType.
-
setWorkflowType
.temporal.api.common.v1.WorkflowType workflow_type = 3; -
setWorkflowType
.temporal.api.common.v1.WorkflowType workflow_type = 3; -
mergeWorkflowType
.temporal.api.common.v1.WorkflowType workflow_type = 3; -
clearWorkflowType
.temporal.api.common.v1.WorkflowType workflow_type = 3; -
getWorkflowTypeBuilder
.temporal.api.common.v1.WorkflowType workflow_type = 3; -
getWorkflowTypeOrBuilder
.temporal.api.common.v1.WorkflowType workflow_type = 3;- Specified by:
getWorkflowTypeOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getPreviousStartedEventId
public long getPreviousStartedEventId()The last workflow task started event which was processed by some worker for this execution. Will be zero if no task has ever started.
int64 previous_started_event_id = 4;- Specified by:
getPreviousStartedEventIdin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The previousStartedEventId.
-
setPreviousStartedEventId
The last workflow task started event which was processed by some worker for this execution. Will be zero if no task has ever started.
int64 previous_started_event_id = 4;- Parameters:
value- The previousStartedEventId to set.- Returns:
- This builder for chaining.
-
clearPreviousStartedEventId
The last workflow task started event which was processed by some worker for this execution. Will be zero if no task has ever started.
int64 previous_started_event_id = 4;- Returns:
- This builder for chaining.
-
getStartedEventId
public long getStartedEventId()The id of the most recent workflow task started event, which will have been generated as a result of this poll request being served. Will be zero if the task does not contain any events which would advance history (no new WFT started). Currently this can happen for queries.
int64 started_event_id = 5;- Specified by:
getStartedEventIdin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The startedEventId.
-
setStartedEventId
The id of the most recent workflow task started event, which will have been generated as a result of this poll request being served. Will be zero if the task does not contain any events which would advance history (no new WFT started). Currently this can happen for queries.
int64 started_event_id = 5;- Parameters:
value- The startedEventId to set.- Returns:
- This builder for chaining.
-
clearStartedEventId
The id of the most recent workflow task started event, which will have been generated as a result of this poll request being served. Will be zero if the task does not contain any events which would advance history (no new WFT started). Currently this can happen for queries.
int64 started_event_id = 5;- Returns:
- This builder for chaining.
-
getAttempt
public int getAttempt()Starting at 1, the number of attempts to complete this task by any worker.
int32 attempt = 6;- Specified by:
getAttemptin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The attempt.
-
setAttempt
Starting at 1, the number of attempts to complete this task by any worker.
int32 attempt = 6;- Parameters:
value- The attempt to set.- Returns:
- This builder for chaining.
-
clearAttempt
Starting at 1, the number of attempts to complete this task by any worker.
int32 attempt = 6;- Returns:
- This builder for chaining.
-
getBacklogCountHint
public long getBacklogCountHint()A hint that there are more tasks already present in this task queue partition. Can be used to prioritize draining a sticky queue. Specifically, the returned number is the number of tasks remaining in the in-memory buffer for this partition, which is currently capped at 1000. Because sticky queues only have one partition, this number is more useful when draining them. Normal queues, typically having more than one partition, will return a number representing only some portion of the overall backlog. Subsequent RPCs may not hit the same partition as this call.
int64 backlog_count_hint = 7;- Specified by:
getBacklogCountHintin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The backlogCountHint.
-
setBacklogCountHint
A hint that there are more tasks already present in this task queue partition. Can be used to prioritize draining a sticky queue. Specifically, the returned number is the number of tasks remaining in the in-memory buffer for this partition, which is currently capped at 1000. Because sticky queues only have one partition, this number is more useful when draining them. Normal queues, typically having more than one partition, will return a number representing only some portion of the overall backlog. Subsequent RPCs may not hit the same partition as this call.
int64 backlog_count_hint = 7;- Parameters:
value- The backlogCountHint to set.- Returns:
- This builder for chaining.
-
clearBacklogCountHint
A hint that there are more tasks already present in this task queue partition. Can be used to prioritize draining a sticky queue. Specifically, the returned number is the number of tasks remaining in the in-memory buffer for this partition, which is currently capped at 1000. Because sticky queues only have one partition, this number is more useful when draining them. Normal queues, typically having more than one partition, will return a number representing only some portion of the overall backlog. Subsequent RPCs may not hit the same partition as this call.
int64 backlog_count_hint = 7;- Returns:
- This builder for chaining.
-
hasHistory
public boolean hasHistory()The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8;- Specified by:
hasHistoryin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the history field is set.
-
getHistory
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8;- Specified by:
getHistoryin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The history.
-
setHistory
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8; -
setHistory
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8; -
mergeHistory
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8; -
clearHistory
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8; -
getHistoryBuilder
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8; -
getHistoryOrBuilder
The history for this workflow, which will either be complete or partial. Partial histories are sent to workers who have signaled that they are using a sticky queue when completing a workflow task.
.temporal.api.history.v1.History history = 8;- Specified by:
getHistoryOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getNextPageToken
public com.google.protobuf.ByteString getNextPageToken()Will be set if there are more history events than were included in this response. Such events should be fetched via `GetWorkflowExecutionHistory`.
bytes next_page_token = 9;- Specified by:
getNextPageTokenin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The nextPageToken.
-
setNextPageToken
Will be set if there are more history events than were included in this response. Such events should be fetched via `GetWorkflowExecutionHistory`.
bytes next_page_token = 9;- Parameters:
value- The nextPageToken to set.- Returns:
- This builder for chaining.
-
clearNextPageToken
Will be set if there are more history events than were included in this response. Such events should be fetched via `GetWorkflowExecutionHistory`.
bytes next_page_token = 9;- Returns:
- This builder for chaining.
-
hasQuery
public boolean hasQuery()Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10;- Specified by:
hasQueryin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the query field is set.
-
getQuery
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10;- Specified by:
getQueryin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The query.
-
setQuery
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10; -
setQuery
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10; -
mergeQuery
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10; -
clearQuery
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10; -
getQueryBuilder
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10; -
getQueryOrBuilder
Legacy queries appear in this field. The query must be responded to via `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on closed workflows) then the `history` field will be populated with the entire history. It may also be populated if this task originates on a non-sticky queue.
.temporal.api.query.v1.WorkflowQuery query = 10;- Specified by:
getQueryOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
hasWorkflowExecutionTaskQueue
public boolean hasWorkflowExecutionTaskQueue()The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11;- Specified by:
hasWorkflowExecutionTaskQueuein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the workflowExecutionTaskQueue field is set.
-
getWorkflowExecutionTaskQueue
The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11;- Specified by:
getWorkflowExecutionTaskQueuein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The workflowExecutionTaskQueue.
-
setWorkflowExecutionTaskQueue
The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11; -
setWorkflowExecutionTaskQueue
public PollWorkflowTaskQueueResponse.Builder setWorkflowExecutionTaskQueue(TaskQueue.Builder builderForValue) The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11; -
mergeWorkflowExecutionTaskQueue
The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11; -
clearWorkflowExecutionTaskQueue
The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11; -
getWorkflowExecutionTaskQueueBuilder
The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11; -
getWorkflowExecutionTaskQueueOrBuilder
The task queue this task originated from, which will always be the original non-sticky name for the queue, even if this response came from polling a sticky queue.
.temporal.api.taskqueue.v1.TaskQueue workflow_execution_task_queue = 11;- Specified by:
getWorkflowExecutionTaskQueueOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
hasScheduledTime
public boolean hasScheduledTime()When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12;- Specified by:
hasScheduledTimein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the scheduledTime field is set.
-
getScheduledTime
public com.google.protobuf.Timestamp getScheduledTime()When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12;- Specified by:
getScheduledTimein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The scheduledTime.
-
setScheduledTime
When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12; -
setScheduledTime
public PollWorkflowTaskQueueResponse.Builder setScheduledTime(com.google.protobuf.Timestamp.Builder builderForValue) When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12; -
mergeScheduledTime
public PollWorkflowTaskQueueResponse.Builder mergeScheduledTime(com.google.protobuf.Timestamp value) When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12; -
clearScheduledTime
When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12; -
getScheduledTimeBuilder
public com.google.protobuf.Timestamp.Builder getScheduledTimeBuilder()When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12; -
getScheduledTimeOrBuilder
public com.google.protobuf.TimestampOrBuilder getScheduledTimeOrBuilder()When this task was scheduled by the server
.google.protobuf.Timestamp scheduled_time = 12;- Specified by:
getScheduledTimeOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
hasStartedTime
public boolean hasStartedTime()When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13;- Specified by:
hasStartedTimein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the startedTime field is set.
-
getStartedTime
public com.google.protobuf.Timestamp getStartedTime()When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13;- Specified by:
getStartedTimein interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The startedTime.
-
setStartedTime
When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13; -
setStartedTime
public PollWorkflowTaskQueueResponse.Builder setStartedTime(com.google.protobuf.Timestamp.Builder builderForValue) When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13; -
mergeStartedTime
When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13; -
clearStartedTime
When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13; -
getStartedTimeBuilder
public com.google.protobuf.Timestamp.Builder getStartedTimeBuilder()When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13; -
getStartedTimeOrBuilder
public com.google.protobuf.TimestampOrBuilder getStartedTimeOrBuilder()When the current workflow task started event was generated, meaning the current attempt.
.google.protobuf.Timestamp started_time = 13;- Specified by:
getStartedTimeOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getQueriesCount
public int getQueriesCount()Description copied from interface:PollWorkflowTaskQueueResponseOrBuilderQueries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14;- Specified by:
getQueriesCountin interfacePollWorkflowTaskQueueResponseOrBuilder
-
containsQueries
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14;- Specified by:
containsQueriesin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getQueries
Deprecated.UsegetQueriesMap()instead.- Specified by:
getQueriesin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getQueriesMap
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14;- Specified by:
getQueriesMapin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getQueriesOrDefault
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14;- Specified by:
getQueriesOrDefaultin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getQueriesOrThrow
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14;- Specified by:
getQueriesOrThrowin interfacePollWorkflowTaskQueueResponseOrBuilder
-
clearQueries
-
removeQueries
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14; -
getMutableQueries
Deprecated.Use alternate mutation accessors instead. -
putQueries
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14; -
putAllQueries
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14; -
putQueriesBuilderIfAbsent
Queries that should be executed after applying the history in this task. Responses should be attached to `RespondWorkflowTaskCompletedRequest::query_results`
map<string, .temporal.api.query.v1.WorkflowQuery> queries = 14; -
getMessagesList
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15;- Specified by:
getMessagesListin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getMessagesCount
public int getMessagesCount()Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15;- Specified by:
getMessagesCountin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15;- Specified by:
getMessagesin interfacePollWorkflowTaskQueueResponseOrBuilder
-
setMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
setMessages
public PollWorkflowTaskQueueResponse.Builder setMessages(int index, Message.Builder builderForValue) Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
addMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
addMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
addMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
addMessages
public PollWorkflowTaskQueueResponse.Builder addMessages(int index, Message.Builder builderForValue) Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
addAllMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
clearMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
removeMessages
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
getMessagesBuilder
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
getMessagesOrBuilder
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15;- Specified by:
getMessagesOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getMessagesOrBuilderList
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15;- Specified by:
getMessagesOrBuilderListin interfacePollWorkflowTaskQueueResponseOrBuilder
-
addMessagesBuilder
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
addMessagesBuilder
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
getMessagesBuilderList
Protocol messages piggybacking on a WFT as a transport
repeated .temporal.api.protocol.v1.Message messages = 15; -
hasPollerScalingDecision
public boolean hasPollerScalingDecision()Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16;- Specified by:
hasPollerScalingDecisionin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the pollerScalingDecision field is set.
-
getPollerScalingDecision
Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16;- Specified by:
getPollerScalingDecisionin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The pollerScalingDecision.
-
setPollerScalingDecision
Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16; -
setPollerScalingDecision
public PollWorkflowTaskQueueResponse.Builder setPollerScalingDecision(PollerScalingDecision.Builder builderForValue) Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16; -
mergePollerScalingDecision
public PollWorkflowTaskQueueResponse.Builder mergePollerScalingDecision(PollerScalingDecision value) Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16; -
clearPollerScalingDecision
Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16; -
getPollerScalingDecisionBuilder
Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16; -
getPollerScalingDecisionOrBuilder
Server-advised information the SDK may use to adjust its poller count.
.temporal.api.taskqueue.v1.PollerScalingDecision poller_scaling_decision = 16;- Specified by:
getPollerScalingDecisionOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getPollerGroupId
This poller group ID identifies the owner of the workflow task awaiting for query response. Corresponding RespondQueryTaskCompleted should pass this value for proper routing.
string poller_group_id = 17;- Specified by:
getPollerGroupIdin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The pollerGroupId.
-
getPollerGroupIdBytes
public com.google.protobuf.ByteString getPollerGroupIdBytes()This poller group ID identifies the owner of the workflow task awaiting for query response. Corresponding RespondQueryTaskCompleted should pass this value for proper routing.
string poller_group_id = 17;- Specified by:
getPollerGroupIdBytesin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The bytes for pollerGroupId.
-
setPollerGroupId
This poller group ID identifies the owner of the workflow task awaiting for query response. Corresponding RespondQueryTaskCompleted should pass this value for proper routing.
string poller_group_id = 17;- Parameters:
value- The pollerGroupId to set.- Returns:
- This builder for chaining.
-
clearPollerGroupId
This poller group ID identifies the owner of the workflow task awaiting for query response. Corresponding RespondQueryTaskCompleted should pass this value for proper routing.
string poller_group_id = 17;- Returns:
- This builder for chaining.
-
setPollerGroupIdBytes
public PollWorkflowTaskQueueResponse.Builder setPollerGroupIdBytes(com.google.protobuf.ByteString value) This poller group ID identifies the owner of the workflow task awaiting for query response. Corresponding RespondQueryTaskCompleted should pass this value for proper routing.
string poller_group_id = 17;- Parameters:
value- The bytes for pollerGroupId to set.- Returns:
- This builder for chaining.
-
getPollerGroupInfosList
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true];- Specified by:
getPollerGroupInfosListin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getPollerGroupInfosCount
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true];- Specified by:
getPollerGroupInfosCountin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getPollerGroupInfos
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true];- Specified by:
getPollerGroupInfosin interfacePollWorkflowTaskQueueResponseOrBuilder
-
setPollerGroupInfos
@Deprecated public PollWorkflowTaskQueueResponse.Builder setPollerGroupInfos(int index, PollerGroupInfo value) Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
setPollerGroupInfos
@Deprecated public PollWorkflowTaskQueueResponse.Builder setPollerGroupInfos(int index, PollerGroupInfo.Builder builderForValue) Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
addPollerGroupInfos
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
addPollerGroupInfos
@Deprecated public PollWorkflowTaskQueueResponse.Builder addPollerGroupInfos(int index, PollerGroupInfo value) Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
addPollerGroupInfos
@Deprecated public PollWorkflowTaskQueueResponse.Builder addPollerGroupInfos(PollerGroupInfo.Builder builderForValue) Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
addPollerGroupInfos
@Deprecated public PollWorkflowTaskQueueResponse.Builder addPollerGroupInfos(int index, PollerGroupInfo.Builder builderForValue) Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
addAllPollerGroupInfos
@Deprecated public PollWorkflowTaskQueueResponse.Builder addAllPollerGroupInfos(Iterable<? extends PollerGroupInfo> values) Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
clearPollerGroupInfos
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
removePollerGroupInfos
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
getPollerGroupInfosBuilder
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
getPollerGroupInfosOrBuilder
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true];- Specified by:
getPollerGroupInfosOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
getPollerGroupInfosOrBuilderList
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true];- Specified by:
getPollerGroupInfosOrBuilderListin interfacePollWorkflowTaskQueueResponseOrBuilder
-
addPollerGroupInfosBuilder
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
addPollerGroupInfosBuilder
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
getPollerGroupInfosBuilderList
Deprecated.Deprecated. Use `poller_groups_info` instead, which carries a version so the client can ignore stale updates. 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 = 18 [deprecated = true]; -
hasPollerGroupsInfo
public 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 = 19;- Specified by:
hasPollerGroupsInfoin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- Whether the pollerGroupsInfo field is set.
-
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 = 19;- Specified by:
getPollerGroupsInfoin interfacePollWorkflowTaskQueueResponseOrBuilder- Returns:
- The pollerGroupsInfo.
-
setPollerGroupsInfo
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 = 19; -
setPollerGroupsInfo
public PollWorkflowTaskQueueResponse.Builder setPollerGroupsInfo(PollerGroupsInfo.Builder builderForValue) 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 = 19; -
mergePollerGroupsInfo
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 = 19; -
clearPollerGroupsInfo
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 = 19; -
getPollerGroupsInfoBuilder
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 = 19; -
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 = 19;- Specified by:
getPollerGroupsInfoOrBuilderin interfacePollWorkflowTaskQueueResponseOrBuilder
-
setUnknownFields
public final PollWorkflowTaskQueueResponse.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
setUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
setUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-
mergeUnknownFields
public final PollWorkflowTaskQueueResponse.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
mergeUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<PollWorkflowTaskQueueResponse.Builder>
-