Class PollerOptions

java.lang.Object

io.temporal.internal.worker.PollerOptions

public final class PollerOptions
extends Object

Options for component that polls Temporal task queues for tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PollerOptions.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	UNHANDLED_COMMAND_EXCEPTION_MESSAGE

Method Summary

Modifier and Type	Method	Description
double	getBackoffCoefficient()
Duration	getBackoffCongestionInitialInterval()
Duration	getBackoffInitialInterval()
Duration	getBackoffMaximumInterval()
double	getBackoffMaximumJitterCoefficient()
static PollerOptions	getDefaultInstance()
int	getMaximumPollRateIntervalMilliseconds()
double	getMaximumPollRatePerSecond()
PollerBehavior	getPollerBehavior()
ExecutorService	getPollerTaskExecutorOverride()
String	getPollThreadNamePrefix()
Thread.UncaughtExceptionHandler	getUncaughtExceptionHandler()
boolean	isAutoscalingAutoEnrollEligible()
boolean	isUsingVirtualThreads()
static PollerOptions	maybeEnrollInPollerAutoscaling(PollerOptions options, NamespaceCapabilities namespaceCapabilities)	If the given options are eligible for poller-autoscaling auto-enrollment (the user left this poller type at its default) and the namespace advertises the auto-enroll capability, returns a copy of the options with a default PollerBehaviorAutoscaling behavior.
static PollerOptions.Builder	newBuilder()
static PollerOptions.Builder	newBuilder(PollerOptions options)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

UNHANDLED_COMMAND_EXCEPTION_MESSAGE

public static final String UNHANDLED_COMMAND_EXCEPTION_MESSAGE

See Also:

• Constant Field Values

Method Details

newBuilder

public static PollerOptions.Builder newBuilder()

newBuilder

public static PollerOptions.Builder newBuilder(PollerOptions options)

getDefaultInstance

public static PollerOptions getDefaultInstance()

maybeEnrollInPollerAutoscaling

public static PollerOptions maybeEnrollInPollerAutoscaling(PollerOptions options,
 NamespaceCapabilities namespaceCapabilities)

If the given options are eligible for poller-autoscaling auto-enrollment (the user left this poller type at its default) and the namespace advertises the auto-enroll capability, returns a copy of the options with a default PollerBehaviorAutoscaling behavior. Otherwise returns the options unchanged.

Must only be called before the worker's poller is created (i.e. at worker start), so the resolved behavior is picked up when the poller is built.

getMaximumPollRateIntervalMilliseconds

public int getMaximumPollRateIntervalMilliseconds()

getMaximumPollRatePerSecond

public double getMaximumPollRatePerSecond()

getBackoffCoefficient

public double getBackoffCoefficient()

getBackoffInitialInterval

public Duration getBackoffInitialInterval()

getBackoffCongestionInitialInterval

public Duration getBackoffCongestionInitialInterval()

getBackoffMaximumInterval

public Duration getBackoffMaximumInterval()

getBackoffMaximumJitterCoefficient

public double getBackoffMaximumJitterCoefficient()

getPollerBehavior

public PollerBehavior getPollerBehavior()

getUncaughtExceptionHandler

public Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

getPollThreadNamePrefix

public String getPollThreadNamePrefix()

isUsingVirtualThreads

public boolean isUsingVirtualThreads()

getPollerTaskExecutorOverride

public ExecutorService getPollerTaskExecutorOverride()

isAutoscalingAutoEnrollEligible

public boolean isAutoscalingAutoEnrollEligible()

toString

public String toString()

Overrides:

toString in class Object