CancelNexusOperation cancels a Nexus operation on the __temporal_system endpoint.

ClearTransactionState resets all transition outputs in the tree. This should be called at the end of every transaction where the transitions are perfo

ConvertWhereOrderBy transforms WHERE SQL statement to Elasticsearch query. It also supports ORDER BY clause.

DescribeHistoryHost returns information about the internal states of a history host

FromClusterIDTag returns a new from cluster tag.

GetRoutingKeyFromContext retrieves the routing Key from the context. Returns a zero-value RoutingKey if not found.

InsertIntoVisibility inserts a row into visibility table. If a row already exist, no changes will be made by this API

IsVersionHistoryItemsInSameBranch checks if two version history items are in the same branch

implements heap.Interface, do not call directly

Scan operations

ListExecutions lists the executions of a CHASM archetype given an initial query. The query string can specify any combination of CHASM, custom, and pr

MethodName returns just the method name from a fully qualified name.

NewContextMetadataInterceptor creates a new ContextMetadataInterceptor

NewDisabledArchvialConfig returns an ArchivalConfig where archival is disabled for both the cluster and the namespace

NewGlobalTypedSettingWithConverter creates a setting with a custom converter function.

NewMockTaskGenerator creates a new mock instance.

NewOperationHandle gets a handle to an asynchronous operation by name and token. Does not incur a trip to the server. Fails if provided an empty opera

NewSQLAdminDB returns a AdminDB.

NewTaskStore returns a new task store

NewThrottledLogger returns an implementation of logger that throttles the log messages being emitted. The underlying implementation uses a token bucke

NexusFailureToTemporalFailure converts a Nexus Failure to an API proto Failure. If the failure metadata "type" field is set to the fullname of the tem

ParentPartition returns a NormalPartition for the parent partition, using the given branching degree.

Rate returns the rate per second for this rate limiter

Write APIs.

RegisterTaskSerializer registers a [TaskSerializer] for a given type. Returns an [ErrDuplicateRegistration] if a serializer for this task type has alr

RunLegacySequential behaves like [Run] but does not mark any test as parallel. Deprecated: use [Run] for new tests. This only exists for backwards-co

SelectFromNamespace returns namespaces that match filter criteria. Either ID or Name can be specified to filter results. If both are not specified, al

general Service returns tag for Service

SetCurrentTime set the current time, and additionally fire the fire chan if new "current" time is after the next wakeup time, return true if "current"

StartAdminBatchOperation starts an admin batch operation. Supports internal operations like RefreshWorkflowTasks.

StartOperation is the type safe version of [HTTPClient.StartOperation]. It accepts input of type I and returns a [ClientStartOperationResponse] of typ

ToClusterIDTag returns a new to cluster tag.

Type gives the type of db (e.g. "cassandra", "sql")

Walk applies the given function to all nodes rooted at the current node. Returns after successfully applying the function to all nodes or first error.

WorkflowTaskQueueType returns tag for WorkflowTaskQueueType

revive:disable-next-line:cognitive-complexity

Creates a mutable state with first WFT completed on the given deployment and behavior set to the given behavior, testing expected output after Add, St

deserialize initializes the node's value from its serializedNode. If a value is of the component type, it initializes every chasm.Field of it and sets

errorType returns tag for ErrorType given a string

expectWatchAndList sets up common mock expectations for WatchNamespaces and ListNamespaces.

findTerminalBuildId follows redirect rules from the given build ID and returns the target of the last redirect rule. Returns empty if a cycle is found

getMutableState loads the persistence-layer mutable state for a workflow run. Mirrors the helper in timeskipping_test.go to keep this file self-contai

revive:disable:cyclomatic grandfathered

isQuery returns true if the underlying task is a query task