MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersMethodcountTooMany
()
service/history/workflow/update/util.go:62
↓ 1 callersMethodcountWorkflowExecutions
( ctx context.Context, request *manager.CountWorkflowExecutionsRequest, )
common/persistence/visibility/store/sql/visibility_store.go:597
↓ 1 callersMethodcountWorkflowExecutionsLegacy
( ctx context.Context, request *manager.CountWorkflowExecutionsRequest, )
common/persistence/visibility/store/sql/visibility_store.go:551
↓ 1 callersMethodcounter
( namespace namespace.Name, methodName string, )
common/rpc/interceptor/concurrent_request_limit.go:119
↓ 1 callersMethodcounts
()
common/testing/objectleak/report.go:211
↓ 1 callersMethodcreateAddActivityTaskRequest
( task *tasks.ActivityTask, ai *persistencespb.ActivityInfo, )
service/history/transfer_queue_active_task_executor_test.go:2964
↓ 1 callersMethodcreateAsCurrent
( ctx context.Context, currentWorkflow Workflow, targetWorkflow Workflow, )
service/history/ndc/transaction_manager_new_workflow.go:139
↓ 1 callersMethodcreateAsCurrent
createAsCurrent creates a new workflow execution and sets it to "current".
service/history/api/startworkflow/api.go:371
↓ 1 callersMethodcreateAsZombie
( ctx context.Context, currentWorkflow Workflow, targetWorkflow Workflow, )
service/history/ndc/transaction_manager_new_workflow.go:192
↓ 1 callersMethodcreateBatchedTask
(task TrackableExecutableTask)
service/history/replication/sequential_batch_queue.go:97
↓ 1 callersMethodcreateBrandNew
createBrandNew creates a "brand new" execution in the executions table.
service/history/api/startworkflow/api.go:304
↓ 1 callersFunctioncreateCheckpointRetryPolicy
()
service/history/queues/queue_base.go:448
↓ 1 callersFunctioncreateClient
(ctrl *gomock.Controller, listener *nettest.PipeListener)
client/history/historytest/clienttest.go:153
↓ 1 callersMethodcreateConfig
()
service/history/workflow/workflow_test/mutable_state_impl_test.go:244
↓ 1 callersFunctioncreateConnection
( cfg *config.SQL, d driver.Driver, resolver resolver.ServiceResolver, )
common/persistence/sql/sqlplugin/postgresql/session/session.go:53
↓ 1 callersFunctioncreateConnection
( dbKind sqlplugin.DbKind, cfg *config.SQL, resolver resolver.ServiceResolver, )
common/persistence/sql/sqlplugin/mysql/session/session.go:65
↓ 1 callersMethodcreateContextWithLargeTimeout
(parent context.Context)
client/admin/client.go:47
↓ 1 callersMethodcreateDBConnection
CreateDBConnection creates a returns a reference to a logical connection to the underlying SQL database. The returned object is to tied to a single SQ
common/persistence/sql/sqlplugin/postgresql/plugin.go:77
↓ 1 callersMethodcreateDBConnection
CreateDBConnection creates a returns a reference to a logical connection to the underlying SQL database. The returned object is to tied to a single SQ
common/persistence/sql/sqlplugin/mysql/plugin.go:59
↓ 1 callersMethodcreateEngine
()
service/history/shard/context_impl.go:1448
↓ 1 callersFunctioncreateExecution
( batch *gocql.Batch, shardID int32, snapshot *p.InternalWorkflowSnapshot, )
common/persistence/cassandra/util.go:371
↓ 1 callersMethodcreateExecution
( ctx context.Context, tx sqlplugin.Tx, namespaceID string, workflowID string, executionInfo *commonpb.Da
common/persistence/sql/execution_util.go:1121
↓ 1 callersFunctioncreateExpirationLogMessage
(cert CertExpirationData, expired bool)
common/rpc/encryption/local_store_tls_provider.go:459
↓ 1 callersFunctioncreateFixedTLSConfigProvider
()
tests/testcore/test_cluster.go:640
↓ 1 callersFunctioncreateHistoryEventBatchBlob
( result map[string]any, )
common/persistence/cassandra/util.go:1126
↓ 1 callersMethodcreateHistoryEventReplicationTaskFromHistoryEventBatch
( namespaceId string, workflowId string, runId string, events []*historypb.HistoryEvent, newRunEvents []*
tests/ndc/replication_task_batching_test.go:241
↓ 1 callersFunctioncreateHistoryTasks
( batch *gocql.Batch, category tasks.Category, historyTasks []p.InternalHistoryTask, shardID int32, )
common/persistence/cassandra/util.go:583
↓ 1 callersFunctioncreateImmediateTasks
( ctx context.Context, tx sqlplugin.Tx, shardID int32, categoryID int, immedidateTasks []p.InternalHistor
common/persistence/sql/execution_util.go:697
↓ 1 callersFunctioncreateIndexesToArchive
(request *archiverspb.VisibilityRecord)
common/archiver/s3store/visibility_archiver.go:142
↓ 1 callersMethodcreateInterceptor
(ctrl *gomock.Controller)
common/rpc/interceptor/concurrent_request_limit_test.go:197
↓ 1 callersMethodcreateKeyspace
(keyspace string)
tools/cassandra/version_tests.go:58
↓ 1 callersFunctioncreateLazyValueFromPayload
(payload *commonpb.Payload)
service/history/handler.go:2599
↓ 1 callersMethodcreateMockNameInterceptor
(mapper searchattribute.Mapper)
common/persistence/visibility/store/elasticsearch/query_interceptors_test.go:206
↓ 1 callersFunctioncreateMockNamespaceCache
(controller *gomock.Controller, nsName namespace.Name)
service/worker/workerdeployment/util_test.go:87
↓ 1 callersFunctioncreateNamespaceIfNotExists
(db sqlplugin.DB, namespace *NamespaceConfig)
schema/sqlite/setup.go:169
↓ 1 callersMethodcreateNewExecution
( ctx context.Context, shardContext historyi.ShardContext, executionRef chasm.ComponentRef, archetypeID ch
service/history/chasm_engine.go:813
↓ 1 callersMethodcreateNewRunWorkflow
( ctx context.Context, namespaceID namespace.ID, workflowID string, archetypeID chasm.ArchetypeID, newRun
service/history/ndc/workflow_state_replicator.go:1532
↓ 1 callersFunctioncreateNexusEndpoint
(t *testing.T, conn *grpc.ClientConn, endpointName, namespace, taskQueue string)
tests/mixedbrain/server_util.go:102
↓ 1 callersFunctioncreateOrUpdateCurrentExecution
( ctx context.Context, tx sqlplugin.Tx, row sqlplugin.CurrentExecutionsRow, createMode p.CreateWorkflowMod
common/persistence/sql/execution_util.go:604
↓ 1 callersMethodcreatePausedWorkflowWithWFT
(tv *testvars.TestVars)
service/history/api/respondworkflowtaskcompleted/api_test.go:772
↓ 1 callersMethodcreatePollActivityTaskQueueResponse
Populate the activity task response based on context and scheduled/started events.
service/matching/matching_engine.go:3207
↓ 1 callersMethodcreatePollWorkflowTaskQueueResponse
( ctx context.Context, namespaceName namespace.Name, namespaceID namespace.ID, matchingResp *matchingservi
service/history/api/respondworkflowtaskcompleted/api.go:795
↓ 1 callersMethodcreateRecordWorkflowExecutionStartedRequest
( namespaceName namespace.Name, task *tasks.StartExecutionVisibilityTask, mutableState historyi.MutableStat
service/history/visibility_queue_task_executor_test.go:859
↓ 1 callersMethodcreateReplicationFetcherLocked
(clusterName string)
service/history/replication/task_fetcher.go:150
↓ 1 callersFunctioncreateReplicationTasks
( ctx context.Context, tx sqlplugin.Tx, shardID int32, replicationTasks []p.InternalHistoryTask, )
common/persistence/sql/execution_util.go:866
↓ 1 callersFunctioncreateReplicationTasks
( batch *gocql.Batch, replicationTasks []p.InternalHistoryTask, shardID int32, )
common/persistence/cassandra/util.go:541
↓ 1 callersMethodcreateRequestHandler
()
common/rpc/interceptor/concurrent_request_limit_test.go:170
↓ 1 callersMethodcreateScheduleCHASM
( ctx context.Context, request *workflowservice.CreateScheduleRequest, )
service/frontend/workflow_handler.go:3459
↓ 1 callersMethodcreateScheduleWorkflow
( ctx context.Context, request *workflowservice.CreateScheduleRequest, )
service/frontend/workflow_handler.go:3528
↓ 1 callersFunctioncreateScheduledTasks
( ctx context.Context, tx sqlplugin.Tx, shardID int32, categoryID int, scheduledTasks []p.InternalHistory
common/persistence/sql/execution_util.go:747
↓ 1 callersFunctioncreateServer
(historyTaskQueueManager persistence.HistoryTaskQueueManager)
client/history/historytest/clienttest.go:137
↓ 1 callersMethodcreateSocket
()
common/testing/nettest/pipe_benchmark_test.go:34
↓ 1 callersMethodcreateSystemNamespace
()
tests/testcore/onebox.go:635
↓ 1 callersMethodcreateTLSConfig
(c *cli.Context)
tools/tdbg/factory.go:123
↓ 1 callersFunctioncreateTestRequestWithNSDivision
()
common/persistence/visibility/store/elasticsearch/visibility_store_read_test.go:107
↓ 1 callersMethodcreateTestScavenger
( rps int, )
service/worker/scanner/history/scavenger_test.go:83
↓ 1 callersFunctioncreateTimerTasks
( ctx context.Context, tx sqlplugin.Tx, shardID int32, timerTasks []p.InternalHistoryTask, )
common/persistence/sql/execution_util.go:829
↓ 1 callersFunctioncreateTimerTasks
( batch *gocql.Batch, timerTasks []p.InternalHistoryTask, shardID int32, )
common/persistence/cassandra/util.go:520
↓ 1 callersFunctioncreateTransferTasks
( ctx context.Context, tx sqlplugin.Tx, shardID int32, transferTasks []p.InternalHistoryTask, )
common/persistence/sql/execution_util.go:792
↓ 1 callersFunctioncreateTransferTasks
( batch *gocql.Batch, transferTasks []p.InternalHistoryTask, shardID int32, )
common/persistence/cassandra/util.go:499
↓ 1 callersFunctioncreateUpdateRequest
(updateID string)
service/history/api/updateworkflow/api_test.go:46
↓ 1 callersMethodcreateVersionCheckRequest
(metadata *persistence.GetClusterMetadataResponse)
service/frontend/version_checker.go:136
↓ 1 callersFunctioncreateVersionedRunID
(currentWorkflowLease api.WorkflowLease)
service/history/api/signalwithstartworkflow/signal_with_start_workflow.go:176
↓ 1 callersFunctioncreateVisibilityTasks
( ctx context.Context, tx sqlplugin.Tx, shardID int32, visibilityTasks []p.InternalHistoryTask, )
common/persistence/sql/execution_util.go:903
↓ 1 callersFunctioncreateVisibilityTasks
( batch *gocql.Batch, visibilityTasks []p.InternalHistoryTask, shardID int32, )
common/persistence/cassandra/util.go:562
↓ 1 callersMethodcreateWorkflowExecutionTx
( ctx context.Context, tx sqlplugin.Tx, request *p.InternalCreateWorkflowExecutionRequest, )
common/persistence/sql/execution.go:81
↓ 1 callersFunctioncreateWorkflowMutationFunction
( shardContext historyi.ShardContext, currentWorkflowLease api.WorkflowLease, namespaceEntry *namespace.Nam
service/history/api/signalwithstartworkflow/signal_with_start_workflow.go:133
↓ 1 callersFunctioncurrentExecutionInfoFromMutableState
(ms historyi.MutableState)
service/history/chasm_engine.go:953
↓ 1 callersMethoddailyFailureCounts
(failures []TestFailure)
tools/flakereport/parser.go:218
↓ 1 callersMethoddataNodePath
dataNodePath implements the CHASM Context interface
chasm/tree.go:1584
↓ 1 callersFunctiondecodeChasmNodes
( chasmNodes map[string]*persistencespb.ChasmNode, registry *chasm.Registry, )
tools/tdbg/chasm_decoder.go:200
↓ 1 callersFunctiondecodePayloadsRecursive
(v any, encoder codec.JSONPBEncoder)
tools/tdbg/proto_decoder.go:33
↓ 1 callersMethoddecodeReportedProblems
decodeReportedProblems safely decodes a keyword list payload to []string
service/history/workflow/mutable_state_impl.go:7092
↓ 1 callersFunctiondecodeTask
( task *persistencespb.ChasmComponentAttributes_Task, registry *chasm.Registry, )
tools/tdbg/chasm_decoder.go:53
↓ 1 callersFunctiondecodeVisibilityRecord
(data []byte)
common/archiver/gcloud/util.go:96
↓ 1 callersFunctiondecodeVisibilityRecord
(data []byte)
common/archiver/filestore/util.go:132
↓ 1 callersFunctiondecodeVisibilityRecord
(data []byte)
common/archiver/s3store/util.go:36
↓ 1 callersFunctiondeepCopyValue
(v reflect.Value)
common/dynamicconfig/deepcopy.go:16
↓ 1 callersFunctiondefaultMaxPendingKeys
()
service/history/queues/slice_test.go:48
↓ 1 callersFunctiondefaultRPS
(wrapper *wrapperspb.DoubleValue)
service/matching/poller_history.go:73
↓ 1 callersMethoddeferredCompletionMetric
deferredCompletionMetric builds the post-commit caller-side emit for a resolved async completion: the terminal outcome (the canceled vs failed split m
components/nexusoperations/completion.go:261
↓ 1 callersMethoddeferredCount
()
service/worker/scanner/executor/runq.go:74
↓ 1 callersMethoddeferredOperationMetric
deferredOperationMetric returns the caller-side metric to record for op's resulting state, or nil when nothing should be emitted (e.g. a retryable att
components/nexusoperations/executors.go:492
↓ 1 callersMethoddelete
(name string)
service/worker/scanner/taskqueue/mocks_test.go:71
↓ 1 callersFunctiondeleteActivityInfoMap
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:87
↓ 1 callersMethoddeleteBranchRangeNodes
( batch *gocql.Batch, treeID string, branchID string, beginNodeID int64, )
common/persistence/cassandra/history_store.go:288
↓ 1 callersFunctiondeleteBufferedEvents
( batch *gocql.Batch, shardID int32, namespaceID string, workflowID string, runID string, )
common/persistence/cassandra/util.go:648
↓ 1 callersMethoddeleteChasmExecution
(ctx context.Context)
service/history/replication/executable_delete_execution_task.go:165
↓ 1 callersFunctiondeleteChasmNodeMap
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:545
↓ 1 callersFunctiondeleteChildExecutionInfoMap
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:266
↓ 1 callersMethoddeleteDLQTasks
( ctx context.Context, request *historyservice.DeleteDLQTasksRequest, )
service/history/handler.go:2069
↓ 1 callersMethoddeleteExecution
( ctx context.Context, task tasks.Task, archetypeID chasm.ArchetypeID, ensureNoPendingCloseTask bool, sta
service/history/transfer_queue_task_executor_base.go:212
↓ 1 callersMethoddeleteExecutionsActivities
()
service/worker/deletenamespace/fx.go:131
↓ 1 callersMethoddeleteExecutionsLocalActivities
()
service/worker/deletenamespace/fx.go:142
↓ 1 callersMethoddeleteHandler
deleteHandler handles deletions for a given task queue this handler limits the amount of tasks deleted to maxTasksPerJob for fairness among all the ta
service/worker/scanner/taskqueue/handler.go:39
↓ 1 callersMethoddeleteHandlerLog
(key *p.TaskQueueKey, state *taskQueueState, nProcessed int, nDeleted int, err error)
service/worker/scanner/taskqueue/handler.go:105
↓ 1 callersMethoddeleteHistoryBranch
( ctx context.Context, branchToken []byte, )
service/history/timer_queue_task_executor_base.go:149
↓ 1 callersMethoddeleteHistoryTasks
deleteHistoryTasks iterates over provided task keys and completes them when the dynamic config history.enableDeleteTasksOnWorkflowUpdate is enabled. C
common/persistence/execution_manager.go:282
↓ 1 callersMethoddeleteLessThan
(id int64, limit int)
service/worker/scanner/taskqueue/mocks_test.go:123
↓ 1 callersMethoddeleteNamespace
deleteNamespace removes a namespace from the cache and returns the deleted namespace if it existed
common/namespace/nsregistry/registry.go:700
← previousnext →11,301–11,400 of 43,335, ranked by callers