Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/temporalio/temporal
/ functions
Functions
43,335 in github.com/temporalio/temporal
⨍
Functions
43,335
◇
Types & classes
5,614
↓ 1 callers
Function
AddV31VersioningInfoToV32
We store versioning info in the modern v0.32 format, so call this before returning the object to readers to mutatively populate the missing fields.
common/worker_versioning/worker_versioning.go:1078
↓ 1 callers
Function
AddVersionHistory
AddVersionHistory adds a VersionHistory to VersionHistories. Returns: - the index of the newly added VersionHistory - error if any
common/persistence/versionhistory/version_histories.go:61
↓ 1 callers
Method
AddWorkerCommandsTasks
(commands []*workerpb.WorkerCommand, controlQueue string)
service/history/workflow/mutable_state_impl.go:4673
↓ 1 callers
Method
AddWorkflowExecutionOptionsUpdatedEvent
( versioningOverride *workflowpb.VersioningOverride, unsetVersioningOverride bool, attachRequestID string,
service/history/historybuilder/history_builder.go:468
↓ 1 callers
Method
AddWorkflowExecutionSignaledEvent
( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, externalWorkflow
service/history/workflow/mutable_state_impl.go:6131
↓ 1 callers
Method
AddWorkflowExecutionSignaledEvent
( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, externalWorkflow
service/history/historybuilder/history_builder.go:748
↓ 1 callers
Method
AddWorkflowExecutionTimeSkippingTransitionedEvent
AddWorkflowExecutionTimeSkippingTransitionedEvent adds a workflow execution time skipping transitioned event to the mutable state. This should only be
service/history/workflow/mutable_state_impl.go:4155
↓ 1 callers
Method
AddWorkflowTaskScheduledEvent
( bypassTaskGeneration bool, workflowTaskType enumsspb.WorkflowTaskType, )
service/history/workflow/mutable_state_impl.go:3458
↓ 1 callers
Method
AddWorkflowTaskScheduledEvent
AddWorkflowTaskScheduledEvent adds a WorkflowTaskScheduled event to the mutable state and generates a transfer task unless bypassTaskGeneration is spe
service/history/workflow/workflow_task_state_machine.go:407
↓ 1 callers
Method
AddWorkflowTaskScheduledEventAsHeartbeat
AddWorkflowTaskScheduledEventAsHeartbeat records the first scheduled workflow task during workflow task heartbeat. If bypassTaskGeneration is specifie
service/history/workflow/workflow_task_state_machine.go:306
↓ 1 callers
Function
AdminBatchRefreshWorkflowTasks
AdminBatchRefreshWorkflowTasks starts a batch job to refresh workflow tasks for multiple workflows
tools/tdbg/commands.go:749
↓ 1 callers
Method
AdminClient
()
tests/testcore/functional_test_base.go:229
↓ 1 callers
Function
AdminDecodeBase64
(c *cli.Context)
tools/tdbg/decode_commands.go:81
↓ 1 callers
Function
AdminDecodeProto
(c *cli.Context)
tools/tdbg/decode_commands.go:15
↓ 1 callers
Function
AdminDeleteWorkflow
AdminDeleteWorkflow force deletes a workflow's mutable state (both concrete and current), history, and visibility records as long as it's possible. It
tools/tdbg/commands.go:380
↓ 1 callers
Function
AdminDescribeExecution
AdminDescribeExecution describes a Temporal execution (CHASM tree or workflow).
tools/tdbg/commands.go:263
↓ 1 callers
Function
AdminDescribeHistoryHost
AdminDescribeHistoryHost describes history host
tools/tdbg/commands.go:649
↓ 1 callers
Function
AdminDescribeShard
AdminDescribeShard describes shard by shard id
tools/tdbg/commands.go:557
↓ 1 callers
Function
AdminDescribeTaskQueuePartition
AdminDescribeTaskQueuePartition displays task queue partition information
tools/tdbg/task_queue_commands.go:95
↓ 1 callers
Function
AdminForceUnloadTaskQueuePartition
AdminForceUnloadTaskQueuePartition forcefully unloads a task queue partition
tools/tdbg/task_queue_commands.go:230
↓ 1 callers
Function
AdminGetShardID
AdminGetShardID get shardID
tools/tdbg/commands.go:429
↓ 1 callers
Function
AdminGetTaskQueueUserData
AdminGetTaskQueueUserData returns the per-type user data for a task queue partition
tools/tdbg/task_queue_commands.go:186
↓ 1 callers
Function
AdminImportWorkflow
AdminImportWorkflow imports history
tools/tdbg/commands.go:163
↓ 1 callers
Function
AdminListClusterMembers
AdminListClusterMembers outputs a list of cluster members
tools/tdbg/commands.go:619
↓ 1 callers
Function
AdminListGossipMembers
AdminListGossipMembers outputs a list of gossip members
tools/tdbg/commands.go:591
↓ 1 callers
Function
AdminListShardTasks
AdminListShardTasks outputs a list of a tasks for given Shard and Task Category
tools/tdbg/commands.go:457
↓ 1 callers
Function
AdminListTaskQueueTasks
AdminListTaskQueueTasks displays task information
tools/tdbg/task_queue_commands.go:15
↓ 1 callers
Function
AdminMigrateSchedule
AdminMigrateSchedule migrates schedules between V1 (workflow-backed) and V2 (CHASM). It supports three mutually-exclusive selection modes, all sharin
tools/tdbg/commands.go:889
↓ 1 callers
Function
AdminRebuildMutableState
AdminRebuildMutableState rebuild a workflow mutable state using persisted history events
tools/tdbg/commands.go:809
↓ 1 callers
Function
AdminRefreshWorkflowTasks
AdminRefreshWorkflowTasks refreshes all the tasks of a workflow
tools/tdbg/commands.go:708
↓ 1 callers
Function
AdminRemoveTask
AdminRemoveTask describes history host
tools/tdbg/commands.go:518
↓ 1 callers
Function
AdminReplicateWorkflow
AdminReplicateWorkflow force replicates a workflow by generating replication tasks
tools/tdbg/commands.go:842
↓ 1 callers
Function
AdminShardManagement
AdminShardManagement describes history host
tools/tdbg/commands.go:573
↓ 1 callers
Function
AdminShowWorkflow
AdminShowWorkflow shows history
tools/tdbg/commands.go:46
↓ 1 callers
Method
AfterFunc
AfterFunc is a pass-through to time.AfterFunc.
common/clock/time_source.go:48
↓ 1 callers
Method
Aggregation
Aggregation implements metric.Exporter
common/metrics/statsd_exporter.go:68
↓ 1 callers
Method
Alias
Alias returns the alias for a given field.
chasm/visibility.go:59
↓ 1 callers
Method
Allocate
Allocate allocates the shared database in the pool or returns already exists instance with the same DSN. If instance for such DSN already exists, it w
common/persistence/sql/sqlplugin/sqlite/conn_pool.go:33
↓ 1 callers
Method
Allow
()
common/circuitbreaker/circuitbreaker.go:16
↓ 1 callers
Method
Allow
()
common/circuitbreaker/circuitbreaker.go:85
↓ 1 callers
Method
Allow
( namespaceName namespace.Name, methodName string, mh metrics.Handler, req any, )
common/rpc/interceptor/concurrent_request_limit.go:86
↓ 1 callers
Method
Allow
( methodName string, headerGetter headers.HeaderGetter, )
common/rpc/interceptor/rate_limit.go:67
↓ 1 callers
Method
Allow
(namespaceName namespace.Name, methodName string, headerGetter headers.HeaderGetter)
common/rpc/interceptor/namespace_rate_limit.go:142
↓ 1 callers
Method
AllowN
AllowN immediately returns with true or false indicating if n rate limit token is available or not
common/quotas/multi_rate_limiter_impl.go:47
↓ 1 callers
Method
AppendHistoryEvents
(ctx context.Context, request *persistence.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *com
service/history/interfaces/shard_context.go:86
↓ 1 callers
Method
ApplicationFailure
()
common/testing/testvars/any.go:65
↓ 1 callers
Method
Apply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:139
↓ 1 callers
Method
Apply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:164
↓ 1 callers
Method
Apply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:199
↓ 1 callers
Method
Apply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:231
↓ 1 callers
Method
Apply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:262
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:119
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:149
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:181
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:215
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:253
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:291
↓ 1 callers
Method
Apply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:329
↓ 1 callers
Method
ApplyActivityTaskCancelRequestedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4751
↓ 1 callers
Method
ApplyActivityTaskCanceledEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4830
↓ 1 callers
Method
ApplyActivityTaskCompletedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4517
↓ 1 callers
Method
ApplyActivityTaskFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4567
↓ 1 callers
Method
ApplyActivityTaskScheduledEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4234
↓ 1 callers
Method
ApplyActivityTaskTimedOutEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4619
↓ 1 callers
Method
ApplyBuildIdRedirect
(startingTaskScheduledEventId int64, buildId string, redirectCounter int64)
service/history/interfaces/mutable_state.go:301
↓ 1 callers
Method
ApplyBuildIdRedirect
ApplyBuildIdRedirect applies possible redirect to mutable state based on versioning stamp of a starting task. If a redirect is applicable, assigned bu
service/history/workflow/mutable_state_impl.go:3647
↓ 1 callers
Method
ApplyChildWorkflowExecutionCanceledEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6663
↓ 1 callers
Method
ApplyChildWorkflowExecutionCompletedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6566
↓ 1 callers
Method
ApplyChildWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6615
↓ 1 callers
Method
ApplyChildWorkflowExecutionStartedEvent
( event *historypb.HistoryEvent, clock *clockspb.VectorClock, )
service/history/workflow/mutable_state_impl.go:6455
↓ 1 callers
Method
ApplyChildWorkflowExecutionTerminatedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6709
↓ 1 callers
Method
ApplyChildWorkflowExecutionTimedOutEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6757
↓ 1 callers
Function
ApplyClusterMetadataConfigProvider
ApplyClusterMetadataConfigProvider performs a config check against the configured persistence store for cluster metadata. If there is a mismatch, the
temporal/fx.go:608
↓ 1 callers
Method
ApplyDefaults
ApplyDefaults copies database configuration from src, preserving any non-zero values already set.
common/persistence/persistence-tests/persistence_test_base.go:68
↓ 1 callers
Method
ApplyExternalWorkflowExecutionCancelRequested
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5142
↓ 1 callers
Method
ApplyExternalWorkflowExecutionSignaled
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5337
↓ 1 callers
Method
ApplyMutation
(mutation *persistencespb.WorkflowMutableStateMutation)
service/history/interfaces/mutable_state.go:239
↓ 1 callers
Method
ApplyMutation
ApplyMutation is used by replication stack to apply node mutations from the source cluster. NOTE: It will be an error if UpdatedNodes and DeletedNode
chasm/tree.go:2441
↓ 1 callers
Method
ApplyRequestCancelExternalWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5187
↓ 1 callers
Method
ApplyRequestCancelExternalWorkflowExecutionInitiatedEvent
( batchID int64, event *historypb.HistoryEvent, cancelRequestID string, )
service/history/workflow/mutable_state_impl.go:5085
↓ 1 callers
Function
ApplySchemaUpdate
(t *testing.T, cfg *config.Cassandra, schemaFile string, logger log.Logger)
common/persistence/tests/cassandra_test_util.go:108
↓ 1 callers
Method
ApplySignalExternalWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5384
↓ 1 callers
Method
ApplySignalExternalWorkflowExecutionInitiatedEvent
( batchID int64, event *historypb.HistoryEvent, signalRequestID string, )
service/history/workflow/mutable_state_impl.go:5220
↓ 1 callers
Method
ApplySnapshot
(snapshot *persistencespb.WorkflowMutableState)
service/history/interfaces/mutable_state.go:240
↓ 1 callers
Method
ApplyStartChildWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6518
↓ 1 callers
Method
ApplyStartChildWorkflowExecutionInitiatedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6390
↓ 1 callers
Method
ApplyTimerCanceledEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5526
↓ 1 callers
Method
ApplyTimerFiredEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5472
↓ 1 callers
Method
ApplyTimerStartedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5419
↓ 1 callers
Method
ApplyUpsertWorkflowSearchAttributesEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5261
↓ 1 callers
Method
ApplyWorkflowExecutionCancelRequestedEvent
( _ *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5011
↓ 1 callers
Method
ApplyWorkflowExecutionCanceledEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5042
↓ 1 callers
Method
ApplyWorkflowExecutionCompletedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4864
↓ 1 callers
Method
ApplyWorkflowExecutionContinuedAsNewEvent
( batchID int64, continueAsNewEvent *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6335
↓ 1 callers
Method
ApplyWorkflowExecutionFailedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4908
↓ 1 callers
Method
ApplyWorkflowExecutionOptionsUpdatedEvent
(event *historypb.HistoryEvent)
service/history/workflow/mutable_state_impl.go:5886
↓ 1 callers
Method
ApplyWorkflowExecutionPausedEvent
(event *historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:231
↓ 1 callers
Method
ApplyWorkflowExecutionPausedEvent
ApplyWorkflowExecutionPausedEvent applies the paused event to the mutable state. It updates the workflow execution status to paused and sets the pause
service/history/workflow/mutable_state_impl.go:3220
↓ 1 callers
Method
ApplyWorkflowExecutionSignaled
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6160
↓ 1 callers
Method
ApplyWorkflowExecutionStartedEvent
( parentClock *clockspb.VectorClock, execution *commonpb.WorkflowExecution, requestID string, startEvent *
service/history/workflow/mutable_state_impl.go:2960
← previous
next →
9,201–9,300 of 43,335, ranked by callers