MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 5 callersFunctionnewPriTaskMatcher
newPriTaskMatcher returns a task matcher instance
service/matching/pri_matcher.go:90
↓ 5 callersMethodnewRandomExecutionBufferRow
( shardID int32, namespaceID primitives.UUID, workflowID string, runID primitives.UUID, )
common/persistence/sql/sqlplugin/tests/history_execution_buffer.go:175
↓ 5 callersMethodnewRandomTreeRow
( shardID int32, treeID primitives.UUID, branchID primitives.UUID, )
common/persistence/sql/sqlplugin/tests/history_tree.go:181
↓ 5 callersFunctionnewSUTFromConfig
(config builderConfig)
service/history/historybuilder/history_builder_categorization_test.go:1246
↓ 5 callersFunctionnewScheduledTestOperation
(t *testing.T, ctx *chasm.MockMutableContext)
chasm/lib/nexusoperation/operation_test.go:106
↓ 5 callersFunctionnewTaskQueueLoadBalancer
(tq *tqid.TaskQueue)
client/matching/loadbalancer.go:147
↓ 5 callersFunctionnewTestActivities
(client schedulerpb.SchedulerServiceClient, nsID namespace.ID)
service/worker/scheduler/activities_test.go:30
↓ 5 callersMethodnewTestEnv
(doAutoEnable bool, opts ...testcore.TestOption)
tests/priority_fairness_test.go:432
↓ 5 callersMethodnewTestEnv
()
tests/archival_test.go:113
↓ 5 callersMethodnewTestEnv
(opts ...testcore.TestOption)
tests/dlq_test.go:77
↓ 5 callersFunctionnewTestFrontendHTTPClient
(ts *httptest.Server)
components/callbacks/request_test.go:23
↓ 5 callersFunctionnewTestFrontendHTTPClient
(ts *httptest.Server)
chasm/lib/callback/request_test.go:22
↓ 5 callersFunctionnewTestRingpopFactory
( serviceName primitives.ServiceName, logger log.Logger, rpcConfig *config.RPC, tlsProvider encryption.TLS
common/membership/ringpop/factory_test.go:150
↓ 5 callersFunctionnewTestUpdateRequest
(keys []tasks.Key)
common/persistence/execution_manager_test.go:25
↓ 5 callersFunctionnexusCompleteOperationFailure
nexusCompleteOperationFailure constructs a failed CompleteOperationOptions from the given failure.
service/history/workflow/mutable_state_impl.go:830
↓ 5 callersMethodnexusTaskPoller
(ctx context.Context, t *testing.T, taskQueue string, handler nexusTaskHandler)
tests/nexus_test_base.go:112
↓ 5 callersMethodoldestTime
oldestTime returns the time of the oldest task in this backlog, or the zero Time if empty.
service/matching/backlog_age_tracker.go:43
↓ 5 callersMethodopenURI
openURI returns a ReadCloser for the given URI. Supports http://, https://, and file:// schemes.
common/authorization/default_token_key_provider.go:171
↓ 5 callersMethodoutput
()
components/callbacks/statemachine.go:102
↓ 5 callersFunctionparseCalendarToStructured
(cal *schedulepb.CalendarSpec)
service/worker/scheduler/calendar.go:216
↓ 5 callersFunctionparseFailedTestsFromOutput
parseFailedTestsFromOutput extracts failing test names from gotestsum stdout. It looks for Go test failure lines produced as tests complete, and is us
tools/testrunner/log.go:330
↓ 5 callersMethodpeekTaskKey
( category tasks.Category, )
service/history/shard/task_key_manager.go:56
↓ 5 callersMethodpercentile
(key string, p float64)
tools/fairsim/sim.go:544
↓ 5 callersMethodpollAndQueryWorkflow
( env *testcore.TestEnv, tv *testvars.TestVars, sticky bool, )
tests/versioning_3_test.go:557
↓ 5 callersMethodprepare
prepare applies request overrides, validates the request, and records eager execution metrics.
service/history/api/startworkflow/api.go:117
↓ 5 callersMethodprepareTransientWorkflowTaskCompletionFirstBatchApplied
(version int64, workflowID, runID string)
service/history/workflow/mutable_state_impl_test.go:2350
↓ 5 callersFunctionprettyPrintAny
(b *strings.Builder, v reflect.Value, depth int)
common/testing/protoassert/pretty_print.go:22
↓ 5 callersMethodprocessCloseCallbacks
processCloseCallbacks triggers "WorkflowClosed" callbacks, applying the state machine transition that schedules callback tasks.
service/history/workflow/mutable_state_impl.go:7199
↓ 5 callersMethodprocessNewRange
()
service/history/queues/queue_base.go:262
↓ 5 callersFunctionpropagateTimeSkippingToChild
propagateTimeSkippingToChild makes sure the start time of the child workflow execution is shifted forward by the accumulated skipped duration. FastFor
service/history/workflow/timeskipping.go:38
↓ 5 callersMethodrampingVersionStringUnversioned
(s string)
service/worker/workerdeployment/workflow.go:744
↓ 5 callersFunctionrandSignalBroadcast
( cv ConditionVariable, signalRatio float64, )
common/locks/condition_variable_test.go:223
↓ 5 callersMethodrandomRequest
()
service/history/api/signalwithstartworkflow/signal_with_start_workflow_test.go:228
↓ 5 callersMethodrandomTask
(taskID, pass int64)
common/persistence/tests/task_queue_fair_task.go:183
↓ 5 callersMethodrate
rate returns the rate of increments in a given interval
service/matching/task_tracker.go:94
↓ 5 callersFunctionreadFile
readFile reads the contents of a file specified by filepath WARNING: callers of this method should be extremely careful not to use it in a context whe
common/archiver/filestore/util.go:83
↓ 5 callersMethodreapplyContinueAsNewWorkflowEvents
( ctx context.Context, resetMutableState historyi.MutableState, currentWorkflow Workflow, namespaceID name
service/history/ndc/workflow_resetter.go:644
↓ 5 callersMethodrecordAttempt
(ts time.Time)
components/nexusoperations/statemachine.go:91
↓ 5 callersMethodrecordHeartbeat
(ctx context.Context, heartbeat heartbeatDetails)
service/worker/scanner/build_ids/scavenger.go:119
↓ 5 callersMethodrecvSyncReplicationState
( attr *replicationspb.SyncReplicationState, )
service/history/replication/stream_sender.go:244
↓ 5 callersMethodrefreshClusterMetadata
(ctx context.Context)
common/cluster/metadata.go:417
↓ 5 callersMethodremovePoller
(id pollerIdentity)
service/matching/poller_history.go:45
↓ 5 callersMethodreplaceAssignmentRule
replaceAssignmentRule replaces a new versioning assignment rule to the task queue user data. It checks the response and returns the conflict token.
tests/versioning_test.go:4453
↓ 5 callersMethodrequireLegacyTaskQueueStatsRelaxed
requireLegacyTaskQueueStatsRelaxed asserts task queue statistics by allowing for over-counting in multi-partition scenarios. The production code inten
tests/task_queue_stats_test.go:773
↓ 5 callersMethodresetNextReadSliceLocked
()
service/history/queues/reader.go:487
↓ 5 callersMethodrespondWorkflowTaskCompleted
(env *testcore.TestEnv, task *workflowservice.PollWorkflowTaskQueueResponse, result any)
tests/eager_workflow_start_test.go:59
↓ 5 callersFunctionrestoreOriginalOptions
( ctx context.Context, ms historyi.MutableState, updateRequest *workflowservice.UpdateActivityOptionsReques
service/history/api/updateactivityoptions/api.go:412
↓ 5 callersMethodroot
()
service/history/hsm/tree.go:707
↓ 5 callersFunctionrouteRequest
( r *http.Request, clusterMetadata cluster.Metadata, namespaceRegistry namespace.Registry, httpClientCache
components/callbacks/request.go:90
↓ 5 callersFunctionrouteRequest
( r *http.Request, clusterMetadata cluster.Metadata, namespaceRegistry namespace.Registry, httpClientCache
chasm/lib/callback/request.go:106
↓ 5 callersMethodrunNexusCompletionHTTPServer
(t *testing.T, h *completionHandler)
tests/activity_standalone_test.go:6350
↓ 5 callersMethodrunScavenger
()
service/worker/scanner/taskqueue/scavenger_test.go:150
↓ 5 callersMethodrunTestCase
(tc *testCase)
common/persistence/sql/sqlplugin/tests/history_execution_chasm.go:47
↓ 5 callersFunctionscalerBackgroundPolls
(s testcore.Env, tv *testvars.TestVars, tp *taskpoller.TaskPoller, workers int)
tests/partition_scaling_test.go:277
↓ 5 callersFunctionscalerBackgroundTasks
TODO: test disabling scaler
tests/partition_scaling_test.go:252
↓ 5 callersFunctionscalerBacklogEmpty
(s testcore.Env, tv *testvars.TestVars, parts ...int)
tests/partition_scaling_test.go:330
↓ 5 callersFunctionscalerEnvOptions
(dcPartitions int)
tests/partition_scaling_test.go:25
↓ 5 callersMethodserializePageToken
(token *visibilityPageToken)
common/persistence/visibility/store/elasticsearch/visibility_store.go:911
↓ 5 callersFunctionserializePageTokenJson
(token *T)
common/persistence/sql/common.go:116
↓ 5 callersMethodsetAckLevel
Moves ack level to the new level if it is higher than the current one. Also updates the read level if it is lower than the ackLevel.
service/matching/ack_manager.go:86
↓ 5 callersMethodsetCurrentVersion
TODO (Shivam): We may have to wait for the propagation status to show completed if we are using async workflows here.
tests/task_queue_stats_test.go:1056
↓ 5 callersMethodsetDefaultDeleteParams
(t *testing.T)
service/worker/dlq/workflow_test.go:512
↓ 5 callersMethodsetDefaultPriority
(task *internalTask)
service/matching/config.go:582
↓ 5 callersFunctionsetIncomingMD
setIncomingMD sets the key-value pairs in the incoming metadata. Empty values are ignored.
common/headers/headers.go:156
↓ 5 callersMethodsetTaskMinScheduledTime
( taskMinScheduledTime time.Time, )
service/history/shard/task_key_manager.go:82
↓ 5 callersMethodsetUserDataState
setUserDataState sets user data enabled/disabled and marks the future ready (if it's not ready yet). userDataState controls whether GetUserData return
service/matching/user_data_manager.go:224
↓ 5 callersMethodsetupComponentWithTree
setupComponentWithTree creates a basic component structure and attaches it to the tree.
chasm/field_test.go:165
↓ 5 callersFunctionsetupForCompletion
(t *testing.T, handler nexusrpc.CompletionHandler, serializer nexus.Serializer, failureConverter nexusrpc.Fail
common/nexus/nexusrpc/setup_test.go:58
↓ 5 callersMethodsetupSignalExternalWorkflowInitiated
( targetNamespace namespace.Name, targetNamespaceID namespace.ID, )
service/history/transfer_queue_active_task_executor_test.go:1972
↓ 5 callersMethodsetupStartWorkflowExecutionForRunning
()
service/history/history_engine2_test.go:1607
↓ 5 callersMethodsetupTaskMgrMocks
()
service/worker/scanner/taskqueue/scavenger_test.go:162
↓ 5 callersMethodsetupToCaptureTasks
()
service/matching/backlog_manager_test.go:141
↓ 5 callersFunctionshallowCloneVersioningData
(data *persistencespb.VersioningData)
service/matching/version_sets.go:126
↓ 5 callersMethodshouldMaskErrors
(req any)
common/rpc/interceptor/mask_internal_error.go:59
↓ 5 callersFunctionsizeOfStringSet
( stringSet map[string]struct{}, )
common/persistence/size_util.go:20
↓ 5 callersMethodskipDuplicatedEvents
(skipIndex int)
service/history/ndc/replication_task.go:48
↓ 5 callersFunctionsleep
(ctx context.Context, deadline time.Time, pollInterval time.Duration)
common/testing/await/require_ctx.go:268
↓ 5 callersMethodspoolDefaultTasks
spoolDefaultTasks spools n tasks to the partition manager's default queue.
service/matching/task_queue_partition_manager_test.go:679
↓ 5 callersFunctionstandbyTransferTaskPostActionTaskDiscarded
( _ context.Context, taskInfo tasks.Task, postActionInfo any, logger log.Logger, )
service/history/ndc_standby_task_util.go:52
↓ 5 callersMethodstartManagerWithLogger
( logger log.Logger, writePartitions int, initial *persistencespb.PartitionScaleState, )
service/matching/scale_manager_test.go:86
↓ 5 callersMethodstartUnversionedWorkflows
(env *taskQueueStatsContext, count int, tqName string)
tests/task_queue_stats_test.go:876
↓ 5 callersMethodstopWorkers
( count int, )
common/tasks/fifo_scheduler.go:153
↓ 5 callersMethodstoppedForOwnershipLost
()
service/history/shard/context_impl.go:1493
↓ 5 callersFunctionsum
--- generic helpers ---
tools/fairsim/sim.go:575
↓ 5 callersMethodtags
(keyvals []any)
common/log/sdk_logger.go:31
↓ 5 callersFunctiontaskWorkflowKey
(task tasks.Task)
service/history/statemachine_environment.go:27
↓ 5 callersMethodtearDownTestCluster
tearDownTestCluster tears down the underlying TestCluster and runs the proxy T's queued cleanups (notably tl.Close). Cleanups run via defer so they ex
tests/testcore/functional_test_base.go:478
↓ 5 callersFunctiontestActivityMetricTags
(operation string)
service/history/workflow/metrics_test.go:270
↓ 5 callersMethodtestStandingBacklog
(p standingBacklogParams)
service/matching/backlog_manager_test.go:828
↓ 5 callersFunctiontimerTypeToTimerMask
( timerType enumspb.TimeoutType, )
service/history/workflow/timer_sequence.go:364
↓ 5 callersMethodtoTally
()
common/metrics/config.go:507
↓ 5 callersFunctiontrimShardInfo
( cfg *configs.Config, allClusterInfo map[string]cluster.ClusterInformation, shardInfo *persistencespb.Shar
service/history/shard/context_impl.go:2315
↓ 5 callersMethodtxExecuteShardLocked
txExecuteShardLocked executes f under transaction and with read lock on shard row
common/persistence/sql/execution.go:40
↓ 5 callersFunctionunion
(this, that map[K]struct{})
service/history/tasks/predicates.go:440
↓ 5 callersMethodunloadFromEngine
(unloadCause unloadCause)
service/matching/task_queue_partition_manager.go:1966
↓ 5 callersFunctionunmarshalTimestamp
unmarshalTimestamp unmarshals a string into a Time instance. Uses RFC 3339, with some extra validation to ensure that seconds and subseconds are with
common/nexus/nexusrpc/timestamp.go:28
↓ 5 callersMethodupdatePhysicalTaskQueueGauge
Responsible for emitting and updating loaded_physical_task_queue_count metric
service/matching/matching_engine.go:2998
↓ 5 callersMethodupdateQuota
(newQuota float64)
common/quotas/calculator/logged_calculator_test.go:108
↓ 5 callersMethodupdateTaskQueuePartitionGauge
Responsible for emitting and updating loaded_task_queue_family_count, loaded_task_queue_count and loaded_task_queue_partition_count metrics
service/matching/matching_engine.go:3041
↓ 5 callersMethodupdateTimeSkippingInfo
updateTimeSkippingInfo updates the time skipping info with with new config and the event ID that updates the config we allow updating the config to ni
service/history/workflow/mutable_state_impl.go:10013
← previousnext →4,601–4,700 of 43,335, ranked by callers