NewTaskManager returns a new task manager

NewTaskQueueTypedSettingWithConverter creates a setting with a custom converter function.

NewTrace returns a *httptrace.ClientTrace which provides hooks to invoke at each point in the HTTP request lifecycle. This trace must be added to the

NewWorkflowClosedTrigger creates a WorkflowClosed trigger variant.

NumWorkers returns the current number of workers. Probably only useful for testing.

ObserveCompletion exports withOnComplete to unit tests

OnAfterCommit adds the provided effect function to set of such functions to be invoked when Buffer.Apply is called.

OnAfterRollback adds the provided effect function to set of such functions to be invoked when Buffer.Cancel is called.

PartitionScale returns the current partition scale info from ephemeral data.

implements heap.Interface, do not call directly

Possible returns a boolean indicating whether the transition is possible for the current state.

ReactivateVersionWorkflowIfPinned sends a reactivation signal to the version workflow when workflow execution options target a potentially DRAINED/INA

RecordCompleted applies the provided function to record activity completion

Remove pop a task from the task set

ReplaceCustomSearchAttributes replaces the existing custom search attribute fields with the provided ones. Nil/empty payload values are filtered. If `

ReplicationReaderIDToClusterShardID convert from reader ID to cluster ID & shard ID NOTE: see ReplicationReaderIDFromClusterShardID

ReplicationTaskPriorityTag returns a replication task priority tag.

ResendReplicationTasks requests replication tasks from remote cluster and apply tasks to current cluster.

ResourceServiceName returns the OpenTelemetry tracing service name for a Temporal service.

ScheduleStandbyCallbacks transitions all STANDBY callbacks to SCHEDULED state, triggering their invocation. Used by both workflows and standalone acti

SelectFromCurrentExecutions returns one or more rows from current_executions table Required params - {shardID, namespaceID, workflowID, archetypeID}

NOTE: DO NOT MODIFY UNLESS ALSO APPLIED TO ./service/frontend/token_deprecated.go

SetPrincipal sets the principal type and name headers in the incoming metadata.

SetRateLimiter sets the rate limiter to delegate to.

ShardRangeID returns tag for ShardRangeID

SpanExportersFromEnv creates OTEL span exporters from environment variables.

Stops workers. Note that this does not wait for workers to exit. When Stop is called, concurrent calls to Do may or may not call their function, and f

StoreOrSelf returns the store for the activity. If the store is not set as a field (e.g. standalone activities), it returns the activity itself.

Submit is a blocking call that accepts a task to execute

SubmitClosedWorkflowSnapshot closes the current mutable state transaction with the given transactionPolicy and updates the workflow execution record i

SysStackTrace returns tag for SysStackTrace

TaskByID returns the registrable task for a given task type ID. This method should only be used by CHASM framework internal code, NOT CHASM library de

TaskCount returns the number of outstanding tasks in the executor

TaskFqnByID converts task type ID to fully qualified task type name. This method should only be used by CHASM framework internal code, NOT CHASM libra

TearDownWorkflowStore to cleanup

ToBuildIdOrderingResponse transforms the internal VersioningData representation to public representation. If maxSets is given, the last sets up to max

Trailer mocks base method.