Class SingleWorkerOptions.Builder

java.lang.Object

io.temporal.internal.worker.SingleWorkerOptions.Builder

Enclosing class:

SingleWorkerOptions

public static final class SingleWorkerOptions.Builder
extends Object

Method Summary

Modifier and Type	Method	Description
SingleWorkerOptions	build()
SingleWorkerOptions.Builder	setAllowActivityHeartbeatDuringShutdown(boolean allowActivityHeartbeatDuringShutdown)
SingleWorkerOptions.Builder	setBinaryChecksum(String binaryChecksum)	Deprecated.
SingleWorkerOptions.Builder	setBuildId(String buildId)
SingleWorkerOptions.Builder	setContextPropagators(List<ContextPropagator> contextPropagators)	Specifies the list of context propagators to use during this workflow.
SingleWorkerOptions.Builder	setDataConverter(DataConverter dataConverter)
SingleWorkerOptions.Builder	setDefaultDeadlockDetectionTimeout(long defaultDeadlockDetectionTimeout)
SingleWorkerOptions.Builder	setDefaultHeartbeatThrottleInterval(Duration defaultHeartbeatThrottleInterval)
SingleWorkerOptions.Builder	setDeploymentOptions(WorkerDeploymentOptions deploymentOptions)
SingleWorkerOptions.Builder	setEnableLoggingInReplay(boolean enableLoggingInReplay)
SingleWorkerOptions.Builder	setExternalStorageRunner(ExternalStorageRunner externalStorageRunner)
SingleWorkerOptions.Builder	setIdentity(String identity)
SingleWorkerOptions.Builder	setMaxHeartbeatThrottleInterval(Duration maxHeartbeatThrottleInterval)
SingleWorkerOptions.Builder	setMetricsScope(com.uber.m3.tally.Scope metricsScope)
SingleWorkerOptions.Builder	setPollerOptions(PollerOptions pollerOptions)
SingleWorkerOptions.Builder	setPreferredVersionProvider(PreferredVersionProvider preferredVersionProvider)
SingleWorkerOptions.Builder	setStickyQueueScheduleToStartTimeout(Duration stickyQueueScheduleToStartTimeout)
SingleWorkerOptions.Builder	setStickyTaskQueueDrainTimeout(Duration drainStickyTaskQueueTimeout)
SingleWorkerOptions.Builder	setStorageCancellation(CancellationToken<CancellationException> storageCancellation)	Cancelled when this worker stops, to abandon its in-flight external storage work.
SingleWorkerOptions.Builder	setUseBuildIdForVersioning(boolean useBuildIdForVersioning)
SingleWorkerOptions.Builder	setUsingVirtualThreads(boolean usingVirtualThreads)
SingleWorkerOptions.Builder	setWorkerControlTaskQueue(String workerControlTaskQueue)
SingleWorkerOptions.Builder	setWorkerInstanceKey(String workerInstanceKey)
SingleWorkerOptions.Builder	setWorkerInterceptors(WorkerInterceptor[] workerInterceptors)	Specifies the list of worker interceptors to use during this workflow.

Methods inherited from class java.lang.Object

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

Method Details

setIdentity

public SingleWorkerOptions.Builder setIdentity(String identity)

setBinaryChecksum

@Deprecated
public SingleWorkerOptions.Builder setBinaryChecksum(String binaryChecksum)

Deprecated.

setDataConverter

public SingleWorkerOptions.Builder setDataConverter(DataConverter dataConverter)

setPollerOptions

public SingleWorkerOptions.Builder setPollerOptions(PollerOptions pollerOptions)

setMetricsScope

public SingleWorkerOptions.Builder setMetricsScope(com.uber.m3.tally.Scope metricsScope)

setEnableLoggingInReplay

public SingleWorkerOptions.Builder setEnableLoggingInReplay(boolean enableLoggingInReplay)

setContextPropagators

public SingleWorkerOptions.Builder setContextPropagators(List<ContextPropagator> contextPropagators)

Specifies the list of context propagators to use during this workflow.

setWorkerInterceptors

public SingleWorkerOptions.Builder setWorkerInterceptors(WorkerInterceptor[] workerInterceptors)

Specifies the list of worker interceptors to use during this workflow.

setStickyQueueScheduleToStartTimeout

public SingleWorkerOptions.Builder setStickyQueueScheduleToStartTimeout(Duration stickyQueueScheduleToStartTimeout)

setDefaultDeadlockDetectionTimeout

public SingleWorkerOptions.Builder setDefaultDeadlockDetectionTimeout(long defaultDeadlockDetectionTimeout)

setMaxHeartbeatThrottleInterval

public SingleWorkerOptions.Builder setMaxHeartbeatThrottleInterval(Duration maxHeartbeatThrottleInterval)

setDefaultHeartbeatThrottleInterval

public SingleWorkerOptions.Builder setDefaultHeartbeatThrottleInterval(Duration defaultHeartbeatThrottleInterval)

setBuildId

public SingleWorkerOptions.Builder setBuildId(String buildId)

setUseBuildIdForVersioning

public SingleWorkerOptions.Builder setUseBuildIdForVersioning(boolean useBuildIdForVersioning)

setStickyTaskQueueDrainTimeout

public SingleWorkerOptions.Builder setStickyTaskQueueDrainTimeout(Duration drainStickyTaskQueueTimeout)

setUsingVirtualThreads

public SingleWorkerOptions.Builder setUsingVirtualThreads(boolean usingVirtualThreads)

setDeploymentOptions

public SingleWorkerOptions.Builder setDeploymentOptions(WorkerDeploymentOptions deploymentOptions)

setWorkerInstanceKey

public SingleWorkerOptions.Builder setWorkerInstanceKey(String workerInstanceKey)

setAllowActivityHeartbeatDuringShutdown

public SingleWorkerOptions.Builder setAllowActivityHeartbeatDuringShutdown(boolean allowActivityHeartbeatDuringShutdown)

setWorkerControlTaskQueue

public SingleWorkerOptions.Builder setWorkerControlTaskQueue(String workerControlTaskQueue)

setPreferredVersionProvider

public SingleWorkerOptions.Builder setPreferredVersionProvider(PreferredVersionProvider preferredVersionProvider)

setStorageCancellation

public SingleWorkerOptions.Builder setStorageCancellation(CancellationToken<CancellationException> storageCancellation)

Cancelled when this worker stops, to abandon its in-flight external storage work.

setExternalStorageRunner

public SingleWorkerOptions.Builder setExternalStorageRunner(@Nullable
 ExternalStorageRunner externalStorageRunner)

build

public SingleWorkerOptions build()