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 callersMethodtaskQueueRateLimitTest
(nPartitions, nWorkers int, timeToDrain time.Duration, useNewMatching bool)
tests/task_queue_test.go:75
↓ 1 callersMethodtaskWorker
( ctx context.Context, taskCh chan taskDetail, )
service/worker/scanner/history/scavenger.go:174
↓ 1 callersMethodtaskWriterLoop
()
service/matching/pri_task_writer.go:152
↓ 1 callersMethodtaskWriterLoop
()
service/matching/task_writer.go:154
↓ 1 callersMethodtaskWriterLoop
()
service/matching/fair_task_writer.go:155
↓ 1 callersMethodtearDownSdk
()
tests/testcore/functional_test_base.go:503
↓ 1 callersFunctionterminalField
(fieldPath string)
cmd/tools/genroutingkeyextractor/main.go:131
↓ 1 callersMethodterminateMutableState
( lastWriteVersion int64, incomingLastWriteVersion int64, )
service/history/ndc/workflow.go:266
↓ 1 callersMethodterminateWorkflow
(ex *commonpb.WorkflowExecution)
service/worker/scheduler/workflow.go:1633
↓ 1 callersMethodterminateWorkflow
( ctx context.Context, scheduler *Scheduler, target *commonpb.WorkflowExecution, )
chasm/lib/scheduler/invoker_tasks.go:707
↓ 1 callersFunctionterminateWorkflowAction
( newRunID string, parentExecutionInfo *workflowspb.ParentExecutionInfo, childWorkflowOnly bool, )
service/history/api/workflow_id_dedup.go:202
↓ 1 callersMethodterminateWorkflows
terminateWorkflows does a best-effort attempt to terminate all workflow executions provided in targets.
chasm/lib/scheduler/invoker_tasks.go:299
↓ 1 callersFunctiontestAllRunDirectories
testAllRunDirectories tests all directories prepended with "run_" since they contain replay test data. For each workflow implementation version we run
service/worker/workerdeployment/replaytester/replay_test.go:63
↓ 1 callersFunctiontestBasics
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:261
↓ 1 callersFunctiontestBeginTxFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:303
↓ 1 callersFunctiontestBufferSizeReportedWhenBuffered
testBufferSizeReportedWhenBuffered verifies that ScheduleInfo.BufferSize is populated by both the V1 and V2 (CHASM) schedulers when at least one fire
tests/schedule_test.go:144
↓ 1 callersFunctiontestCHASMCanListV1Schedules
testCHASMCanListV1Schedules tests that a schedule created in the V1 stack will also be visible in the V2 stack.
tests/schedule_test.go:2694
↓ 1 callersFunctiontestCHASMUnpauseResumesProcessing
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:3388
↓ 1 callersFunctiontestCassandraNexusEndpointStore
(t *testing.T, cluster *cassandra.TestCluster, tableVersion *atomic.Int64)
common/persistence/tests/cassandra_test.go:1257
↓ 1 callersFunctiontestCassandraNexusEndpointStoreConcurrentCreate
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/cassandra_test.go:1276
↓ 1 callersFunctiontestCassandraNexusEndpointStoreConcurrentCreateAndUpdate
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/cassandra_test.go:1373
↓ 1 callersFunctiontestCassandraNexusEndpointStoreConcurrentUpdate
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/cassandra_test.go:1321
↓ 1 callersFunctiontestCassandraNexusEndpointStoreConcurrentUpdateAndDelete
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/cassandra_test.go:1443
↓ 1 callersFunctiontestCassandraNexusEndpointStoreDeleteWhilePaging
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/cassandra_test.go:1507
↓ 1 callersFunctiontestCassandraQueueV2
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:363
↓ 1 callersFunctiontestCassandraQueueV2ConcurrentConflicts
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:392
↓ 1 callersFunctiontestCassandraQueueV2ConcurrentRangeDeleteMessages
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:928
↓ 1 callersFunctiontestCassandraQueueV2DataCorruption
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:348
↓ 1 callersFunctiontestCassandraQueueV2EnqueueErrEnqueueMessageConflict
testCassandraQueueV2EnqueueErrEnqueueMessageConflict tests that when there are concurrent inserts to the queue, only one of them is accepted if they t
common/persistence/tests/cassandra_test.go:558
↓ 1 callersFunctiontestCassandraQueueV2ErrCreateQueueQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:843
↓ 1 callersFunctiontestCassandraQueueV2ErrEnqueueMessageGetMaxMessageIDQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:486
↓ 1 callersFunctiontestCassandraQueueV2ErrEnqueueMessageQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:730
↓ 1 callersFunctiontestCassandraQueueV2ErrGetMessagesQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:706
↓ 1 callersFunctiontestCassandraQueueV2ErrGetQueueQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:819
↓ 1 callersFunctiontestCassandraQueueV2ErrInvalidPayload
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:790
↓ 1 callersFunctiontestCassandraQueueV2ErrInvalidPayloadEncodingType
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:750
↓ 1 callersFunctiontestCassandraQueueV2ErrInvalidQueueMessageEncodingType
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:662
↓ 1 callersFunctiontestCassandraQueueV2ErrListQueuesGetMaxMessageIDQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:506
↓ 1 callersFunctiontestCassandraQueueV2ErrRangeDeleteMessagesGetMaxMessageIDQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:463
↓ 1 callersFunctiontestCassandraQueueV2ErrRangeDeleteMessagesQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:861
↓ 1 callersFunctiontestCassandraQueueV2ErrRangeDeleteMessagesUpdateQueueQuery
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:442
↓ 1 callersFunctiontestCassandraQueueV2MinMessageIDOptimization
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:882
↓ 1 callersFunctiontestCassandraQueueV2MultiplePartitions
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:529
↓ 1 callersFunctiontestCassandraQueueV2MultiplePartitionsListQueues
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:1106
↓ 1 callersFunctiontestCassandraQueueV2MultiplePartitionsRangeDelete
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:1068
↓ 1 callersFunctiontestCassandraQueueV2MultiplePartitionsReadMessages
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:1085
↓ 1 callersFunctiontestCassandraQueueV2QueryErrors
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:403
↓ 1 callersFunctiontestCassandraQueueV2RangeDeleteUpperBoundHigherThanMaxMessageID
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:1126
↓ 1 callersFunctiontestCassandraQueueV2RepeatedRangeDelete
(t *testing.T, cluster *cassandra.TestCluster)
common/persistence/tests/cassandra_test.go:1145
↓ 1 callersFunctiontestCommitTxFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:283
↓ 1 callersFunctiontestCountSchedules
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1318
↓ 1 callersFunctiontestCreateOrUpdateNexusEndpointExpectedErrors
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/nexus_endpoint_suite.go:179
↓ 1 callersFunctiontestCreateScheduleAlreadyExists
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:2411
↓ 1 callersFunctiontestCreatesCHASMSentinel
testCreatesCHASMSentinel tests that creating a V1 schedule also creates a CHASM sentinel to reserve the schedule ID in the CHASM execution space.
tests/schedule_test.go:2223
↓ 1 callersFunctiontestCreatesWorkflowSentinel
testCreatesWorkflowSentinel tests that creating a CHASM schedule also starts a dummy workflow to reserve the schedule ID in the V1 workflow ID-space.
tests/schedule_test.go:2115
↓ 1 callersFunctiontestDeleteNexusEndpointExpectedErrors
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/nexus_endpoint_suite.go:278
↓ 1 callersFunctiontestDeletedScheduleOperations
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:205
↓ 1 callersFunctiontestDuration
()
tests/mixedbrain/mixed_brain_test.go:20
↓ 1 callersMethodtestFailure
( t *testing.T, ms *workflow.MutableStateImpl, wft *historyi.WorkflowTaskInfo, workflowEvents []*persisten
service/history/workflow/workflow_test/mutable_state_impl_test.go:299
↓ 1 callersFunctiontestFutureActionTimesAdvanceWhilePaused
testFutureActionTimesAdvanceWhilePaused verifies that ListSchedules returns up-to-date FutureActionTimes for a paused schedule. CHASM's always-on Gene
tests/schedule_test.go:3850
↓ 1 callersFunctiontestGetLastMessageIDFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:323
↓ 1 callersFunctiontestGetLastMessageIDForDeleteFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:414
↓ 1 callersFunctiontestGetPartitionFailsForRangeDelete
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:385
↓ 1 callersFunctiontestHappyPath
( ctx context.Context, t *testing.T, queue persistence.QueueV2, queueType persistence.QueueV2Type, queueN
common/persistence/tests/queue_v2_test_suite.go:135
↓ 1 callersFunctiontestHistoryTaskQueueManagerCreateQueueErr
(t *testing.T, queue persistence.QueueV2)
common/persistence/tests/history_task_queue_manager_test_suite.go:131
↓ 1 callersFunctiontestHistoryTaskQueueManagerDeleteTasks
(t *testing.T, manager *persistence.HistoryTaskQueueManagerImpl)
common/persistence/tests/history_task_queue_manager_test_suite.go:232
↓ 1 callersFunctiontestHistoryTaskQueueManagerDeleteTasksErr
(t *testing.T, queue persistence.QueueV2)
common/persistence/tests/history_task_queue_manager_test_suite.go:302
↓ 1 callersFunctiontestHistoryTaskQueueManagerEnqueueTasks
(t *testing.T, manager persistence.HistoryTaskQueueManager)
common/persistence/tests/history_task_queue_manager_test_suite.go:144
↓ 1 callersFunctiontestHistoryTaskQueueManagerEnqueueTasksErr
(t *testing.T, queue persistence.QueueV2)
common/persistence/tests/history_task_queue_manager_test_suite.go:191
↓ 1 callersFunctiontestHistoryTaskQueueManagerErrDeserializeHistoryTask
( t *testing.T, queue persistence.QueueV2, manager persistence.HistoryTaskQueueManager, )
common/persistence/tests/history_task_queue_manager_test_suite.go:211
↓ 1 callersFunctiontestInactiveNS
(name string, state enumspb.NamespaceState)
service/worker/pernamespaceworker_test.go:715
↓ 1 callersFunctiontestInput
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:691
↓ 1 callersFunctiontestInsertIntoQueueV2MetadataFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:368
↓ 1 callersFunctiontestInvalidMetadataEncoding
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:536
↓ 1 callersFunctiontestInvalidMetadataPayload
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:513
↓ 1 callersFunctiontestLastCompletionAndError
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:755
↓ 1 callersFunctiontestLimitMemoSpecSize
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1247
↓ 1 callersFunctiontestListBeforeRun
testListBeforeRun only applies to V1, as V2 scheduler does not involve the per-NS worker or workflow.
tests/schedule_test.go:2871
↓ 1 callersFunctiontestListNexusEndpointsExpectedErrors
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/nexus_endpoint_suite.go:236
↓ 1 callersFunctiontestListQueueFailsToExtractQueueMetadata
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:696
↓ 1 callersFunctiontestListQueueFailsToGetLastMessageID
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:673
↓ 1 callersFunctiontestListQueues
(ctx context.Context, t *testing.T, queue persistence.QueueV2)
common/persistence/tests/queue_v2_test_suite.go:392
↓ 1 callersFunctiontestListQueuesGetPartitionFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:642
↓ 1 callersFunctiontestListScheduleMatchingTimes
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1198
↓ 1 callersFunctiontestListSchedulesFilterAndEntryFields
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1459
↓ 1 callersFunctiontestListSchedulesFilterByScheduleID
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1552
↓ 1 callersFunctiontestListSchedulesPagination
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1388
↓ 1 callersFunctiontestListSchedulesReturnsWorkflowStatus
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:1038
↓ 1 callersFunctiontestMigrationCallbackAttach
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:2564
↓ 1 callersFunctiontestMultiDateScheduleCloses
testMultiDateScheduleCloses verifies that a CHASM schedule configured with two calendar dates closes after both workflows complete.
tests/schedule_test.go:3754
↓ 1 callersFunctiontestNextTimeCache
testNextTimeCache only applies to V1.
tests/schedule_test.go:2974
↓ 1 callersFunctiontestNexusEndpointsStoreSteadyState
(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)
common/persistence/tests/nexus_endpoint_suite.go:42
↓ 1 callersFunctiontestOnlyStacktrace
testOnlyStacktrace removes all but the test stacktraces from the full stacktrace.
tools/testrunner/log.go:50
↓ 1 callersFunctiontestPanic
(panicObj any)
common/log/panic_test.go:27
↓ 1 callersFunctiontestPatchRejectsExcessBackfillers
(t *testing.T, newContext contextFactory)
tests/schedule_test.go:2486
↓ 1 callersFunctiontestPausedDropsCatchup
testPausedDropsCatchup verifies that an action scheduled by the spec during a paused window is NOT replayed when the schedule is unpaused. The test us
tests/schedule_test.go:3913
↓ 1 callersMethodtestPinnedWorkflowWithLateActivityPoller
(env *testcore.TestEnv)
tests/versioning_3_test.go:580
↓ 1 callersMethodtestPollComponentWait
(useEmptyRunID bool)
service/history/chasm_engine_test.go:1089
↓ 1 callersFunctiontestQueueInsertFails
(ctx context.Context, t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:260
↓ 1 callersFunctiontestRangeDeleteActuallyDeletes
(ctx context.Context, t *testing.T, db sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:569
← previousnext →13,101–13,200 of 43,335, ranked by callers