MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 2 callersMethodcompareStartTimeBetween
(fromTime time.Time, toTime time.Time)
service/history/workflow/matcher/activity_evaluator.go:289
↓ 2 callersMethodcompareStartTimeBetween
(fromTime time.Time, toTime time.Time)
service/history/workflow/matcher/mutable_state_evaluator.go:232
↓ 2 callersMethodcompareTime
(receivedTime time.Time, expectedTime time.Time, operation string)
service/matching/workers/worker_query_engine.go:436
↓ 2 callersMethodcompareTimeBetween
( fromTime time.Time, toTime time.Time, timeValue time.Time, )
service/matching/workers/worker_query_engine.go:430
↓ 2 callersMethodcompleteFirstWorkflowTask
completeFirstWorkflowTask polls and completes the initial workflow task on the active cluster with no commands, leaving the workflow open and idle. On
tests/xdc/timeskipping_replication_test.go:141
↓ 2 callersMethodcompleteTaskLocked
(task *internalTask)
service/matching/fair_task_reader.go:189
↓ 2 callersMethodcompleteUpdateMessageHandler
(updateId string)
tests/xdc/history_replication_signals_and_updates_test.go:828
↓ 2 callersMethodcomputeEffectiveConfig
computeEffectiveConfig determines the effective NewMatcher and EnableFairness config values based on fairnessState, autoEnable, and the base dynamic c
service/matching/task_queue_partition_manager.go:205
↓ 2 callersMethodconcurrentPublishConsumeActivities
( workerCount int, taskCount int64, dispatchLimitFn func(int, int64) float64, )
service/matching/matching_engine_test.go:1854
↓ 2 callersFunctionconfigExcludeTags
(cfg ClientConfig)
common/metrics/config.go:495
↓ 2 callersMethodconfigureRateLimitAndLaunchWorkflows
configureRateLimitAndLaunchWorkflows sets up the test environment to validate task queue API rate limiting behavior. - Applies an API-level RPS overri
tests/task_queue_test.go:193
↓ 2 callersFunctionconstructHistoryFilenamePrefix
(namespaceID, workflowID, runID string)
common/archiver/filestore/util.go:168
↓ 2 callersFunctionconstructHistoryKeyPrefix
(path, namespaceID, workflowID, runID string)
common/archiver/s3store/util.go:125
↓ 2 callersFunctionconstructTimeBasedSearchKey
(path, namespaceID, primaryIndexKey, primaryIndexValue, secondaryIndexKey string, t time.Time, precision strin
common/archiver/s3store/util.go:129
↓ 2 callersFunctionconstructTimestampIndex
(path, namespaceID, primaryIndexKey, primaryIndexValue, secondaryIndexKey string, secondaryIndexValue time.Tim
common/archiver/s3store/util.go:152
↓ 2 callersFunctionconstructTransitionOptions
(opts ...chasm.TransitionOption)
chasm/chasmtest/test_engine.go:638
↓ 2 callersFunctionconstructVisibilitySearchPrefix
(path, namespaceID string)
common/archiver/s3store/util.go:177
↓ 2 callersMethodconsumeTokens
(now int64, task *internalTask, tokens int64)
service/matching/ratelimit_manager.go:348
↓ 2 callersMethodcontextWithTimeoutFromHTTPRequest
contextWithTimeoutFromHTTPRequest extracts the context from the HTTP request and applies the timeout indicated by the Request-Timeout header, if set.
common/nexus/nexusrpc/server.go:288
↓ 2 callersFunctioncontinueAsNewCmd
continueAsNewCmd builds a ContinueAsNewWorkflowExecution command with the given workflow type and task queue, using the same virtual-time timeouts as
tests/timeskipping_propagation_test.go:904
↓ 2 callersMethodconvertAndExpr
(exprRef *sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter_legacy.go:313
↓ 2 callersMethodconvertAndExpr
(expr *sqlparser.AndExpr)
common/persistence/visibility/store/query/converter.go:359
↓ 2 callersFunctionconvertDeleteExecutionReplicationTask
( taskInfo *tasks.DeleteExecutionReplicationTask, )
service/history/replication/raw_task_converter.go:324
↓ 2 callersFunctionconvertDuration
(val any)
common/dynamicconfig/collection.go:619
↓ 2 callersMethodconvertIsExpr
(exprRef *sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter_legacy.go:633
↓ 2 callersMethodconvertIsExpr
(expr *sqlparser.IsExpr)
common/persistence/visibility/store/query/converter.go:451
↓ 2 callersMethodconvertNotExpr
(expr *sqlparser.NotExpr)
common/persistence/visibility/store/query/converter.go:350
↓ 2 callersMethodconvertOrExpr
(exprRef *sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter_legacy.go:325
↓ 2 callersMethodconvertOrExpr
(expr *sqlparser.OrExpr)
common/persistence/visibility/store/query/converter.go:372
↓ 2 callersFunctionconvertOutcomeToNexusHandlerError
(resp *matchingservice.DispatchNexusTaskResponse_HandlerError)
service/frontend/nexus_handler.go:810
↓ 2 callersMethodconvertParenExpr
(expr *sqlparser.ParenExpr)
common/persistence/visibility/store/query/converter.go:341
↓ 2 callersFunctionconvertQueueMessage
( message map[string]any, )
common/persistence/cassandra/queue_store.go:370
↓ 2 callersMethodconvertRangeCond
(exprRef *sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter_legacy.go:405
↓ 2 callersMethodconvertRangeCond
(expr *sqlparser.RangeCond)
common/persistence/visibility/store/query/converter.go:422
↓ 2 callersFunctionconvertReleaseInfo
(releaseInfo versioninfo.ReleaseInfo)
service/frontend/version_checker.go:201
↓ 2 callersFunctionconvertRunningWorkflowsToBufferedStarts
convertRunningWorkflowsToBufferedStarts converts V1's RunningWorkflows list to V2's BufferedStarts format. In V2, running workflows are represented as
chasm/lib/scheduler/migration/migration.go:232
↓ 2 callersMethodconvertSelectStmt
( sel *sqlparser.Select, )
common/persistence/visibility/store/query/converter.go:242
↓ 2 callersFunctionconvertSyncActivityInfos
( now time.Time, workflowKey definition.WorkflowKey, activityInfos map[int64]*persistencespb.ActivityInfo,
service/history/workflow/mutable_state_util.go:12
↓ 2 callersFunctionconvertTimeoutError
(err error)
common/persistence/cassandra/history_store.go:424
↓ 2 callersFunctionconvertToReports
convertToReports converts grouped failures to TestReport slice testRunCounts maps test name to total number of runs (including successes)
tools/flakereport/parser.go:284
↓ 2 callersMethodconvertToStartWorkflowExecutionResponse
( resp *historyservice.StartWorkflowExecutionResponse, namespaceName namespace.Name, )
service/frontend/workflow_handler.go:576
↓ 2 callersMethodconvertToWorkflowExecutionInfo
( internalExecution *store.InternalExecutionInfo, namespaceName namespace.Name, )
common/persistence/visibility/visibility_manager_impl.go:445
↓ 2 callersFunctionconvertUpdateFailure
(updateRes *workflowservice.UpdateWorkflowExecutionResponse)
service/worker/workerdeployment/util.go:339
↓ 2 callersMethodconvertWhereString
(queryString string)
common/persistence/visibility/store/query/converter.go:223
↓ 2 callersFunctioncopyRecursive
(src, dst string)
cmd/tools/protogen/main.go:31
↓ 2 callersMethodcopySuite
copySuite creates a fresh suite instance initialized for the given *testing.T. assertT overrides which TestingT assertions are bound to; nil means use
common/testing/parallelsuite/suite.go:52
↓ 2 callersMethodcountTasksByDrainingActive
(env *testcore.TestEnv, tp enumspb.TaskQueueType)
tests/priority_fairness_test.go:795
↓ 2 callersMethodcountWorkerDeployments
TODO: this is an expensive query that is called every time a new deployment name is seen. If user passes a ton of unique deployment names, we're in tr
service/worker/workerdeployment/client.go:1522
↓ 2 callersFunctioncountWorkflowForReplication
(ctx workflow.Context, params ForceReplicationParams)
service/worker/migration/force_replication_workflow.go:447
↓ 2 callersMethodcreateBatchUpdateOptionsWorkflow
(env *testcore.TestEnv, workflowFn WorkflowFunction)
tests/activity_api_batch_update_options_test.go:35
↓ 2 callersMethodcreateCrossNamespaceCallError
( namespaceEntry *namespace.Namespace, targetNamespaceEntry *namespace.Namespace, )
service/history/api/command_attr_validator.go:626
↓ 2 callersFunctioncreateDB
( dbKind sqlplugin.DbKind, cfg *config.SQL, r resolver.ServiceResolver, logger log.Logger, mh metrics.Han
common/persistence/sql/store.go:53
↓ 2 callersMethodcreateDatabase
(database string)
tools/sql/clitest/version_tests.go:113
↓ 2 callersMethodcreateDeploymentInTaskQueue
TODO (Shivam): Remove this guy.
tests/task_queue_stats_test.go:1210
↓ 2 callersFunctioncreateExecutions
( mockAdminCliednt *adminservicemock.MockAdminServiceClient, states []executionState, nextIndex int, )
service/worker/migration/activities_test.go:451
↓ 2 callersMethodcreateGRPCConnection
(c *cli.Context)
tools/tdbg/factory.go:97
↓ 2 callersMethodcreateGlobalNamespace
()
tests/xdc/delete_execution_replication_test.go:269
↓ 2 callersFunctioncreateHeartbeatTimeoutFailure
()
chasm/lib/activity/activity.go:767
↓ 2 callersMethodcreateInternodeGRPCConnection
createInternodeGRPCConnection creates connection for gRPC calls
common/rpc/rpc.go:270
↓ 2 callersMethodcreateKeyspace
createKeyspace creates a cassandra Keyspace if it doesn't exist
tools/cassandra/cqlclient.go:145
↓ 2 callersMethodcreateNamespace
( isGlobal bool, clusters []*testcore.TestCluster, )
tests/xdc/base.go:277
↓ 2 callersMethodcreatePollWorkflowTaskQueueResponse
Populate the workflow task response based on context and scheduled/started events.
service/matching/matching_engine.go:3105
↓ 2 callersMethodcreatePollWorkflowTaskRequestAndPoll
(taskQueue *taskqueuepb.TaskQueue)
service/matching/matching_engine_test.go:3632
↓ 2 callersMethodcreateRecordWorkflowExecutionClosedRequest
( namespaceName namespace.Name, task *tasks.CloseExecutionVisibilityTask, mutableState historyi.MutableStat
service/history/visibility_queue_task_executor_test.go:897
↓ 2 callersMethodcreateRequestCancelWorkflowExecutionRequest
( targetNamespace namespace.Name, task *tasks.CancelExecutionTask, rci *persistencespb.RequestCancelInfo,
service/history/transfer_queue_active_task_executor_test.go:3153
↓ 2 callersMethodcreateSchedulerWithMaxQueues
(maxQueues int)
common/tasks/execution_aware_scheduler_test.go:423
↓ 2 callersMethodcreateSchedulerWithoutLifecycle
(enabled bool)
common/tasks/execution_aware_scheduler_test.go:410
↓ 2 callersMethodcreateSearchAttributes
()
tests/advanced_visibility_test.go:1576
↓ 2 callersMethodcreateTask
()
service/worker/scanner/executions/task_test.go:38
↓ 2 callersMethodcreateTaskQueue
(rangeID int64)
common/persistence/tests/task_queue_fair_task.go:155
↓ 2 callersMethodcreateUpsertWorkflowRequest
( namespaceName namespace.Name, task *tasks.UpsertExecutionVisibilityTask, mutableState historyi.MutableSta
service/history/visibility_queue_task_executor_test.go:878
↓ 2 callersMethodcreateVersionsInDeployments
(env *VersioningTestEnv, tv *testvars.TestVars, n int)
tests/worker_deployment_test.go:3497
↓ 2 callersMethodcreateWorkflow
( env *testcore.TestEnv, tv *testvars.TestVars, sa *commonpb.SearchAttributes, )
tests/workflow_alias_search_attribute_test.go:95
↓ 2 callersMethodcreateWorkflow
(env *testcore.TestEnv, workflowFn WorkflowFunction)
tests/activity_api_batch_unpause_test.go:83
↓ 2 callersFunctioncreateWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, mutableStateFailoverVersion int64, request *per
service/history/workflow/transaction_impl.go:358
↓ 2 callersMethodcreationTasks
creationTasks returns tasks that are emitted when the machine is created.
components/nexusoperations/statemachine.go:141
↓ 2 callersFunctiondecodeAndValidateMemo
(t *testing.T, filePath, deploymentName, buildID string)
service/worker/workerdeployment/util_test.go:183
↓ 2 callersFunctiondecodeGob
(payload *commonpb.Payload, valuePtr any)
tests/testcore/test_data_converter.go:112
↓ 2 callersFunctiondecodeLink
decodeLink decodes the Nexus-Link header values. It must have the same format of HTTP Link header: https://developer.mozilla.org/en-US/docs/Web/HTTP/H
common/nexus/nexusrpc/api.go:154
↓ 2 callersMethoddecodeScheduleListInfo
(memo *commonpb.Memo)
service/frontend/workflow_handler.go:6679
↓ 2 callersFunctiondecodeTasks
( tasks []*persistencespb.ChasmComponentAttributes_Task, registry *chasm.Registry, )
tools/tdbg/chasm_decoder.go:185
↓ 2 callersFunctiondedupLinksFromCallbacks
( links []*commonpb.Link, callbacks []*commonpb.Callback, )
service/frontend/workflow_handler.go:6322
↓ 2 callersFunctiondedupeAlerts
dedupeAlerts removes duplicate alerts (e.g., repeated across retries) based on type and details while preserving the first-seen order.
tools/testrunner/junit.go:203
↓ 2 callersFunctiondefaultActivityOptions
()
tests/workflow_reset_with_child_test.go:888
↓ 2 callersMethoddefaultErrorFromResponse
(response *http.Response, body []byte, cause error)
common/nexus/nexusrpc/client.go:98
↓ 2 callersMethoddefaultTaskQueue
()
tests/eager_workflow_start_test.go:37
↓ 2 callersMethoddelete
(isSystemDelete bool)
chasm/tree.go:2735
↓ 2 callersFunctiondeleteBufferedEvents
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_non_map.go:154
↓ 2 callersMethoddeleteChildren
( childrenToKeep map[string]struct{}, )
chasm/tree.go:1158
↓ 2 callersMethoddeleteExecution
( ctx context.Context, ref chasm.ComponentRef, request chasm.DeleteExecutionRequest, )
service/history/chasm_engine.go:559
↓ 2 callersFunctiondeleteIndex
(esConfig *esclient.Config, logger log.Logger)
tests/testcore/test_cluster.go:467
↓ 2 callersMethoddeleteNamespace
(ctx context.Context, name string, ID []byte)
common/persistence/cassandra/metadata_store.go:488
↓ 2 callersFunctiondeleteTimerFiredEvent
( timerID string, events []*historypb.HistoryEvent, )
service/history/historybuilder/event_store.go:623
↓ 2 callersMethoddeleteVersion
(ctx workflow.Context, args *deploymentspb.DeleteVersionArgs)
service/worker/workerdeployment/workflow.go:1138
↓ 2 callersMethoddeleteVersionFromTaskQueues
(ctx workflow.Context, activityCtx workflow.Context)
service/worker/workerdeployment/version_workflow.go:618
↓ 2 callersMethoddeleteWorkflowExecutionInternal
( ctx context.Context, namespaceID namespace.ID, we *commonpb.WorkflowExecution, weCtx historyi.WorkflowCo
service/history/deletemanager/delete_manager.go:162
↓ 2 callersMethoddeleteWorkflowTask
deleteWorkflowTask deletes a workflow task.
service/history/workflow/workflow_task_state_machine.go:1098
↓ 2 callersMethoddescribe
Describe returns information about physical queues for the requested versions, including pollers, stats (with "versioning attribution", which means th
service/matching/task_queue_partition_manager.go:1292
↓ 2 callersMethoddescribeJob
Calls describe dlq job and verify the output
tests/dlq_test.go:523
↓ 2 callersMethoddescribeVersioningInfo
( env *testcore.TestEnv, execution *commonpb.WorkflowExecution, )
tests/versioning_3_test.go:2264
← previousnext →8,001–8,100 of 43,335, ranked by callers