Class SingleWorkerOptions

java.lang.Object

io.temporal.internal.worker.SingleWorkerOptions

public final class SingleWorkerOptions
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SingleWorkerOptions.Builder

Method Summary

Modifier and Type	Method	Description
boolean	getAllowActivityHeartbeatDuringShutdown()
String	getBinaryChecksum()	Deprecated.
String	getBuildId()
List<ContextPropagator>	getContextPropagators()
DataConverter	getDataConverter()
long	getDefaultDeadlockDetectionTimeout()
Duration	getDefaultHeartbeatThrottleInterval()
WorkerDeploymentOptions	getDeploymentOptions()
Duration	getDrainStickyTaskQueueTimeout()
boolean	getEnableLoggingInReplay()
String	getIdentity()
Duration	getMaxHeartbeatThrottleInterval()
com.uber.m3.tally.Scope	getMetricsScope()
PollerOptions	getPollerOptions()
Duration	getStickyQueueScheduleToStartTimeout()
String	getWorkerControlTaskQueue()
String	getWorkerInstanceKey()
WorkerInterceptor[]	getWorkerInterceptors()
WorkerVersioningOptions	getWorkerVersioningOptions()
boolean	isUsingBuildIdForVersioning()
boolean	isUsingVirtualThreads()
static SingleWorkerOptions.Builder	newBuilder()
static SingleWorkerOptions.Builder	newBuilder(SingleWorkerOptions options)
io.temporal.api.common.v1.WorkerVersionStamp	workerVersionStamp()

Methods inherited from class java.lang.Object

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

Method Details

newBuilder

public static SingleWorkerOptions.Builder newBuilder()

newBuilder

public static SingleWorkerOptions.Builder newBuilder(SingleWorkerOptions options)

getIdentity

public String getIdentity()

getBinaryChecksum

@Deprecated
public String getBinaryChecksum()

Deprecated.

getBuildId

public String getBuildId()

isUsingBuildIdForVersioning

public boolean isUsingBuildIdForVersioning()

isUsingVirtualThreads

public boolean isUsingVirtualThreads()

getDrainStickyTaskQueueTimeout

public Duration getDrainStickyTaskQueueTimeout()

getAllowActivityHeartbeatDuringShutdown

public boolean getAllowActivityHeartbeatDuringShutdown()

getDataConverter

public DataConverter getDataConverter()

getPollerOptions

public PollerOptions getPollerOptions()

getMetricsScope

public com.uber.m3.tally.Scope getMetricsScope()

getEnableLoggingInReplay

public boolean getEnableLoggingInReplay()

getContextPropagators

public List<ContextPropagator> getContextPropagators()

getWorkerInterceptors

public WorkerInterceptor[] getWorkerInterceptors()

getStickyQueueScheduleToStartTimeout

public Duration getStickyQueueScheduleToStartTimeout()

getDefaultDeadlockDetectionTimeout

public long getDefaultDeadlockDetectionTimeout()

getMaxHeartbeatThrottleInterval

public Duration getMaxHeartbeatThrottleInterval()

getDefaultHeartbeatThrottleInterval

public Duration getDefaultHeartbeatThrottleInterval()

workerVersionStamp

public io.temporal.api.common.v1.WorkerVersionStamp workerVersionStamp()

getDeploymentOptions

public WorkerDeploymentOptions getDeploymentOptions()

getWorkerInstanceKey

public String getWorkerInstanceKey()

getWorkerControlTaskQueue

public String getWorkerControlTaskQueue()

getWorkerVersioningOptions

public WorkerVersioningOptions getWorkerVersioningOptions()