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 callersFunctiontestRangeDeleteMessages
(ctx context.Context, t *testing.T, queue persistence.QueueV2)
common/persistence/tests/queue_v2_test_suite.go:196
↓ 1 callersFunctiontestRangeDeleteMessagesFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:437
↓ 1 callersFunctiontestRangeSelectFromQueueV2MessagesFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:344
↓ 1 callersFunctiontestRateLimit
testRateLimit applies only to V1, as V2 scheduler does not impose its own rate limiting.
tests/schedule_test.go:2919
↓ 1 callersMethodtestReadTasks
This method calls `tdbg dlq read`, verifying that it contains the correct replication tasks.
tests/xdc/history_replication_dlq_test.go:430
↓ 1 callersFunctiontestRefresh
testRefresh applies to V1 scheduler only; V2 does not support/need manual refresh.
tests/schedule_test.go:2765
↓ 1 callersMethodtestRespondWorkflowTaskCompletedSignalGeneration
()
service/history/history_engine_test.go:1800
↓ 1 callersFunctiontestRunDirectory
testRunDirectory tests all workflow histories in a specific run directory
service/worker/workerdeployment/replaytester/replay_test.go:83
↓ 1 callersMethodtestRunForceReplicationForContinueAsNew
( mockListWorkflows func(context.Context, *workflowservice.ListWorkflowExecutionsRequest) (*listWorkflowsResp
service/worker/migration/force_replication_workflow_test.go:237
↓ 1 callersFunctiontestScheduleContinuesAfterWorkflowRetryFailure
testScheduleContinuesAfterWorkflowRetryFailure verifies a schedule keeps firing actions after a scheduled workflow exhausts its retry policy and fails
tests/schedule_test.go:832
↓ 1 callersFunctiontestScheduleInternalTaskQueue
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1683
↓ 1 callersFunctiontestScheduledWorkflowContinueAsNewCompletion
testScheduledWorkflowContinueAsNewCompletion validates that the CHASM scheduler observes the completion of a scheduled workflow that continues-as-new
tests/schedule_test.go:922
↓ 1 callersFunctiontestSelectMetadataFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:485
↓ 1 callersMethodtestSelectMinStartTimeMaxStartTimeStatusCloseByTypeMultiple
( status enumspb.WorkflowExecutionStatus, )
common/persistence/sql/sqlplugin/tests/visibility.go:1254
↓ 1 callersMethodtestSelectMinStartTimeMaxStartTimeStatusCloseByTypeSingle
( status enumspb.WorkflowExecutionStatus, )
common/persistence/sql/sqlplugin/tests/visibility.go:1197
↓ 1 callersMethodtestSelectMinStartTimeMaxStartTimeStatusCloseSingle
( status enumspb.WorkflowExecutionStatus, )
common/persistence/sql/sqlplugin/tests/visibility.go:1065
↓ 1 callersFunctiontestSelectNameFromQueueV2MetadataFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:612
↓ 1 callersFunctiontestSelectNameFromQueueV2NegativeToken
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:629
↓ 1 callersFunctiontestSingleDateScheduleCloses
testSingleDateScheduleCloses verifies that a CHASM schedule configured with a single calendar date closes after its one workflow completes.
tests/schedule_test.go:3672
↓ 1 callersFunctiontestSkipsCHASMSentinelWhenDisabled
testSkipsCHASMSentinelWhenDisabled asserts that a V1 CreateSchedule does not create a CHASM sentinel when EnableCHASMSchedulerSentinels is off.
tests/schedule_test.go:2357
↓ 1 callersFunctiontestSkipsWorkflowSentinelWhenDisabled
testSkipsWorkflowSentinelWhenDisabled asserts that a CHASM CreateSchedule does not start the dummy V1 workflow when EnableCHASMSchedulerSentinels is o
tests/schedule_test.go:2308
↓ 1 callersFunctiontestStateSizeBytesReported
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:2178
↓ 1 callersMethodtestSuccess
( t *testing.T, ms *workflow.MutableStateImpl, workflowEvents []*persistence.WorkflowEvents, )
service/history/workflow/workflow_test/mutable_state_impl_test.go:338
↓ 1 callersMethodtestTaskQueueRateLimitName
(nPartitions, nWorkers int, useNewMatching bool)
tests/task_queue_test.go:178
↓ 1 callersFunctiontestUpdateIntervalTakesEffect
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1133
↓ 1 callersFunctiontestUpdateMetadataFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:461
↓ 1 callersFunctiontestUpdateScheduleBlobSizeLimit
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:3529
↓ 1 callersFunctiontestUpdateScheduleMemo
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:3131
↓ 1 callersFunctiontestUpdateScheduleMemoOnly
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:3314
↓ 1 callersFunctiontestUpdateScheduleMemoRejected
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:3255
↓ 1 callersFunctiontestUpdateScheduleRequestIDTooLong
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:3477
↓ 1 callersMethodtestWFTFailedEvent
( t *testing.T, wft *historyi.WorkflowTaskInfo, event *historypb.HistoryEvent, )
service/history/workflow/workflow_test/mutable_state_impl_test.go:260
↓ 1 callersMethodthrottledLogger
()
service/matching/task_reader.go:292
↓ 1 callersFunctiontimeComparator
(t1, t2 time.Time, timeTolerance time.Duration)
common/persistence/persistence-tests/persistence_test_base.go:445
↓ 1 callersFunctiontimeSkippingTimerTaskFromProto
(info *persistencespb.TimerTaskInfo)
common/persistence/serialization/task_serializers.go:157
↓ 1 callersFunctiontimeSkippingTimerTaskToProto
(task *tasks.TimeSkippingTimerTask)
common/persistence/serialization/task_serializers.go:145
↓ 1 callersFunctiontimerActivityRetryTaskFromProto
( activityRetryTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:849
↓ 1 callersFunctiontimerActivityRetryTaskToProto
( activityRetryTimer *tasks.ActivityRetryTimerTask, )
common/persistence/serialization/task_serializers.go:830
↓ 1 callersFunctiontimerActivityTaskFromProto
( activityTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:812
↓ 1 callersFunctiontimerActivityTaskToProto
( activityTimer *tasks.ActivityTimeoutTask, )
common/persistence/serialization/task_serializers.go:794
↓ 1 callersMethodtimerCallback
()
common/authorization/default_token_key_provider.go:97
↓ 1 callersMethodtimerCallback
()
common/rpc/encryption/local_store_tls_provider.go:404
↓ 1 callersFunctiontimerChasmPureTaskFromProto
(info *persistencespb.TimerTaskInfo)
common/persistence/serialization/task_serializers.go:254
↓ 1 callersFunctiontimerChasmPureTaskToProto
(task *tasks.ChasmTaskPure)
common/persistence/serialization/task_serializers.go:170
↓ 1 callersFunctiontimerChasmTaskFromProto
(info *persistencespb.TimerTaskInfo)
common/persistence/serialization/task_serializers.go:240
↓ 1 callersFunctiontimerChasmTaskToProto
(task *tasks.ChasmTask)
common/persistence/serialization/task_serializers.go:186
↓ 1 callersMethodtimerInMilliseconds
(timer string)
common/metrics/otel_metrics_handler.go:161
↓ 1 callersMethodtimerInSeconds
(timer string)
common/metrics/otel_metrics_handler.go:175
↓ 1 callersFunctiontimerUserTaskFromProto
( userTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:884
↓ 1 callersFunctiontimerUserTaskToProto
( userTimer *tasks.UserTimerTask, )
common/persistence/serialization/task_serializers.go:867
↓ 1 callersFunctiontimerWorkflowCleanupTaskFromProto
( workflowCleanupTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:1002
↓ 1 callersFunctiontimerWorkflowCleanupTaskToProto
( workflowCleanupTimer *tasks.DeleteHistoryEventTask, )
common/persistence/serialization/task_serializers.go:963
↓ 1 callersFunctiontimerWorkflowDelayTaskFromProto
( workflowDelayTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:778
↓ 1 callersFunctiontimerWorkflowDelayTaskToProto
( workflowDelayTimer *tasks.WorkflowBackoffTimerTask, )
common/persistence/serialization/task_serializers.go:760
↓ 1 callersFunctiontimerWorkflowExecutionFromProto
( workflowExecutionTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:951
↓ 1 callersFunctiontimerWorkflowExecutionToProto
( workflowExecutionTimer *tasks.WorkflowExecutionTimeoutTask, )
common/persistence/serialization/task_serializers.go:917
↓ 1 callersFunctiontimerWorkflowRunFromProto
( workflowRunTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:936
↓ 1 callersFunctiontimerWorkflowRunToProto
( workflowRunTimer *tasks.WorkflowRunTimeoutTask, )
common/persistence/serialization/task_serializers.go:899
↓ 1 callersFunctiontimerWorkflowTaskFromProto
( workflowTimer *persistencespb.TimerTaskInfo, )
common/persistence/serialization/task_serializers.go:741
↓ 1 callersFunctiontimerWorkflowTaskToProto
( workflowTimer *tasks.WorkflowTaskTimeoutTask, )
common/persistence/serialization/task_serializers.go:722
↓ 1 callersFunctiontlsCN
(state tls.ConnectionState)
common/auth/tls_config_helper.go:74
↓ 1 callersMethodtlsConfig
(serviceName primitives.ServiceName)
tests/testcore/clients.go:155
↓ 1 callersFunctiontoAdminTask
(historyTasks []tasks.Task)
service/history/api/listtasks/api.go:76
↓ 1 callersMethodtoBase
()
chasm/lib/nexusoperation/task_handler_base.go:55
↓ 1 callersMethodtoCassandraConfig
()
tools/cassandra/cqlclient.go:113
↓ 1 callersFunctiontoLocalHealthProto
(in grpchealthspb.HealthCheckResponse_ServingStatus)
service/history/deep_health_check.go:112
↓ 1 callersFunctiontoVersionInfo
(resp *versioninfo.VersionCheckResponse)
service/frontend/version_checker.go:175
↓ 1 callersFunctiontombstoneExists
( tombstones []*persistencespb.StateMachineTombstone, expectedTombstone *persistencespb.StateMachineTombston
service/history/workflow/mutable_state_impl_test.go:5138
↓ 1 callersMethodtotalCallbackCount
totalCallbackCount returns the total number of callbacks across workflow-level and all update-level callback maps.
chasm/lib/workflow/workflow.go:124
↓ 1 callersMethodtotalTasks
returns the total number of tasks in the buffer
service/matching/task_tracker.go:32
↓ 1 callersMethodtotals
()
common/testing/objectleak/report.go:138
↓ 1 callersMethodtrack
(root any)
common/testing/objectleak/walker.go:31
↓ 1 callersFunctiontrackPointerObject
(ptr unsafe.Pointer, addr uintptr, path path, typeName string)
common/testing/objectleak/walker.go:90
↓ 1 callersFunctiontransferActivityTaskFromProto
( activityTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:431
↓ 1 callersFunctiontransferActivityTaskToProto
( activityTask *tasks.ActivityTask, )
common/persistence/serialization/task_serializers.go:410
↓ 1 callersFunctiontransferChasmTaskFromProto
(task *persistencespb.TransferTaskInfo)
common/persistence/serialization/task_serializers.go:95
↓ 1 callersFunctiontransferChasmTaskToProto
(task *tasks.ChasmTask)
common/persistence/serialization/task_serializers.go:47
↓ 1 callersFunctiontransferChildWorkflowTaskFromProto
( signalTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:588
↓ 1 callersFunctiontransferChildWorkflowTaskToProto
( childWorkflowTask *tasks.StartChildExecutionTask, )
common/persistence/serialization/task_serializers.go:568
↓ 1 callersFunctiontransferCloseTaskFromProto
( closeTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:634
↓ 1 callersFunctiontransferCloseTaskToProto
( closeTask *tasks.CloseExecutionTask, )
common/persistence/serialization/task_serializers.go:606
↓ 1 callersFunctiontransferDeleteExecutionTaskFromProto
( deleteExecutionTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:705
↓ 1 callersFunctiontransferDeleteExecutionTaskToProto
( deleteExecutionTask *tasks.DeleteExecutionTask, )
common/persistence/serialization/task_serializers.go:687
↓ 1 callersFunctiontransferRequestCancelTaskFromProto
( requestCancelTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:508
↓ 1 callersFunctiontransferRequestCancelTaskToProto
( requestCancelTask *tasks.CancelExecutionTask, )
common/persistence/serialization/task_serializers.go:488
↓ 1 callersFunctiontransferResetTaskFromProto
( resetTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:672
↓ 1 callersFunctiontransferResetTaskToProto
( resetTask *tasks.ResetWorkflowTask, )
common/persistence/serialization/task_serializers.go:652
↓ 1 callersFunctiontransferSignalTaskFromProto
( signalTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:548
↓ 1 callersFunctiontransferSignalTaskToProto
( signalTask *tasks.SignalExecutionTask, )
common/persistence/serialization/task_serializers.go:528
↓ 1 callersFunctiontransferWorkflowTaskFromProto
( workflowTask *persistencespb.TransferTaskInfo, )
common/persistence/serialization/task_serializers.go:470
↓ 1 callersFunctiontransferWorkflowTaskToProto
( workflowTask *tasks.WorkflowTask, )
common/persistence/serialization/task_serializers.go:449
↓ 1 callersFunctiontransitionHistoryRangeForVersion
transitionHistoryRangeForVersion finds the index and transition count range in the given history for the given version.
common/persistence/transitionhistory/transition_history.go:128
↓ 1 callersMethodtriggerAutoEnable
(env *testcore.TestEnv)
tests/priority_fairness_test.go:456
↓ 1 callersMethodtriggerTransientWFT
Trigger a normal task and then fail the task twice to trigger a transient WFT
tests/versioning_3_test.go:3489
↓ 1 callersFunctiontruncateAlertDetails
truncateAlertDetails keeps alert payloads from bloating the JUnit artifact.
tools/testrunner/junit.go:193
↓ 1 callersFunctiontryChasmMapper
(name string, chasmMapper *chasm.VisibilitySearchAttributesMapper)
common/persistence/visibility/store/query/resolve.go:85
↓ 1 callersFunctiontryDecodePayloadJSON
(obj map[string]any, encoder codec.JSONPBEncoder)
tools/tdbg/proto_decoder.go:49
↓ 1 callersFunctiontryDirectAndPrefixedLookup
(name string, saTypeMap searchattribute.NameTypeMap)
common/persistence/visibility/store/query/resolve.go:102
↓ 1 callersMethodtryDispatchTaskDirectly
( task T, )
common/tasks/interleaved_weighted_round_robin.go:368
↓ 1 callersMethodtryEnqueueLocked
tryEnqueueLocked enqueues a task into the pool's buffer if it is under capacity. Returns true if the task was enqueued, otherwise returns false. Must
common/tasks/dynamic_worker_pool_scheduler.go:147
← previousnext →13,201–13,300 of 43,335, ranked by callers