Class WorkerTuner

Namespace

Temporalio.Worker.Tuning

Assembly

Temporalio.dll

Implements IWorkerTuner by holding the different SlotSuppliers.

public class WorkerTuner : IWorkerTuner

Inheritance

object

WorkerTuner

Implements

IWorkerTuner

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

WorkerTuner(SlotSupplier, SlotSupplier, SlotSupplier, SlotSupplier)

Initializes a new instance of the WorkerTuner class composed of the provided slot suppliers.

public WorkerTuner(SlotSupplier workflowTaskSlotSupplier, SlotSupplier activityTaskSlotSupplier, SlotSupplier localActivitySlotSupplier, SlotSupplier nexusTaskSlotSupplier)

Parameters

workflowTaskSlotSupplier SlotSupplier

The supplier of workflow task slots.

activityTaskSlotSupplier SlotSupplier

The supplier of activity task slots.

localActivitySlotSupplier SlotSupplier

The supplier of local activity slots.

nexusTaskSlotSupplier SlotSupplier

The supplier of Nexus operation slots.

Remarks

WARNING: Nexus support is experimental.

Properties

ActivityTaskSlotSupplier

Gets a slot supplier for activity tasks.

public SlotSupplier ActivityTaskSlotSupplier { get; init; }

Property Value

SlotSupplier

A slot supplier for activity tasks.

LocalActivitySlotSupplier

Gets a slot supplier for local activities.

public SlotSupplier LocalActivitySlotSupplier { get; init; }

Property Value

SlotSupplier

A slot supplier for local activities.

NexusTaskSlotSupplier

Gets a slot supplier for Nexus operations.

public SlotSupplier NexusTaskSlotSupplier { get; init; }

Property Value

SlotSupplier

A slot supplier for Nexus operations.

Remarks

WARNING: Nexus support is experimental.

WorkflowTaskSlotSupplier

Gets a slot supplier for workflow tasks.

public SlotSupplier WorkflowTaskSlotSupplier { get; init; }

Property Value

SlotSupplier

A slot supplier for workflow tasks.

Methods

CreateFixedSize(int, int, int, int)

Create a fixed-size tuner with the given slot capacities.

public static WorkerTuner CreateFixedSize(int workflowTaskSlots, int activityTaskSlots, int localActivitySlots, int nexusTaskSlots = 100)

Parameters

workflowTaskSlots int

The number of available workflow task slots.

activityTaskSlots int

The number of available activity task slots.

localActivitySlots int

The number of available local activity slots.

nexusTaskSlots int

The number of available Nexus operation slots.

Returns

WorkerTuner

The tuner.

Remarks

WARNING: Nexus support is experimental.

CreateResourceBased(double, double, ResourceBasedSlotSupplierOptions?, ResourceBasedSlotSupplierOptions?, ResourceBasedSlotSupplierOptions?, ResourceBasedSlotSupplierOptions?)

Create a resource based tuner with the provided options.

public static WorkerTuner CreateResourceBased(double targetMemoryUsage, double targetCpuUsage, ResourceBasedSlotSupplierOptions? workflowOptions = null, ResourceBasedSlotSupplierOptions? activityOptions = null, ResourceBasedSlotSupplierOptions? localActivityOptions = null, ResourceBasedSlotSupplierOptions? nexusOptions = null)

Parameters

targetMemoryUsage double

A value between 0 and 1 that represents the target (system) memory usage. It's not recommended to set this higher than 0.8, since how much memory a workflow may use is not predictable, and you don't want to encounter OOM errors.

targetCpuUsage double

A value between 0 and 1 that represents the target (system) CPU usage. This can be set to 1.0 if desired, but it's recommended to leave some headroom for other processes.

workflowOptions ResourceBasedSlotSupplierOptions

Options for the workflow task slot supplier.

activityOptions ResourceBasedSlotSupplierOptions

Options for the activity task slot supplier.

localActivityOptions ResourceBasedSlotSupplierOptions

Options for the local activity slot supplier.

nexusOptions ResourceBasedSlotSupplierOptions

Options for the Nexus operation slot supplier.

Returns

WorkerTuner

The tuner.

Remarks

WARNING: Nexus support is experimental.