MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 2 callersMethodset
set sets rt to call f after delay. set to <= 0 stops the timer.
service/matching/matcher_data.go:647
↓ 2 callersMethodsetAndCheckOverrideWithExpectedOutput
(env *testcore.TestEnv, tv *testvars.TestVars, inputOverride, expectedOutputOverride *workflowpb.VersioningOve
tests/worker_deployment_version_test.go:1857
↓ 2 callersMethodsetCurrentVersionAllowNoPollersOption
( env *VersioningTestEnv, tv *testvars.TestVars, ignoreMissingTaskQueues, allowNoPollers, ensureSystemWorkf
tests/worker_deployment_test.go:3398
↓ 2 callersMethodsetDefaultParams
(t *testing.T)
service/worker/dlq/workflow_test.go:554
↓ 2 callersFunctionsetDefaultPerUnitHistogramBoundaries
(clientConfig *ClientConfig)
common/metrics/config.go:376
↓ 2 callersMethodsetEnabled
(enabled bool)
common/nexus/endpoint_registry.go:121
↓ 2 callersMethodsetPriority
(task *internalTask)
service/matching/pri_backlog_manager.go:439
↓ 2 callersMethodsetReadLevelAfterGap
(newReadLevel int64)
service/matching/ack_manager.go:63
↓ 2 callersMethodsetRemoveFunc
setRemoveFunc sets the function to remove the task from the matcher. It returns true if the task is still valid and the function was set, false if the
service/matching/task.go:348
↓ 2 callersMethodsetSerializedNode
( nodePath []string, encodedPath string, serializedNode *persistencespb.ChasmNode, )
chasm/tree.go:772
↓ 2 callersFunctionsetTestComponentFields
(c *TestComponent, backend *MockNodeBackend)
chasm/test_component_test.go:185
↓ 2 callersMethodsetTimerLocked
(newTmr clock.Timer)
common/dynamicconfig/gradual_change.go:191
↓ 2 callersMethodsetVersionSummaryDraining
(version string, routingUpdateTime *timestamppb.Timestamp)
service/worker/workerdeployment/workflow.go:1102
↓ 2 callersMethodsetupCache
()
service/history/api/respondactivitytaskfailed/api_test.go:452
↓ 2 callersMethodsetupCluster
(options ...TestClusterOption)
tests/testcore/functional_test_base.go:298
↓ 2 callersFunctionsetupFsEmulation
(s3cli *mocks.MockS3API)
common/archiver/s3store/history_archiver_test.go:87
↓ 2 callersMethodsetupLookAheadMock
( hasLookAheadTask bool, )
service/history/queues/queue_scheduled_test.go:300
↓ 2 callersFunctionsetupMutableStateWithStartedActivity
setupMutableStateWithStartedActivity creates mock shard and mutable state with an activity that is already started (StartedEventId != EmptyEventID). T
service/history/api/recordactivitytaskstarted/api_test.go:284
↓ 2 callersMethodsetupNamespaceRegistry
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:578
↓ 2 callersMethodsetupReadComponent
()
chasm/lib/nexusoperation/operation_tasks_test.go:140
↓ 2 callersMethodsetupReadComponent
()
chasm/lib/nexusoperation/cancellation_tasks_test.go:105
↓ 2 callersMethodsetupRecordActivityTaskStartedMock
(tlName string)
service/matching/matching_engine_test.go:4630
↓ 2 callersMethodsetupSQLiteDatabase
(cfg *config.SQL, conn *sqlx.DB, logger log.Logger)
common/persistence/sql/sqlplugin/sqlite/plugin.go:152
↓ 2 callersMethodsetupStartWorkflowExecutionDedup
(startTime *timestamppb.Timestamp)
service/history/history_engine2_test.go:1586
↓ 2 callersMethodsetupStartWorkflowExecutionForTerminate
()
service/history/history_engine2_test.go:1613
↓ 2 callersMethodsetupTemplate
setupTemplate handles template configuration
tools/elasticsearch/tasks.go:50
↓ 2 callersMethodsetupUpdateComponent
()
chasm/lib/nexusoperation/operation_tasks_test.go:169
↓ 2 callersMethodsetupUpdateComponent
()
chasm/lib/nexusoperation/cancellation_tasks_test.go:120
↓ 2 callersFunctionshardTotals
(smap map[string]float64, shards int, salt string)
tools/optimize-test-sharding/main.go:273
↓ 2 callersMethodshortSHA
()
tools/ci-notify/types.go:69
↓ 2 callersMethodshouldGenerateChecksum
()
service/history/workflow/mutable_state_impl.go:9038
↓ 2 callersMethodshouldPrune
(t reflect.Type)
common/testing/objectleak/walker.go:86
↓ 2 callersMethodshouldReadMoreLocked
()
service/matching/fair_task_reader.go:211
↓ 2 callersFunctionshouldReapplyEvent
shouldReapplyEvent returns true if the event should be reapplied to the workflow execution.
service/history/workflow/util.go:228
↓ 2 callersMethodshouldRouteToExecutionQueueScheduler
(task T)
common/tasks/execution_aware_scheduler.go:124
↓ 2 callersMethodshouldUpdateMetadataOnAppendLocked
shouldUpdateMetadataOnAppendLocked returns whether a task append should also write the metadata blob. This is always true when enough time has passed
service/matching/db.go:291
↓ 2 callersMethodshouldVerifyChecksum
()
service/history/workflow/mutable_state_impl.go:9045
↓ 2 callersMethodsignalAndWaitForDrained
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/worker_deployment_version_test.go:715
↓ 2 callersMethodsignalDemoteVersion
signalDemoteVersion sends a signal to a version workflow to demote it with the given routing config. The version workflow will determine its new statu
service/worker/workerdeployment/workflow.go:1587
↓ 2 callersMethodsignalPropagationComplete
signalPropagationComplete sends a signal to the deployment workflow when async propagation completes
service/worker/workerdeployment/version_workflow.go:1464
↓ 2 callersMethodslideBase
slideBase increases the base by delta, subtracting delta from all cells. Cells that would go negative are clamped to 0 (those keys are "dragged up").
service/matching/counter/cmsketch.go:227
↓ 2 callersFunctionsoftDeadlockTimeout
()
common/testing/await/require_ctx.go:22
↓ 2 callersFunctionsortAncestors
(ans []*persistencespb.HistoryBranchRange)
common/persistence/history_manager_util.go:126
↓ 2 callersFunctionsortAndFilterFiles
sortAndFilterFiles sort visibility record file names based on close timestamp (desc) and use hashed runID to break ties. if a nextPageToken is give, i
common/archiver/filestore/visibility_archiver.go:255
↓ 2 callersFunctionsortAndFilterVersions
sortAndFilterVersions returns a sorted list of semantic versions the fall within the range (startVerExcl, endVerIncl]. If endVerIncl is not specified,
tools/common/schema/updatetask.go:312
↓ 2 callersMethodsortedSummaries
()
service/worker/workerdeployment/workflow.go:1757
↓ 2 callersFunctionspeculativeWorkflowTaskOutcomes
( capture *testcore.GlobalMetricCapture, )
tests/update_workflow_test.go:36
↓ 2 callersMethodsplit
( thisScope Scope, thatScope Scope, )
service/history/queues/tracker.go:28
↓ 2 callersFunctionsplitBufferedStartsForLegacy
( starts []*schedulespb.BufferedStart, )
chasm/lib/scheduler/migration/migration.go:393
↓ 2 callersFunctionsplitSearchAttributes
splitSearchAttributes splits decoded search attributes into CHASM and custom attributes.
common/persistence/visibility/visibility_manager_impl.go:246
↓ 2 callersMethodsplitTask
()
service/history/ndc/replication_task.go:49
↓ 2 callersFunctionsplitUserAndChasmMemo
splitUserAndChasmMemo extracts user memo and CHASM memo from the combined memo.
common/persistence/visibility/visibility_manager_impl.go:260
↓ 2 callersFunctionstandbyTimerTaskPostActionTaskDiscarded
( _ context.Context, taskInfo tasks.Task, postActionInfo any, logger log.Logger, )
service/history/ndc_standby_task_util.go:67
↓ 2 callersMethodstart
(controller *ControllerImpl)
service/history/shard/ownership.go:60
↓ 2 callersMethodstartActivityWithType
(ctx context.Context, activityID string, taskQueue string, activityType *commonpb.ActivityType)
tests/activity_standalone_test.go:6335
↓ 2 callersMethodstartAndAcceptUpdateInCluster1ThenFailoverTo2AndCompleteUpdate
Start update in cluster0, run it through to acceptance, replicate it to cluster1, then failover to 2 and complete the update there.
tests/xdc/history_replication_signals_and_updates_test.go:441
↓ 2 callersFunctionstartChildWorkflowCommand
(tv *testvars.TestVars)
tests/versioning_3_test.go:2340
↓ 2 callersMethodstartDrainage
(ctx workflow.Context)
service/worker/workerdeployment/version_workflow.go:473
↓ 2 callersMethodstartPinnedWorkflow
(ctx context.Context, env *testcore.TestEnv, tv *testvars.TestVars)
tests/worker_deployment_version_test.go:511
↓ 2 callersFunctionstartServerProcess
(t *testing.T, name, binary, configDir, logPath string)
tests/mixedbrain/server_util.go:33
↓ 2 callersFunctionstartTestServer
(t *testing.T, opt ...grpc.ServerOption)
chasm/interceptor_test.go:97
↓ 2 callersMethodstartToCloseTimeoutTask
startToCloseTimeoutTask returns the StartToCloseTimeout task if the timeout is set. This task is created when an operation transitions to the STARTED
components/nexusoperations/statemachine.go:161
↓ 2 callersMethodstartVersion
(ctx workflow.Context, args *deploymentspb.StartWorkerDeploymentVersionRequest)
service/worker/workerdeployment/workflow.go:1719
↓ 2 callersMethodstartVersionedWorkflow
(ctx context.Context, env *testcore.TestEnv, tv *testvars.TestVars, behavior workflow.VersioningBehavior)
tests/worker_deployment_version_test.go:484
↓ 2 callersMethodstartWithMemoHelper
helper function for TestStartWithMemo and TestSignalWithStartWithMemo to reduce duplicate code
tests/workflow_memo_test.go:121
↓ 2 callersFunctionstartWorkflowExecutionRequestIDMatches
(requestID string)
chasm/lib/scheduler/invoker_execute_task_test.go:575
↓ 2 callersFunctionstartWorkflowRequest
(s testcore.Env, tv *testvars.TestVars)
tests/workflow_utils.go:18
↓ 2 callersFunctionstatusAdmitted
()
service/history/workflow/update/status.go:19
↓ 2 callersFunctionstatusCompleted
(outcome *updatepb.Outcome)
service/history/workflow/update/status.go:40
↓ 2 callersFunctionstatusOfInternalWorkflowMutation
( mutation *InternalWorkflowMutation, historyStatistics *HistoryStatistics, )
common/persistence/size.go:104
↓ 2 callersFunctionstickyWorkerAvailable
We use a very short timeout for considering a sticky worker available, since tasks can also be processed on the normal queue.
service/matching/matching_engine.go:3437
↓ 2 callersFunctionstopManager
(t *testing.T, manager *PerNamespaceWorkerManager)
service/worker/pernamespaceworker_test.go:81
↓ 2 callersFunctionstringMap
(a []string, f func(string) string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:88
↓ 2 callersFunctionstringMap
(a []string, f func(string) string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:55
↓ 2 callersFunctionstringMap
(a []string, f func(string) string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:54
↓ 2 callersMethodstructuredRef
(Component)
chasm/context.go:67
↓ 2 callersFunctionsubtractStatsByPriority
(into, sub map[int32]*taskqueuepb.TaskQueueStats)
service/matching/task_queue_partition_manager.go:1855
↓ 2 callersFunctionsuiteRunKey
suiteRunKey returns a string that uniquely identifies a single (CI run × DB config) pair. Each workflow run may spawn multiple matrix jobs sharing the
tools/flakereport/parser.go:420
↓ 2 callersMethodsummary
summary returns a shorthand summary string suitable for logging.
common/membership/ringpop/hostinfo.go:51
↓ 2 callersMethodsyncActivityToReplicationTask
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8486
↓ 2 callersMethodsyncExecutionInfo
(current *persistencespb.WorkflowExecutionInfo, incoming *persistencespb.WorkflowExecutionInfo, isSnapshot boo
service/history/workflow/mutable_state_impl.go:9441
↓ 2 callersFunctionsyncOfferTask
( ctx context.Context, tm *TaskMatcher, task *internalTask, taskChan chan *internalTask, forwardFunc func
service/matching/matcher.go:189
↓ 2 callersMethodsyncOfferTask
( ctx context.Context, task *internalTask, returnNoPollerErr bool, )
service/matching/pri_matcher.go:447
↓ 2 callersMethodsyncSingleActivityState
( workflowKey *definition.WorkflowKey, mutableState historyi.MutableState, activitySyncInfo *historyservice
service/history/ndc/activity_state_replicator.go:268
↓ 2 callersMethodsyncStateInBatches
(totalWorkers int)
service/worker/workerdeployment/version_workflow_test.go:89
↓ 2 callersMethodsyncSubField
syncSubField syncs node n with value from fieldV parameter. If fieldV is a component, then it will sync all subcomponents recursively. It returns: - b
chasm/tree.go:1074
↓ 2 callersMethodsyncUnversionedRampInBatches
(totalWorkers int)
service/worker/workerdeployment/workflow_test.go:409
↓ 2 callersMethodsyncVersionDataToTaskQueues
syncVersionDataToTaskQueues is a helper that syncs the provided version data to all task queues. This function does NOT acquire the workflow lock - th
service/worker/workerdeployment/version_workflow.go:1249
↓ 2 callersFunctiontagsToMap
(t1 []Tag, e excludeTags)
common/metrics/tally_metrics_handler.go:283
↓ 2 callersFunctiontaskAddErrResult
(err error)
service/matching/task_queue_partition_manager.go:694
↓ 2 callersFunctiontaskBaseMetricTagsWithoutArchetype
( task tasks.Task, namespaceRegistry namespace.Registry, currentClusterName string, chasmRegistry *chasm.R
service/history/queues/executable.go:865
↓ 2 callersFunctiontaskCountsByCategory
(t *map[tasks.Category][]InternalHistoryTask)
common/persistence/size.go:222
↓ 2 callersFunctiontaskFairLevel
taskFairLevel returns the fair level for a task, or the zero fairLevel for tasks with no event (query, nexus, and poll-forwarder tasks).
service/matching/matcher_data.go:148
↓ 2 callersMethodtearDownLocked
(t *testing.T)
tests/testcore/test_cluster_pool.go:148
↓ 2 callersFunctiontelemetryUnaryOverrideOperationTag
telemetryUnaryOverrideOperationTag is used to override scope used for reporting a metric. Ideally this method should never be used.
common/rpc/interceptor/telemetry.go:116
↓ 2 callersMethodterminalFailure
terminalFailure returns the failure for a closed activity. The failure may be stored in Outcome.Failed (terminated, canceled, timed out) or in LastAtt
chasm/lib/activity/activity.go:1046
↓ 2 callersMethodterminateWorkflow
( mutableState historyi.MutableState, terminateReason string, )
service/history/ndc/workflow_resetter.go:629
↓ 2 callersMethodterminateWorkflow
( env *testcore.TestEnv, )
tests/workflow_alias_search_attribute_test.go:116
↓ 2 callersMethodtestAppendFlushFinishEventWithoutBufferMultiBatch
( flushBuffer bool, )
service/history/historybuilder/history_builder_test.go:1729
↓ 2 callersMethodtestAppendFlushFinishEventWithoutBufferSingleBatch
( flushBuffer bool, )
service/history/historybuilder/history_builder_test.go:1686
← previousnext →8,901–9,000 of 43,335, ranked by callers