OverrideDynamicConfig overrides a dynamic config setting for the duration of this test. For settings that can be namespace-scoped, a namespace constra

ParseDurationDefaultDays is like time.ParseDuration, but supports unit "d" for days (always interpreted as exactly 24 hours), and also supports unit-l

PickFinalCurrentAndRamping determines the effective "current" and "ramping" deployment versions by comparing timestamps from the legacy deployment dat

PickReadPartition returns the task queue partition to send a poller to. Input is name of the original task queue as specified by caller. When forwarde

PickWritePartition returns the task queue partition for adding an activity or workflow task. The input is the name of the original task queue (with no

Pop pop an item from priority queue, used by go internal heap implementation

Predefined returns a clone of the predefined search attributes map.

PredefinedWhiteList returns a clone of the predefined whitelist search attributes map.

ProcessCloseCallbacks triggers "WorkflowClosed" callbacks using the CHASM implementation. It schedules all workflow-level and update-level callbacks t

ProcessInput routes the input processing request to the appropriate operation processor and returns routing information for the operation. Returns a

ProcessInput routes the input processing request to the appropriate service processor and returns routing information for the operation. Returns a ne

ProcessTaskAdd is called for each Task addition (whether sync or async matching)

ProcessUpdateCallbacks triggers callbacks for a single updateID if exists.

ProtoRefToComponentRef converts a persistence ChasmComponentRef reference to a ComponentRef. This is useful for situations where the protobuf Componen

PublishToNamespaceDLQ is a utility method to add messages to the namespace DLQ

implements heap.Interface, do not call directly

Push push an item to priority queue, used by go internal heap implementation

Put adds an element to the cache.

QueueAlert returns tag for queue alert

RangeDeleteFromHistoryImmediateTasks deletes one or more rows from history_immediate_tasks table. HistoryImmediateTasksRangeFilter - {PageSize} will b

RangeDeleteFromScheduledTasks deletes one or more rows from history_scheduled_tasks table ScheduledTasksRangeFilter - {TaskID, PageSize} will be ignor

RangeDeleteMessagesFromNamespaceDLQ deletes messages from namespace DLQ

RangeSelectFromHistoryImmediateTasks returns rows that match filter criteria from history_immediate_tasks table.

RangeSelectFromScheduledTasks returns one or more rows from history_scheduled_tasks table

ReachabilityExitPointTag returns tag for reachabilityExitPoint

ReadFullPageEvents reads a full page of history events from ExecutionManager. Due to storage format of V2 History it is not guaranteed that pageSize a

ReadFullPageEventsByBatch reads a full page of history events by batch from ExecutionManager. Due to storage format of V2 History it is not guaranteed

ReadFullPageEventsReverse reads a full page of history events from ExecutionManager in reverse orcer. Due to storage format of V2 History it is not gu

ReadFullPageRawEvents reads a full page of raw history events from ExecutionManager. Due to storage format of V2 History it is not guaranteed that pag

ReadRawTasks returns a page of "raw" tasks from the queue. Here's a quick disambiguation of the different types of tasks: - [go.temporal.io/server/ap

ReadSchemaVersion returns the current schema version for the keyspace

RecordSDKInfo records name and version tuple in memory

RedirectionPolicyGenerator generate corresponding redirection policy

RegisterOperation registers a named operation with this service processor. Returns an error if an operation with the same name is already registered.

RegisterPlugin adds an auth plugin to the plugin registry it is only safe to use from a package init function

Used internally by the Worker Deployment workflow in its RegisterWorkerInVersion Activity to register a task-queue worker in a version.

RejectUpdate stores the rejection failure on the WorkflowUpdate component and fires any pending callbacks. This is used when a reapplied update (after

RejectWorkflowExecutionUpdate notifies the store that an update was rejected by the worker's validator. The store uses this to fire any completion cal