MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersFunctionAddV31VersioningInfoToV32
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 callersFunctionAddVersionHistory
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 callersMethodAddWorkerCommandsTasks
(commands []*workerpb.WorkerCommand, controlQueue string)
service/history/workflow/mutable_state_impl.go:4673
↓ 1 callersMethodAddWorkflowExecutionOptionsUpdatedEvent
( versioningOverride *workflowpb.VersioningOverride, unsetVersioningOverride bool, attachRequestID string,
service/history/historybuilder/history_builder.go:468
↓ 1 callersMethodAddWorkflowExecutionSignaledEvent
( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, externalWorkflow
service/history/workflow/mutable_state_impl.go:6131
↓ 1 callersMethodAddWorkflowExecutionSignaledEvent
( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, externalWorkflow
service/history/historybuilder/history_builder.go:748
↓ 1 callersMethodAddWorkflowExecutionTimeSkippingTransitionedEvent
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 callersMethodAddWorkflowTaskScheduledEvent
( bypassTaskGeneration bool, workflowTaskType enumsspb.WorkflowTaskType, )
service/history/workflow/mutable_state_impl.go:3458
↓ 1 callersMethodAddWorkflowTaskScheduledEvent
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 callersMethodAddWorkflowTaskScheduledEventAsHeartbeat
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 callersFunctionAdminBatchRefreshWorkflowTasks
AdminBatchRefreshWorkflowTasks starts a batch job to refresh workflow tasks for multiple workflows
tools/tdbg/commands.go:749
↓ 1 callersMethodAdminClient
()
tests/testcore/functional_test_base.go:229
↓ 1 callersFunctionAdminDecodeBase64
(c *cli.Context)
tools/tdbg/decode_commands.go:81
↓ 1 callersFunctionAdminDecodeProto
(c *cli.Context)
tools/tdbg/decode_commands.go:15
↓ 1 callersFunctionAdminDeleteWorkflow
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 callersFunctionAdminDescribeExecution
AdminDescribeExecution describes a Temporal execution (CHASM tree or workflow).
tools/tdbg/commands.go:263
↓ 1 callersFunctionAdminDescribeHistoryHost
AdminDescribeHistoryHost describes history host
tools/tdbg/commands.go:649
↓ 1 callersFunctionAdminDescribeShard
AdminDescribeShard describes shard by shard id
tools/tdbg/commands.go:557
↓ 1 callersFunctionAdminDescribeTaskQueuePartition
AdminDescribeTaskQueuePartition displays task queue partition information
tools/tdbg/task_queue_commands.go:95
↓ 1 callersFunctionAdminForceUnloadTaskQueuePartition
AdminForceUnloadTaskQueuePartition forcefully unloads a task queue partition
tools/tdbg/task_queue_commands.go:230
↓ 1 callersFunctionAdminGetShardID
AdminGetShardID get shardID
tools/tdbg/commands.go:429
↓ 1 callersFunctionAdminGetTaskQueueUserData
AdminGetTaskQueueUserData returns the per-type user data for a task queue partition
tools/tdbg/task_queue_commands.go:186
↓ 1 callersFunctionAdminImportWorkflow
AdminImportWorkflow imports history
tools/tdbg/commands.go:163
↓ 1 callersFunctionAdminListClusterMembers
AdminListClusterMembers outputs a list of cluster members
tools/tdbg/commands.go:619
↓ 1 callersFunctionAdminListGossipMembers
AdminListGossipMembers outputs a list of gossip members
tools/tdbg/commands.go:591
↓ 1 callersFunctionAdminListShardTasks
AdminListShardTasks outputs a list of a tasks for given Shard and Task Category
tools/tdbg/commands.go:457
↓ 1 callersFunctionAdminListTaskQueueTasks
AdminListTaskQueueTasks displays task information
tools/tdbg/task_queue_commands.go:15
↓ 1 callersFunctionAdminMigrateSchedule
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 callersFunctionAdminRebuildMutableState
AdminRebuildMutableState rebuild a workflow mutable state using persisted history events
tools/tdbg/commands.go:809
↓ 1 callersFunctionAdminRefreshWorkflowTasks
AdminRefreshWorkflowTasks refreshes all the tasks of a workflow
tools/tdbg/commands.go:708
↓ 1 callersFunctionAdminRemoveTask
AdminRemoveTask describes history host
tools/tdbg/commands.go:518
↓ 1 callersFunctionAdminReplicateWorkflow
AdminReplicateWorkflow force replicates a workflow by generating replication tasks
tools/tdbg/commands.go:842
↓ 1 callersFunctionAdminShardManagement
AdminShardManagement describes history host
tools/tdbg/commands.go:573
↓ 1 callersFunctionAdminShowWorkflow
AdminShowWorkflow shows history
tools/tdbg/commands.go:46
↓ 1 callersMethodAfterFunc
AfterFunc is a pass-through to time.AfterFunc.
common/clock/time_source.go:48
↓ 1 callersMethodAggregation
Aggregation implements metric.Exporter
common/metrics/statsd_exporter.go:68
↓ 1 callersMethodAlias
Alias returns the alias for a given field.
chasm/visibility.go:59
↓ 1 callersMethodAllocate
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 callersMethodAllow
()
common/circuitbreaker/circuitbreaker.go:16
↓ 1 callersMethodAllow
()
common/circuitbreaker/circuitbreaker.go:85
↓ 1 callersMethodAllow
( namespaceName namespace.Name, methodName string, mh metrics.Handler, req any, )
common/rpc/interceptor/concurrent_request_limit.go:86
↓ 1 callersMethodAllow
( methodName string, headerGetter headers.HeaderGetter, )
common/rpc/interceptor/rate_limit.go:67
↓ 1 callersMethodAllow
(namespaceName namespace.Name, methodName string, headerGetter headers.HeaderGetter)
common/rpc/interceptor/namespace_rate_limit.go:142
↓ 1 callersMethodAllowN
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 callersMethodAppendHistoryEvents
(ctx context.Context, request *persistence.AppendHistoryNodesRequest, namespaceID namespace.ID, execution *com
service/history/interfaces/shard_context.go:86
↓ 1 callersMethodApplicationFailure
()
common/testing/testvars/any.go:65
↓ 1 callersMethodApply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:139
↓ 1 callersMethodApply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:164
↓ 1 callersMethodApply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:199
↓ 1 callersMethodApply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:231
↓ 1 callersMethodApply
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:262
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:119
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:149
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:181
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:215
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:253
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:291
↓ 1 callersMethodApply
(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent)
chasm/lib/workflow/nexus_events.go:329
↓ 1 callersMethodApplyActivityTaskCancelRequestedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4751
↓ 1 callersMethodApplyActivityTaskCanceledEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4830
↓ 1 callersMethodApplyActivityTaskCompletedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4517
↓ 1 callersMethodApplyActivityTaskFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4567
↓ 1 callersMethodApplyActivityTaskScheduledEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4234
↓ 1 callersMethodApplyActivityTaskTimedOutEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4619
↓ 1 callersMethodApplyBuildIdRedirect
(startingTaskScheduledEventId int64, buildId string, redirectCounter int64)
service/history/interfaces/mutable_state.go:301
↓ 1 callersMethodApplyBuildIdRedirect
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 callersMethodApplyChildWorkflowExecutionCanceledEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6663
↓ 1 callersMethodApplyChildWorkflowExecutionCompletedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6566
↓ 1 callersMethodApplyChildWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6615
↓ 1 callersMethodApplyChildWorkflowExecutionStartedEvent
( event *historypb.HistoryEvent, clock *clockspb.VectorClock, )
service/history/workflow/mutable_state_impl.go:6455
↓ 1 callersMethodApplyChildWorkflowExecutionTerminatedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6709
↓ 1 callersMethodApplyChildWorkflowExecutionTimedOutEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6757
↓ 1 callersFunctionApplyClusterMetadataConfigProvider
ApplyClusterMetadataConfigProvider performs a config check against the configured persistence store for cluster metadata. If there is a mismatch, the
temporal/fx.go:608
↓ 1 callersMethodApplyDefaults
ApplyDefaults copies database configuration from src, preserving any non-zero values already set.
common/persistence/persistence-tests/persistence_test_base.go:68
↓ 1 callersMethodApplyExternalWorkflowExecutionCancelRequested
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5142
↓ 1 callersMethodApplyExternalWorkflowExecutionSignaled
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5337
↓ 1 callersMethodApplyMutation
(mutation *persistencespb.WorkflowMutableStateMutation)
service/history/interfaces/mutable_state.go:239
↓ 1 callersMethodApplyMutation
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 callersMethodApplyRequestCancelExternalWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5187
↓ 1 callersMethodApplyRequestCancelExternalWorkflowExecutionInitiatedEvent
( batchID int64, event *historypb.HistoryEvent, cancelRequestID string, )
service/history/workflow/mutable_state_impl.go:5085
↓ 1 callersFunctionApplySchemaUpdate
(t *testing.T, cfg *config.Cassandra, schemaFile string, logger log.Logger)
common/persistence/tests/cassandra_test_util.go:108
↓ 1 callersMethodApplySignalExternalWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5384
↓ 1 callersMethodApplySignalExternalWorkflowExecutionInitiatedEvent
( batchID int64, event *historypb.HistoryEvent, signalRequestID string, )
service/history/workflow/mutable_state_impl.go:5220
↓ 1 callersMethodApplySnapshot
(snapshot *persistencespb.WorkflowMutableState)
service/history/interfaces/mutable_state.go:240
↓ 1 callersMethodApplyStartChildWorkflowExecutionFailedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6518
↓ 1 callersMethodApplyStartChildWorkflowExecutionInitiatedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6390
↓ 1 callersMethodApplyTimerCanceledEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5526
↓ 1 callersMethodApplyTimerFiredEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5472
↓ 1 callersMethodApplyTimerStartedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5419
↓ 1 callersMethodApplyUpsertWorkflowSearchAttributesEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5261
↓ 1 callersMethodApplyWorkflowExecutionCancelRequestedEvent
( _ *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5011
↓ 1 callersMethodApplyWorkflowExecutionCanceledEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5042
↓ 1 callersMethodApplyWorkflowExecutionCompletedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4864
↓ 1 callersMethodApplyWorkflowExecutionContinuedAsNewEvent
( batchID int64, continueAsNewEvent *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6335
↓ 1 callersMethodApplyWorkflowExecutionFailedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4908
↓ 1 callersMethodApplyWorkflowExecutionOptionsUpdatedEvent
(event *historypb.HistoryEvent)
service/history/workflow/mutable_state_impl.go:5886
↓ 1 callersMethodApplyWorkflowExecutionPausedEvent
(event *historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:231
↓ 1 callersMethodApplyWorkflowExecutionPausedEvent
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 callersMethodApplyWorkflowExecutionSignaled
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6160
↓ 1 callersMethodApplyWorkflowExecutionStartedEvent
( parentClock *clockspb.VectorClock, execution *commonpb.WorkflowExecution, requestID string, startEvent *
service/history/workflow/mutable_state_impl.go:2960
← previousnext →9,201–9,300 of 43,335, ranked by callers