MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersMethodImportWorkflow
( ctx context.Context, workflowKey definition.WorkflowKey, versionHistoryItems []*historyspb.VersionH
service/history/ndc/history_importer.go:25
↓ 1 callersMethodIndexPutMapping
(ctx context.Context, indexName string, bodyString string)
common/persistence/visibility/store/elasticsearch/client/client.go:41
↓ 1 callersMethodIndexPutTemplate
(ctx context.Context, templateName string, bodyString string)
common/persistence/visibility/store/elasticsearch/client/client.go:48
↓ 1 callersMethodInfo
Info returns the underlying NamespaceInfo proto. The returned value is the registry's own copy and must not be mutated.
common/namespace/namespace.go:232
↓ 1 callersMethodInfo
(msg string, keyvals ...any)
common/log/sdk_logger.go:61
↓ 1 callersMethodInitialize
( ctx context.Context, workflowKey definition.WorkflowKey, token []byte, )
service/history/ndc/mutable_state_initializer.go:42
↓ 1 callersMethodInitializeFromDB
( ctx context.Context, namespaceEntry *namespace.Namespace, workflowKey definition.WorkflowKey, )
service/history/ndc/mutable_state_initializer.go:85
↓ 1 callersMethodInitializeFromToken
( _ context.Context, namespaceEntry *namespace.Namespace, workflowKey definition.WorkflowKey, token []byte
service/history/ndc/mutable_state_initializer.go:151
↓ 1 callersFunctionInitializeHistoryEventGenerator
InitializeHistoryEventGenerator initializes the history event generator
common/testing/history_event_util.go:38
↓ 1 callersMethodInitializeNexusEndpointsTableVersion
(ctx context.Context)
common/persistence/sql/sqlplugin/nexus_endpoints.go:23
↓ 1 callersMethodInitiateShutdown
InitiateShutdown signals the scheduler to stop without waiting for shutdown to complete.
common/tasks/runnable_scheduler.go:14
↓ 1 callersMethodInitiateShutdown
InitiateShutdown aborts all buffered tasks and empties the buffer.
common/tasks/dynamic_worker_pool_scheduler.go:64
↓ 1 callersMethodInjectWorkerRPS
Lazy injection of poll metadata. Called whenever a new poll request comes in. This allows the rate limit manager to adjust its rate limits based on an
service/matching/ratelimit_manager.go:180
↓ 1 callersMethodInsertIntoHistoryImmediateTasks
InsertIntoHistoryImmediateTasks inserts rows that into history_immediate_tasks table.
common/persistence/sql/sqlplugin/history_immediate_tasks.go:39
↓ 1 callersMethodInsertIntoHistoryScheduledTasks
InsertIntoHistoryScheduledTasks inserts rows that into history_scheduled_tasks table.
common/persistence/sql/sqlplugin/history_scheduled_tasks.go:43
↓ 1 callersMethodInsertIntoNexusEndpoints
(ctx context.Context, row *NexusEndpointsRow)
common/persistence/sql/sqlplugin/nexus_endpoints.go:27
↓ 1 callersMethodIntercept
Intercept wraps the request context with metadata storage and invokes the handler. When setTrailer is enabled, accumulated metadata is written to gRPC
common/rpc/interceptor/context_metadata_interceptor.go:48
↓ 1 callersFunctionInterruptCh
()
temporal/interrupt.go:9
↓ 1 callersFunctionInterruptOn
InterruptOn interrupts server on the signal from server. If channel is nil Start() will block forever.
temporal/server_option.go:75
↓ 1 callersMethodInvalidateCache
()
service/history/hsm/tree.go:344
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.RecordActivityTaskHeartbeatRequest, shard historyi.ShardContext,
service/history/api/recordactivitytaskheartbeat/api.go:17
↓ 1 callersFunctionInvoke
( ctx context.Context, resetRequest *historyservice.ResetWorkflowExecutionRequest, shardContext historyi.Sh
service/history/api/resetworkflow/api.go:27
↓ 1 callersFunctionInvoke
( ctx context.Context, request *historyservice.VerifyChildExecutionCompletionRecordedRequest, workflowConsi
service/history/api/verifychildworkflowcompletionrecorded/api.go:87
↓ 1 callersFunctionInvoke
( ctx context.Context, request *historyservice.QueryWorkflowRequest, shardContext historyi.ShardContext, w
service/history/api/queryworkflow/api.go:33
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.RequestCancelWorkflowExecutionRequest, shard historyi.ShardConte
service/history/api/requestcancelworkflow/api.go:14
↓ 1 callersFunctionInvoke
( ctx context.Context, request *historyservice.UnpauseActivityRequest, shardContext historyi.ShardContext,
service/history/api/unpauseactivity/api.go:18
↓ 1 callersFunctionInvoke
( ctx context.Context, namespaceUUID namespace.ID, workflowID string, runID string, reapplyEvents []*hist
service/history/api/reapplyevents/api.go:21
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.IsActivityTaskValidRequest, shardContext historyi.ShardContext,
service/history/api/isactivitytaskvalid/api.go:14
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.RespondWorkflowTaskFailedRequest, shardContext historyi.ShardCon
service/history/api/respondworkflowtaskfailed/api.go:21
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.UnpauseWorkflowExecutionRequest, shard historyi.ShardContext, w
service/history/api/unpauseworkflow/api.go:17
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.IsWorkflowTaskValidRequest, shardContext historyi.ShardContext,
service/history/api/isworkflowtaskvalid/api.go:14
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.ScheduleWorkflowTaskRequest, shardContext historyi.ShardContext,
service/history/api/scheduleworkflowtask/api.go:14
↓ 1 callersFunctionInvoke
( ctx context.Context, request *historyservice.RecordActivityTaskStartedRequest, shardContext historyi.Shar
service/history/api/recordactivitytaskstarted/api.go:38
↓ 1 callersFunctionInvoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionrawhistoryv2/api.go:25
↓ 1 callersFunctionInvoke
( ctx context.Context, workflowKey definition.WorkflowKey, archetypeID chasm.ArchetypeID, shardContext his
service/history/api/refreshworkflow/api.go:14
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.ExecuteMultiOperationRequest, shardContext historyi.ShardContext
service/history/api/multioperation/api.go:55
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.DescribeWorkflowExecutionRequest, shard historyi.ShardContext,
service/history/api/describeworkflow/api.go:63
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.RemoveSignalMutableStateRequest, shard historyi.ShardContext, w
service/history/api/removesignalmutablestate/api.go:14
↓ 1 callersFunctionInvoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionrawhistory/api.go:25
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.RespondActivityTaskCanceledRequest, shard historyi.ShardContext,
service/history/api/respondactivitytaskcanceled/api.go:21
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.DescribeMutableStateRequest, shardContext historyi.ShardContext,
service/history/api/describemutablestate/api.go:16
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.PauseWorkflowExecutionRequest, shard historyi.ShardContext, wor
service/history/api/pauseworkflow/api.go:17
↓ 1 callersFunctionInvoke
( ctx context.Context, request *historyservice.DeleteWorkflowExecutionRequest, shardContext historyi.ShardC
service/history/api/deleteworkflow/api.go:18
↓ 1 callersFunctionInvoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionhistoryreverse/api.go:23
↓ 1 callersFunctionInvoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionhistory/api.go:119
↓ 1 callersFunctionInvoke
( ctx context.Context, chasmEngine chasm.Engine, request *historyservice.DeleteExecutionRequest, )
service/history/api/deleteexecution/api.go:10
↓ 1 callersFunctionInvoke
( ctx context.Context, signalWithStartRequest *historyservice.SignalWithStartWorkflowExecutionRequest, shar
service/history/api/signalwithstartworkflow/api.go:19
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.ResetActivityRequest, shardContext historyi.ShardContext, workf
service/history/api/resetactivity/api.go:17
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.RespondActivityTaskCompletedRequest, shard historyi.ShardContext
service/history/api/respondactivitytaskcompleted/api.go:21
↓ 1 callersFunctionInvoke
( ctx context.Context, request *historyservice.PauseActivityRequest, shardContext historyi.ShardContext, w
service/history/api/pauseactivity/api.go:19
↓ 1 callersFunctionInvoke
( ctx context.Context, req *historyservice.TerminateWorkflowExecutionRequest, shardContext historyi.ShardCo
service/history/api/terminateworkflow/api.go:15
↓ 1 callersMethodInvoke
( ctx context.Context, )
service/history/api/updateworkflow/api.go:74
↓ 1 callersMethodInvoke
Invoke starts a new workflow execution. NOTE: `beforeCreateHook` might be invoked more than once in the case where the workflow policy requires termin
service/history/api/startworkflow/api.go:180
↓ 1 callersMethodInvoke
nolint:revive // cyclomatic complexity
service/history/api/respondworkflowtaskcompleted/api.go:110
↓ 1 callersFunctionIsAPIOperation
(apiFullName string)
service/frontend/configs/quotas.go:388
↓ 1 callersFunctionIsASCIIUpper
(c rune)
cmd/tools/codegen/helpers.go:94
↓ 1 callersMethodIsCurrentWorkflowGuaranteed
()
service/history/workflow/mutable_state_impl.go:1308
↓ 1 callersMethodIsDirty
IsDirty is used for sanity check that mutable state is "clean" after mutable state lock is released. However, certain in-memory changes (e.g. speculat
service/history/workflow/mutable_state_impl.go:7417
↓ 1 callersMethodIsDirty
()
service/history/historybuilder/history_builder.go:155
↓ 1 callersMethodIsDupDatabaseError
(err error)
common/persistence/sql/sqlplugin/postgresql/db.go:22
↓ 1 callersMethodIsDupDatabaseError
(error)
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:26
↓ 1 callersMethodIsDupEntryError
(error)
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:25
↓ 1 callersMethodIsEmpty
IsEmpty indicate if the priority queue is empty
common/collection/priority_queue.go:59
↓ 1 callersMethodIsEmpty
()
common/namespace/namespace.go:343
↓ 1 callersFunctionIsEnabled
(t trace.Tracer)
common/telemetry/config.go:419
↓ 1 callersMethodIsForceTerminated
( workflowID string, runID string, )
tests/ndc/ndc_test.go:2425
↓ 1 callersMethodIsGlobalNamespace
()
common/namespace/replication_resolver.go:98
↓ 1 callersMethodIsGlobalNamespace
IsGlobalNamespace returns whether the namespace is a global namespace. Being a global namespace doesn't necessarily mean that there are multiple regis
common/namespace/namespace.go:221
↓ 1 callersFunctionIsHealthCheckAPI
(fullApi string)
common/authorization/frontend_api.go:25
↓ 1 callersMethodIsInHandover
IsInHandover returns true if operations for this namespace+workflowID should be blocked due to handover.
service/history/shard/handover_tracker.go:30
↓ 1 callersFunctionIsInternalTag
(internal bool)
common/metrics/tags.go:582
↓ 1 callersFunctionIsInternalTaskQueue
IsInternalTaskQueue returns true if the task queue name belongs to an internal system task queue.
common/primitives/task_queues.go:41
↓ 1 callersFunctionIsInternalTaskQueueKind
IsInternalTaskQueueKind returns true if the task queue kind identifies a server-internal task queue (e.g. worker commands queues). All kinds are liste
common/primitives/task_queues.go:28
↓ 1 callersFunctionIsLongPollDescribeActivityExecutionRequest
( req any, )
common/rpc/interceptor/namespace_rate_limit.go:171
↓ 1 callersFunctionIsLongPollGetWorkflowExecutionHistoryRequest
( req any, )
common/rpc/interceptor/namespace_rate_limit.go:161
↓ 1 callersFunctionIsNamespaceHandoverError
(err error)
common/util.go:374
↓ 1 callersFunctionIsNegativeScheduleIDOperator
IsNegativeScheduleIDOperator returns true for operators that express exclusion. Negative operators require AND when combining V1 and V2 WorkflowId con
service/worker/scheduler/schedule_id_query_rewriter.go:146
↓ 1 callersMethodIsNonCurrentWorkflowGuaranteed
()
service/history/interfaces/mutable_state.go:219
↓ 1 callersFunctionIsNoopAuthorizer
(authorizer Authorizer)
common/authorization/authorizer.go:75
↓ 1 callersFunctionIsRetryableError
(err error)
service/history/api/retry_util.go:12
↓ 1 callersMethodIsStateDirty
IsStateDirty returns true if any node in the tree has USER DATA modified, which need to be persisted to DB AND replicated to other clusters. The resul
chasm/tree.go:2806
↓ 1 callersMethodIsStickyTaskQueueSet
()
service/history/workflow/mutable_state_impl.go:1449
↓ 1 callersFunctionIsStickyWorkerUnavailable
(err error)
common/util.go:378
↓ 1 callersMethodIsStrictOnNextVertex
IsStrictOnNextVertex returns the isStrict flag
common/testing/event_generator.go:455
↓ 1 callersMethodIsStrictOnNextVertex
()
common/testing/generator_interface.go:54
↓ 1 callersMethodIsSubStateMachineDeleted
()
service/history/interfaces/mutable_state.go:413
↓ 1 callersMethodIsTerminalTaskError
()
service/history/queues/executable.go:76
↓ 1 callersFunctionIsUserDefinedSearchAttribute
IsUserDefinedSearchAttribute returns true if alias refers to a user-defined custom search attribute rather than a synthetic one (e.g. the synthetic Sc
common/searchattribute/mapper.go:235
↓ 1 callersMethodIsValid
()
service/history/replication/stream_receiver.go:36
↓ 1 callersMethodIsVersionMissingTaskQueues
Used internally by the Worker Deployment workflow in its IsVersionMissingTaskQueues Activity to verify if there are missing task queues in the new cur
service/worker/workerdeployment/client.go:192
↓ 1 callersMethodIsWorkflow
()
service/history/workflow/mutable_state_impl.go:664
↓ 1 callersMethodIsWorkflow
()
chasm/tree.go:225
↓ 1 callersMethodIsWorkflowExecutionRunning
()
service/history/interfaces/mutable_state.go:229
↓ 1 callersMethodIsWorkflowTaskTrigger
IsWorkflowTaskTrigger returns a boolean indicating whether this event type should trigger a workflow task.
chasm/lib/workflow/events.go:18
↓ 1 callersMethodIter
Iter returns an iterator to the map. This map does not use re-entrant locks, so access or modification to the map during iteration can cause a dead lo
common/collection/concurrent_tx_map.go:192
↓ 1 callersMethodKey
(task tasks.Task)
service/history/queues/grouper.go:19
↓ 1 callersMethodKey
(task tasks.Task)
service/history/queues/grouper.go:37
↓ 1 callersFunctionKeyExists
(ctx context.Context, s3cli S3API, URI archiver.URI, key string)
common/archiver/s3store/util.go:93
↓ 1 callersMethodKillHost
KillHost kills the given host within the cluster
common/membership/ringpop/test_cluster.go:177
↓ 1 callersMethodLastActiveTime
()
common/tasks/weighted_channel.go:48
← previousnext →10,001–10,100 of 43,335, ranked by callers