MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersMethodgetVisibilityTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/cassandra/mutable_state_task_store.go:620
↓ 1 callersMethodgetWFTFailure
(admin adminservice.AdminServiceClient, ns, wfid, runid string)
tests/xdc/workflow_task_reported_problems_test.go:98
↓ 1 callersMethodgetWorkerAllocation
(args refreshArgs)
service/worker/pernamespaceworker.go:268
↓ 1 callersMethodgetWorkerByNamespace
(ns *namespace.Namespace)
service/worker/pernamespaceworker.go:234
↓ 1 callersMethodgetWorkerHeartbeat
(nsID namespace.ID, workerInstanceKey string)
service/matching/workers/registry_impl.go:169
↓ 1 callersMethodgetWorkerTaskReachabilityValidated
Implementation of the GetWorkerTaskReachability API. Expects an already validated request.
service/frontend/task_reachability.go:65
↓ 1 callersFunctiongetWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, request *persistence.GetWorkflowExecutionRequest
service/history/workflow/transaction_impl.go:468
↓ 1 callersFunctiongetWorkflowID
getWorkflowID extracts the workflow ID from the schedule's action. This is the workflow ID specified in the schedule spec. During workflow start gener
chasm/lib/scheduler/migration/migration.go:386
↓ 1 callersMethodgetWorkflowLease
(ctx context.Context)
service/history/api/multioperation/api.go:286
↓ 1 callersFunctiongetWorkflowMemo
( memoFields map[string]*commonpb.Payload, )
service/history/visibility_queue_task_executor.go:666
↓ 1 callersMethodgetWriteBatch
(reqs []*writeTaskRequest)
service/matching/pri_task_writer.go:182
↓ 1 callersMethodgetWriteBatch
(reqs []*writeTaskRequest)
service/matching/task_writer.go:182
↓ 1 callersMethodgetWriteBatch
(reqs []*writeTaskRequest)
service/matching/fair_task_writer.go:202
↓ 1 callersFunctiongoTestNameToRunFlagRegexp
(test string)
tools/testrunner/testrunner.go:468
↓ 1 callersMethodgotIncomingEphemeralData
(eph *taskqueuespb.VersionedEphemeralData)
service/matching/user_data_manager.go:783
↓ 1 callersMethodgrpcAddress
(serviceName primitives.ServiceName)
tests/testcore/clients.go:147
↓ 1 callersMethodhandleActivityTask
( ctx context.Context, task *replicationspb.ReplicationTask, forceApply bool, )
service/history/replication/task_executor.go:105
↓ 1 callersMethodhandleCommandCancelTimer
( _ context.Context, attr *commandpb.CancelTimerCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:908
↓ 1 callersMethodhandleCommandCancelWorkflow
( ctx context.Context, attr *commandpb.CancelWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:934
↓ 1 callersMethodhandleCommandCompleteWorkflow
( ctx context.Context, attr *commandpb.CompleteWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:783
↓ 1 callersMethodhandleCommandContinueAsNewWorkflow
( ctx context.Context, attr *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1029
↓ 1 callersMethodhandleCommandFailWorkflow
( ctx context.Context, attr *commandpb.FailWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:838
↓ 1 callersMethodhandleCommandModifyWorkflowProperties
( _ context.Context, attr *commandpb.ModifyWorkflowPropertiesCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1364
↓ 1 callersMethodhandleCommandProtocolMessage
( ctx context.Context, attr *commandpb.ProtocolMessageCommandAttributes, msgs *collection.IndexedTakeList[s
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:434
↓ 1 callersMethodhandleCommandRecordMarker
( _ context.Context, attr *commandpb.RecordMarkerCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1004
↓ 1 callersMethodhandleCommandRequestCancelExternalWorkflow
( _ context.Context, attr *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:964
↓ 1 callersMethodhandleCommandScheduleActivity
( _ context.Context, attr *commandpb.ScheduleActivityTaskCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:463
↓ 1 callersMethodhandleCommandSignalExternalWorkflow
( _ context.Context, attr *commandpb.SignalExternalWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1248
↓ 1 callersMethodhandleCommandStartChildWorkflow
( _ context.Context, attr *commandpb.StartChildWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1138
↓ 1 callersMethodhandleCommandStartTimer
( _ context.Context, attr *commandpb.StartTimerCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:764
↓ 1 callersMethodhandleCommandUpsertWorkflowSearchAttributes
( _ context.Context, attr *commandpb.UpsertWorkflowSearchAttributesCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1296
↓ 1 callersMethodhandleCommands
( ctx context.Context, commands []*commandpb.Command, msgs *collection.IndexedTakeList[string, *protocolpb.
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:168
↓ 1 callersMethodhandleConflict
handleConflict handles CurrentWorkflowConditionFailedError where there's a workflow with the same workflowID. This may happen either when the currentl
service/history/api/startworkflow/api.go:321
↓ 1 callersMethodhandleConflictPolicy
( _ context.Context, _ historyi.ShardContext, newExecutionParams newExecutionParams, currentRunInfo curren
service/history/chasm_engine.go:1016
↓ 1 callersMethodhandleConflictPolicy
handleConflictPolicy is called when a StartExecution arrives for a business ID whose current run is still running.
chasm/chasmtest/test_engine.go:345
↓ 1 callersMethodhandleErr
( err error, )
service/worker/scanner/history/scavenger.go:291
↓ 1 callersMethodhandleFailures
( mutableState *MutableState, results []MutableStateValidationResult, )
service/worker/scanner/executions/task.go:206
↓ 1 callersMethodhandleFirstReplicationTaskWithNewRun
( ctx context.Context, archetypeID chasm.ArchetypeID, wfCtx historyi.WorkflowContext, executionInfo *persi
service/history/ndc/workflow_state_replicator.go:490
↓ 1 callersMethodhandleFirstReplicationTaskWithoutNewRun
( ctx context.Context, archetypeID chasm.ArchetypeID, wfCtx historyi.WorkflowContext, executionInfo *persi
service/history/ndc/workflow_state_replicator.go:407
↓ 1 callersMethodhandleHistoryReplicationTask
( ctx context.Context, task *replicationspb.ReplicationTask, forceApply bool, )
service/history/replication/task_executor.go:207
↓ 1 callersMethodhandleNamespaceUpdateReplicationTask
handleNamespaceUpdateReplicationTask handles the namespace update replication task
common/namespace/nsreplication/replication_task_executor.go:249
↓ 1 callersMethodhandlePostCommandEagerExecuteActivity
( _ context.Context, attr *commandpb.ScheduleActivityTaskCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:570
↓ 1 callersFunctionhandlePredefinedCronStrings
(c string)
service/worker/scheduler/calendar.go:327
↓ 1 callersMethodhandleQuery
( ctx context.Context, task *workflowservice.PollWorkflowTaskQueueResponse, handler func(task *workflowserv
common/testing/taskpoller/taskpoller.go:420
↓ 1 callersMethodhandleRemoteGeneratedHistoryEvents
( ctx context.Context, workflowKey definition.WorkflowKey, baseExecutionInfo *workflowspb.BaseExecutionInfo
service/history/replication/eventhandler/history_events_handler.go:199
↓ 1 callersMethodhandleReplicationTask
( ctx context.Context, task *replicationspb.ReplicationTask, )
service/worker/replicator/replication_message_processor.go:237
↓ 1 callersMethodhandleReplicationTasks
()
service/worker/replicator/replication_message_processor.go:142
↓ 1 callersMethodhandleRetry
( ctx context.Context, backoffInterval time.Duration, failure *failurepb.Failure, newRunID string, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1421
↓ 1 callersMethodhandleReusePolicy
( ctx context.Context, shardContext historyi.ShardContext, newExecutionParams newExecutionParams, currentR
service/history/chasm_engine.go:1065
↓ 1 callersMethodhandleReusePolicy
handleReusePolicy is called when a StartExecution arrives for a business ID whose current run is closed or completed.
chasm/chasmtest/test_engine.go:387
↓ 1 callersMethodhandleSolError
(opEntry cacheEntry[C], solErr *serviceerrors.ShardOwnershipLost)
client/history/caching_redirector.go:200
↓ 1 callersMethodhandleStartOperationError
handleStartOperationError resolves a failed StartOperation attempt by transitioning the operation to its resulting state: terminally failed/canceled/t
components/nexusoperations/executors.go:533
↓ 1 callersMethodhandleSyncWorkflowStateTask
( ctx context.Context, task *replicationspb.ReplicationTask, forceApply bool, )
service/history/replication/task_executor.go:301
↓ 1 callersMethodhandleTask
( ctx context.Context, task taskDetail, )
service/worker/scanner/history/scavenger.go:251
↓ 1 callersMethodhandleTask
( ctx context.Context, opts *options, task *workflowservice.PollNexusTaskQueueResponse, handler func(task
common/testing/taskpoller/taskpoller.go:190
↓ 1 callersMethodhandleTaskQueueUserDataReplicationTask
( ctx context.Context, attrs *replicationspb.TaskQueueUserDataAttributes, )
service/worker/replicator/replication_message_processor.go:275
↓ 1 callersMethodhandleUseExistingWorkflowOnConflictOptions
( ctx context.Context, workflowKey definition.WorkflowKey, currentWorkflowConditionFailed *persistence.Curr
service/history/api/startworkflow/api.go:652
↓ 1 callersMethodhasBusinessIDAlias
hasBusinessIDAlias returns true if the component has a businessID alias configured via WithBusinessIDAlias option.
chasm/registrable_component.go:208
↓ 1 callersFunctionhasCallerSegment
(req quotas.Request)
common/persistence/client/quotas.go:298
↓ 1 callersMethodhasEnoughTimeForRetry
hasEnoughTimeForRetry checks if there is enough time left in the schedule-to-close timeout. If sufficient time remains, it will also return a valid re
chasm/lib/activity/activity.go:724
↓ 1 callersMethodhasFinishedDraining
hasFinishedDraining returns true if this is a draining backlog manager and all tasks have been fully drained (read and acked).
service/matching/pri_backlog_manager.go:409
↓ 1 callersMethodhasFinishedDraining
hasFinishedDraining returns true if this is a draining backlog manager and all tasks have been fully drained (read and acked).
service/matching/fair_backlog_manager.go:416
↓ 1 callersMethodhasMinVersionOld
hasMinVersionOld is only kept for replay consistency. Should not be used in any new place. TODO: remove with cleanup for AsyncSetCurrentAndRamping and
service/worker/workerdeployment/version_workflow.go:1483
↓ 1 callersMethodhasMoreBackfills
()
chasm/lib/scheduler/scheduler.go:531
↓ 1 callersFunctionhasNoLintComment
hasNoLintComment checks for //parallelize:ignore in the function's doc comment.
tools/parallelize/parallelize.go:161
↓ 1 callersFunctionhasParallelCall
hasParallelCall checks if the function body already contains <param>.Parallel().
tools/parallelize/parallelize.go:174
↓ 1 callersMethodhasRemainingTasks
()
common/tasks/interleaved_weighted_round_robin.go:378
↓ 1 callersMethodhasSuiteScoped
(t *testing.T)
tests/testcore/test_cluster_pool.go:220
↓ 1 callersMethodhasUnprocessedStarts
hasUnprocessedStarts reports whether any BufferedStart is still awaiting its initial ProcessBuffer pass (Attempt == 0).
chasm/lib/scheduler/invoker.go:324
↓ 1 callersFunctionhash
(s string)
common/testing/testvars/hash.go:7
↓ 1 callersMethodheartbeatLoop
(ctx context.Context)
service/worker/scanner/scheduleinvariants/invariants.go:165
↓ 1 callersFunctionhistoryMutated
(request *archiver.ArchiveHistoryRequest, historyBatches []*historypb.History, isLast bool)
common/archiver/gcloud/history_archiver.go:301
↓ 1 callersFunctionhistoryMutated
(request *archiver.ArchiveHistoryRequest, historyBatches []*historypb.History, isLast bool)
common/archiver/s3store/util.go:237
↓ 1 callersFunctionhistoryRoutingOptions
(reqType reflect.Type)
cmd/tools/genrpcwrappers/main.go:210
↓ 1 callersFunctionhttpStatusCodeToHandlerErrorType
(response *http.Response)
common/nexus/nexusrpc/client.go:425
↓ 1 callersFunctionidConflictPolicyFromProto
(p enumspb.NexusOperationIdConflictPolicy)
chasm/lib/nexusoperation/handler.go:288
↓ 1 callersFunctionidReusePolicyFromProto
(p enumspb.NexusOperationIdReusePolicy)
chasm/lib/nexusoperation/handler.go:277
↓ 1 callersFunctionidentifyCIBreakers
identifyCIBreakers finds tests that failed their final retry in a CI job. A test breaks CI if it has a failure with the "(final)" suffix in an artifac
tools/flakereport/parser.go:385
↓ 1 callersMethodidentity
()
chasm/lib/scheduler/scheduler.go:431
↓ 1 callersFunctionimmutableFieldsChanged
immutableFieldsChanged returns true if any of immutable fields changed.
common/persistence/cluster_metadata_store.go:204
↓ 1 callersMethodimportEvents
( workflowID string, runID string, versionHistory *historyspb.VersionHistory, eventBatches []*historypb.Hi
tests/xdc/stream_based_replication_test.go:332
↓ 1 callersMethodimportTestEvents
( historyClient historyservice.HistoryServiceClient, namespaceName namespace.Name, namespaceId namespace.ID
tests/xdc/stream_based_replication_test.go:191
↓ 1 callersMethodincrementShardRequestCount
(shardID int32)
common/persistence/health_signal_aggregator.go:113
↓ 1 callersMethodinit
()
service/history/queues/action_pending_task_count.go:82
↓ 1 callersMethodinit
()
common/dynamicconfig/file_based_client.go:124
↓ 1 callersMethodinitDependencies
()
common/persistence/client/factory.go:289
↓ 1 callersFunctioninitPrometheusListener
( config *PrometheusConfig, reg *prometheus.Registry, logger log.Logger, fatalOnListenerError bool, )
common/metrics/opentelemetry_provider.go:124
↓ 1 callersMethodinitScanner
(serializer serialization.Serializer)
service/worker/service.go:330
↓ 1 callersFunctioninitSeeds
()
cmd/tools/getproto/main.go:147
↓ 1 callersMethodinitSerializedCollectionNode
()
chasm/tree.go:758
↓ 1 callersMethodinitState
()
service/matching/pri_task_writer.go:140
↓ 1 callersMethodinitState
()
service/matching/fair_task_writer.go:143
↓ 1 callersFunctioninitSystemNamespaces
( ctx context.Context, cfg *config.Persistence, currentClusterName string, persistenceServiceResolver reso
temporal/server_impl.go:148
↓ 1 callersMethodinitVersionedTransitionInDB
()
service/history/workflow/mutable_state_impl.go:9630
↓ 1 callersMethodinitialize
()
service/matching/task_queue_partition_manager.go:230
↓ 1 callersMethodinitialize
()
common/authorization/default_token_key_provider.go:43
↓ 1 callersMethodinitialize
()
common/rpc/encryption/local_store_cert_provider.go:55
↓ 1 callersMethodinitialize
()
common/rpc/encryption/local_store_tls_provider.go:90
↓ 1 callersMethodinitializeDLQMetadata
( ctx context.Context, blob *commonpb.DataBlob, )
common/persistence/sql/queue.go:347
↓ 1 callersMethodinitializeDLQMetadata
( ctx context.Context, blob *commonpb.DataBlob, )
common/persistence/cassandra/queue_store.go:359
← previousnext →12,001–12,100 of 43,335, ranked by callers