MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 1 callersMethoddeleteNamespaceLocalActivities
()
service/worker/deletenamespace/fx.go:112
↓ 1 callersFunctiondeleteRequestCancelInfoMap
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:357
↓ 1 callersMethoddeleteScheduleCHASM
(ctx context.Context, request *workflowservice.DeleteScheduleRequest)
service/frontend/workflow_handler.go:4963
↓ 1 callersMethoddeleteScheduleWorkflow
(ctx context.Context, request *workflowservice.DeleteScheduleRequest)
service/frontend/workflow_handler.go:4980
↓ 1 callersFunctiondeleteSignalInfoMap
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:448
↓ 1 callersFunctiondeleteSignalsRequestedSet
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_non_map.go:81
↓ 1 callersFunctiondeleteStateMachineTimersByPath
(execInfo *persistencespb.WorkflowExecutionInfo, path []hsm.Key)
service/history/workflow/task_generator.go:999
↓ 1 callersMethoddeleteTaskQueue
( ctx context.Context, key *p.TaskQueueKey, rangeID int64, )
service/worker/scanner/taskqueue/db.go:78
↓ 1 callersFunctiondeleteTimerInfoMap
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:176
↓ 1 callersMethoddeleteWorkflowExecution
(ctx context.Context)
service/history/replication/executable_delete_execution_task.go:142
↓ 1 callersMethoddeleteWorkflowExecutionFromVisibility
( ctx context.Context, nsID namespace.ID, nsName namespace.Name, execution *workflowpb.WorkflowExecutionIn
service/worker/deletenamespace/deleteexecutions/activities.go:252
↓ 1 callersFunctiondeleteWorkflowExecutions
(ctx workflow.Context, logger log.Logger, params ReclaimResourcesParams)
service/worker/deletenamespace/reclaimresources/workflow.go:204
↓ 1 callersFunctiondeletedNS
deletedNS builds a local namespace in the DELETED state, which ListAllNamespaces skips.
service/worker/scanner/scheduleinvariants/invariants_test.go:89
↓ 1 callersMethoddeploymentStateToDeploymentInfo
(deploymentName string, state *deploymentspb.WorkerDeploymentLocalState)
service/worker/workerdeployment/client.go:1769
↓ 1 callersMethoddequeueHistoryEventNotifications
()
service/history/events/notifier.go:214
↓ 1 callersMethoddequeueLocked
dequeueLocked dequeues a task from the pool's buffer. Must be called while holding the lock.
common/tasks/dynamic_worker_pool_scheduler.go:134
↓ 1 callersMethoddescribeLegacyTaskQueueStats
DescribeTaskQueue Legacy Mode shall report the stats for this task queue from all the different versions that the task queue is part of.
tests/task_queue_stats_test.go:1108
↓ 1 callersFunctiondescribeMutableState
(c *cli.Context, clientFactory ClientFactory)
tools/tdbg/commands.go:344
↓ 1 callersMethoddescribeNamespaceFromRegistry
describeNamespaceFromRegistry serves DescribeNamespace from the in-memory namespace registry. The response may be stale, and may return NamespaceNotFo
service/frontend/namespace_handler.go:350
↓ 1 callersMethoddescribeRequest
(id int32)
service/matching/scale_manager.go:304
↓ 1 callersMethoddescribeScheduleCHASM
(ctx context.Context, request *workflowservice.DescribeScheduleRequest)
service/frontend/workflow_handler.go:4351
↓ 1 callersMethoddescribeScheduleWorkflow
(ctx context.Context, request *workflowservice.DescribeScheduleRequest)
service/frontend/workflow_handler.go:4364
↓ 1 callersMethoddescribeWDVTaskQueueStats
( ctx context.Context, tqName string, tqType enumspb.TaskQueueType, deploymentName string, buildID string
tests/task_queue_stats_test.go:1082
↓ 1 callersFunctiondeserializeArchivalTask
( decoder Decoder, blob *commonpb.DataBlob, )
common/persistence/serialization/task_serializers.go:392
↓ 1 callersMethoddeserializeBackfillToken
( token []byte, )
service/history/ndc/mutable_state_initializer.go:228
↓ 1 callersMethoddeserializeBranchInfos
( historyTreeResp *InternalGetHistoryTreeContainingBranchResponse, )
common/persistence/history_manager.go:310
↓ 1 callersMethoddeserializeComponentNode
( valueT reflect.Type, )
chasm/tree.go:1254
↓ 1 callersMethoddeserializeDataNode
( valueT reflect.Type, )
chasm/tree.go:1322
↓ 1 callersFunctiondeserializeGetHistoryToken
(bytes []byte)
common/archiver/s3store/util.go:53
↓ 1 callersFunctiondeserializeMemo
(data *commonpb.DataBlob)
common/persistence/visibility/visibility_manager_impl.go:511
↓ 1 callersFunctiondeserializeOutboundTask
( decoder Decoder, blob *commonpb.DataBlob, )
common/persistence/serialization/task_serializers.go:1507
↓ 1 callersMethoddeserializePointerNode
deserializePointerNode doesn't deserialize anything but named this way for consistency.
chasm/tree.go:1336
↓ 1 callersFunctiondeserializeQueryVisibilityToken
(bytes []byte)
common/archiver/gcloud/util.go:111
↓ 1 callersFunctiondeserializeQueryVisibilityToken
(bytes []byte)
common/archiver/filestore/util.go:155
↓ 1 callersFunctiondeserializeQueryVisibilityToken
(bytes []byte)
common/archiver/s3store/util.go:59
↓ 1 callersFunctiondeserializeReplicationTask
( decoder Decoder, blob *commonpb.DataBlob, )
common/persistence/serialization/task_serializers.go:327
↓ 1 callersFunctiondeserializeTimerTask
( decoder Decoder, blob *commonpb.DataBlob, )
common/persistence/serialization/task_serializers.go:200
↓ 1 callersFunctiondeserializeTransferTask
( decoder Decoder, blob *commonpb.DataBlob, )
common/persistence/serialization/task_serializers.go:61
↓ 1 callersFunctiondeserializeVisibilityTask
( decoder Decoder, blob *commonpb.DataBlob, )
common/persistence/serialization/task_serializers.go:289
↓ 1 callersMethoddetected
(name string)
common/deadlock/deadlock.go:111
↓ 1 callersFunctiondfs
(curr string, visited, inStack map[string]bool, nodes map[string][]string)
service/matching/version_rule_helpers.go:518
↓ 1 callersFunctiondialHello
(s *suite.Suite, hostport string, clientFactory *TestFactory, serverType ServerUsageType)
common/rpc/test/rpc_common_test.go:131
↓ 1 callersFunctiondiffAndLogConstraints
(logger log.Logger, key Key, oldValues []ConstrainedValue, newValues []ConstrainedValue)
common/dynamicconfig/client_diff.go:49
↓ 1 callersFunctiondiffLists
(listA, listB any)
common/testing/protoassert/testify_assert.go:33
↓ 1 callersFunctiondirToVersion
(dir string)
tools/common/schema/updatetask.go:429
↓ 1 callersMethoddirtyHSMToReplicationTask
( transactionPolicy historyi.TransactionPolicy, eventBatches [][]*historypb.HistoryEvent, clearBufferEvents
service/history/workflow/mutable_state_impl.go:8522
↓ 1 callersMethoddisableEagerDispatch
( request *workflowservice.RespondWorkflowTaskCompletedRequest, )
service/frontend/overrides.go:37
↓ 1 callersMethoddisablingTransitionHistory
()
service/history/workflow/mutable_state_impl.go:9612
↓ 1 callersMethoddispatchActivityCompatible
(env *testcore.TestEnv)
tests/versioning_test.go:2323
↓ 1 callersMethoddispatchHistoryEventNotification
(event *Notification)
service/history/events/notifier.go:180
↓ 1 callersMethoddispatchNewWorkflowStartWorkerFirst
(env *testcore.TestEnv)
tests/versioning_test.go:1555
↓ 1 callersMethoddispatchNexusTask
( ctx context.Context, pc PartitionCounts, request *matchingservice.DispatchNexusTaskRequest, opts []grpc.
client/matching/client.go:368
↓ 1 callersMethoddispatchRetry
(env *testcore.TestEnv)
tests/versioning_test.go:3433
↓ 1 callersMethoddispatchRetryOld
(env *testcore.TestEnv)
tests/versioning_test.go:3321
↓ 1 callersMethoddispatchTasksWithWeight
()
common/tasks/interleaved_weighted_round_robin.go:328
↓ 1 callersMethoddispatchToWorker
( ctx context.Context, task *tasks.WorkerCommandsTask, namespaceName string, )
service/history/worker_commands_task_dispatcher.go:116
↓ 1 callersMethoddispatchUnversionedRemainsUnversioned
(env *testcore.TestEnv)
tests/versioning_test.go:1594
↓ 1 callersMethoddispatchWorkflowUpdateAsZombie
( ctx context.Context, isWorkflowRebuilt bool, currentWorkflow Workflow, targetWorkflow Workflow, newWork
service/history/ndc/transaction_manager_existing_workflow.go:183
↓ 1 callersMethoddoAddAssignmentRule
( env *testcore.TestEnv, tq string, rule *taskqueuepb.BuildIdAssignmentRule, )
tests/versioning_test.go:4802
↓ 1 callersMethoddoCleanup
()
common/tasks/interleaved_weighted_round_robin.go:209
↓ 1 callersMethoddoCleanups
doCleanups runs queued cleanup callbacks in LIFO order (matches *testing.T.Cleanup).
tests/testcore/shared_cluster_t.go:144
↓ 1 callersFunctiondoCreateKeyspace
(cfg *CQLClientConfig, name string, logger log.Logger)
tools/cassandra/handler.go:126
↓ 1 callersMethoddoDispatchTaskDirectly
( task T, )
common/tasks/interleaved_weighted_round_robin.go:361
↓ 1 callersMethoddoDispatchTasksWithWeight
( channels WeightedChannels[T], )
common/tasks/interleaved_weighted_round_robin.go:342
↓ 1 callersFunctiondoDropKeyspace
(cfg *CQLClientConfig, name string, logger log.Logger)
tools/cassandra/handler.go:136
↓ 1 callersMethoddoGC
called in new goroutine
service/matching/fair_task_reader.go:686
↓ 1 callersMethoddoGC
called in new goroutine
service/matching/pri_task_reader.go:517
↓ 1 callersMethoddoLinger
(ctx context.Context, shard historyi.ControllableContext)
service/history/shard/controller_impl.go:347
↓ 1 callersMethoddoShutdown
()
service/history/shard/controller_impl.go:536
↓ 1 callersMethoddoesVersionHaveActivePollers
doesVersionHaveActivePollers returns true if the version has active pollers.
service/worker/workerdeployment/version_workflow.go:662
↓ 1 callersMethoddone
(ack bool, metricsHandler metrics.Handler)
common/persistence/visibility/store/elasticsearch/processor.go:417
↓ 1 callersFunctiondownloadAndBuildOmes
(t *testing.T, workDir string)
tests/mixedbrain/build_util.go:118
↓ 1 callersFunctiondownloadAndBuildReleaseServer
downloadAndBuildReleaseServer finds the highest patch of the previous minor version, clones the repo at that tag, and builds the server binary. For ex
tests/mixedbrain/build_util.go:88
↓ 1 callersFunctiondownloadArtifact
downloadArtifact downloads a single artifact zip file
tools/flakereport/github.go:112
↓ 1 callersFunctiondownloadArtifacts
downloadArtifacts uses gh CLI to find the latest successful runs and download matching artifacts. Returns the path to a temp directory containing the
tools/optimize-test-sharding/main.go:115
↓ 1 callersFunctiondrainChannel
(ch <-chan T)
common/membership/ringpop/monitor_test.go:239
↓ 1 callersMethoddrainTaskRequests
()
service/history/shard/task_key_manager.go:68
↓ 1 callersMethoddropAllTablesTypes
dropAllTablesTypes deletes all tables/types in the Keyspace without deleting the Keyspace
tools/cassandra/cqlclient.go:259
↓ 1 callersMethoddropTable
dropTable drops a given table from the Keyspace
tools/cassandra/cqlclient.go:248
↓ 1 callersMethoddropType
dropType drops a given type from the Keyspace
tools/cassandra/cqlclient.go:253
↓ 1 callersFunctiondumpChasmTree
(resp *adminservice.DescribeMutableStateResponse, c *cli.Context)
tools/tdbg/commands.go:321
↓ 1 callersMethoddumpGoroutines
()
common/deadlock/deadlock.go:130
↓ 1 callersMethoddumpRecorders
dumpRecorders writes task queues and replication streams to /tmp/xdc for debugging
tests/xdc/stream_based_replication_test.go:1386
↓ 1 callersFunctionembedTags
embedTags adds the sorted list of tags directly in the stat name. For example, if the stat is `hello.world` and the tags are `{universe: milkyWay, pla
common/metrics/statsd_exporter.go:242
↓ 1 callersFunctionembedTags
embedTags adds the sorted list of tags directly in the stat name. For example, if the stat is `hello.world` and the tags are `{universe: milkyWay, pla
common/metrics/tally/statsd/reporter.go:94
↓ 1 callersFunctionemitCompletionLatencies
emitCompletionLatencies emits schedule-to-close plus either start-to-close (operations that started) or schedule-to-start (sync / never-started), mirr
components/nexusoperations/metrics.go:88
↓ 1 callersMethodemitEvent
(event *membership.ChangedEvent)
common/membership/ringpop/service_resolver.go:406
↓ 1 callersMethodemitForwardedSourceStats
( isTaskForwarded bool, pollForwardedSource string, forwardedPoll bool, )
service/matching/matcher.go:608
↓ 1 callersMethodemitForwardedSourceStats
( isTaskForwarded bool, pollForwardedSource string, )
service/matching/pri_matcher.go:684
↓ 1 callersFunctionemitGetMetrics
( shardContext historyi.ShardContext, namespace *namespace.Namespace, archetypeID chasm.ArchetypeID, stats
service/history/workflow/transaction_impl.go:722
↓ 1 callersMethodemitMetrics
()
client/matching/partition_cache.go:69
↓ 1 callersMethodemitMetrics
()
common/persistence/dlq_metrics_emitter.go:91
↓ 1 callersMethodemitMetricsLoop
Traverse through all shards and get the per-namespace persistence RPS for all shards. If that is over the limit, print a log line. Per-shard-per-names
common/persistence/health_signal_aggregator.go:123
↓ 1 callersMethodemitMetricsLoop
()
common/persistence/dlq_metrics_emitter.go:74
↓ 1 callersMethodemitOnAttemptFailedMetrics
(ctx chasm.Context, handler metrics.Handler)
chasm/lib/activity/activity.go:1128
↓ 1 callersMethodemitOnCanceledMetrics
(ctx chasm.Context, closeTime time.Time)
chasm/lib/nexusoperation/operation.go:628
↓ 1 callersMethodemitOnCanceledMetrics
( ctx chasm.Context, handler metrics.Handler, fromStatus activitypb.ActivityExecutionStatus, )
chasm/lib/activity/activity.go:1173
↓ 1 callersMethodemitOnCompletedMetrics
(ctx chasm.Context, handler metrics.Handler)
chasm/lib/activity/activity.go:1138
↓ 1 callersMethodemitOnFailedMetrics
(ctx chasm.Context, closeTime time.Time)
chasm/lib/nexusoperation/operation.go:619
↓ 1 callersMethodemitOnFailedMetrics
(ctx chasm.Context, handler metrics.Handler)
chasm/lib/activity/activity.go:1151
← previousnext →11,401–11,500 of 43,335, ranked by callers