MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 2 callersFunctionVersioningBehaviorAfterOverrideTag
(behavior enumspb.VersioningBehavior)
common/metrics/tags.go:527
↓ 2 callersFunctionVersioningBehaviorBeforeOverrideTag
(behavior enumspb.VersioningBehavior)
common/metrics/tags.go:523
↓ 2 callersMethodVisibilityTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:100
↓ 2 callersMethodVisibilityURI
()
tests/testcore/test_cluster.go:130
↓ 2 callersMethodWait
(ctx context.Context, request Request)
common/quotas/request_rate_limiter_delegator.go:45
↓ 2 callersMethodWaitN
WaitN is the only method that is different from rate.Limiter. We need to fully reimplement this method because the original method uses time.Now(), an
common/quotas/clocked_rate_limiter.go:86
↓ 2 callersFunctionWildCardStringToRegexp
WildCardStringToRegexp converts a given string pattern to a regular expression matching wildcards (*) with any substring.
common/util/wildcard.go:11
↓ 2 callersMethodWith
With adds a series of [Component] instances to the [Route].
common/routing/route.go:53
↓ 2 callersFunctionWithClusterHistoryTaskRecorder
()
tests/testcore/functional_test_base.go:193
↓ 2 callersFunctionWithDisableTestloggerFailure
WithDisableTestloggerFailure disables the test logger's behavior of failing the test when an error log matches a registered expectation (e.g. soft-ass
tests/testcore/test_env.go:122
↓ 2 callersFunctionWithDynamicConfigClient
WithDynamicConfigClient sets custom client for reading dynamic configuration.
temporal/server_option.go:139
↓ 2 callersFunctionWithFrontendAddress
WithFrontendAddress ensures that admin clients created by the factory will connect to the specified address.
tools/tdbg/factory.go:78
↓ 2 callersFunctionWithFxOptions
WithFxOptions appends fx options to a specific service's fx graph. This implies a dedicated cluster because custom fx options cannot be shared across
tests/testcore/test_env.go:146
↓ 2 callersFunctionWithGCSettleTimeout
WithGCSettleTimeout sets the maximum time Check spends forcing GC and waiting for retained-object counts to settle.
common/testing/objectleak/leakcheck.go:51
↓ 2 callersFunctionWithGetenv
(getenv func(string) string)
tests/testutils/source_root.go:37
↓ 2 callersMethodWithGroup
WithGroup implements slog.Handler.
common/log/slog.go:81
↓ 2 callersFunctionWithInFlightSizeLimit
WithInFlightSizeLimit provides an optional limit to the total payload size of incomplete Updates that a Registry instance will allow.
service/history/workflow/update/registry.go:118
↓ 2 callersMethodWithJitter
(jitterPct float64)
common/backoff/retrypolicy.go:282
↓ 2 callersMethodWithPredefinedSearchAttributes
WithPredefinedSearchAttributes returns a new NameTypeMap overriding the predefined search attributes with the given input. The default value is the sa
common/searchattribute/name_type_map.go:90
↓ 2 callersMethodWithSystemSearchAttributes
WithSystemSearchAttributes returns a new NameTypeMap overriding the system search attributes with the given input. The default value is the sadefs.Sys
common/searchattribute/name_type_map.go:72
↓ 2 callersMethodWithTimestamp
(int64)
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:36
↓ 2 callersFunctionWithTotalLimitSuggestCAN
WithTotalLimitSuggestCAN provides an optional threshold for suggesting ContinueAsNew when the total number of Updates reaches a certain percentage of
service/history/workflow/update/registry.go:133
↓ 2 callersFunctionWorkerDeploymentVersionFromStringV32
(s string)
common/worker_versioning/worker_versioning.go:1221
↓ 2 callersFunctionWorkflowBinaryChecksum
WorkflowBinaryChecksum returns tag for WorkflowBinaryChecksum
common/log/tag/tags.go:146
↓ 2 callersFunctionWorkflowEventCount
WorkflowEventCount returns tag for EventCount
common/log/tag/tags.go:350
↓ 2 callersFunctionWorkflowHistorySize
WorkflowHistorySize returns tag for HistorySize
common/log/tag/tags.go:335
↓ 2 callersFunctionWorkflowMutableStateSize
WorkflowMutableStateSize returns tag for MutableStateSize
common/log/tag/tags.go:345
↓ 2 callersFunctionWorkflowPollContextTimeout
WorkflowPollContextTimeout returns tag for WorkflowPollContextTimeout
common/log/tag/tags.go:99
↓ 2 callersFunctionWorkflowResetBaseRunID
WorkflowResetBaseRunID returns tag for WorkflowResetBaseRunID
common/log/tag/tags.go:136
↓ 2 callersFunctionWorkflowState
WorkflowState returns tag for WorkflowState
common/log/tag/tags.go:120
↓ 2 callersFunctionWorkflowTaskRequestId
WorkflowTaskRequestId returns a tag for workflow task RequestId
common/log/tag/tags.go:936
↓ 2 callersFunctionWorkflowsExistForBuildId
(ctx context.Context, visibilityManager manager.VisibilityManager, ns *namespace.Namespace, taskQueue, buildId
common/worker_versioning/worker_versioning.go:150
↓ 2 callersMethodWriteLockExecutions
(ctx context.Context, filter ExecutionsFilter)
common/persistence/sql/sqlplugin/history_execution.go:78
↓ 2 callersMethodWriteLockShards
(ctx context.Context, filter ShardsFilter)
common/persistence/sql/sqlplugin/history_shard.go:29
↓ 2 callersFunctionZap
(field zap.Field)
common/log/tag/zap_tag.go:238
↓ 2 callersMethodabortTasks
()
common/tasks/interleaved_weighted_round_robin.go:383
↓ 2 callersMethodadd
(task Task)
service/worker/scanner/executor/runq.go:32
↓ 2 callersMethodadd
(key Key, yamlCV yamlConstrainedValue)
common/dynamicconfig/yaml_loader.go:79
↓ 2 callersMethodaddAssignmentRuleWithRamp
( env *testcore.TestEnv, tq, buildID string, ramp float32, )
tests/versioning_test.go:4787
↓ 2 callersFunctionaddBackfiller
addBackfiller returns an initialized backfiller, adding it to the scheduler's Backfillers.
chasm/lib/scheduler/backfiller.go:35
↓ 2 callersMethodaddBuildIDAndDeploymentInfoToSearchAttributesWithNoVisibilityTask
( stamp *commonpb.WorkerVersionStamp, usedVersion *deploymentpb.WorkerDeploymentVersion, maxSearchAttribute
service/history/workflow/mutable_state_impl.go:3993
↓ 2 callersFunctionaddCallbacksToMap
addCallbacksToMap converts common callbacks to CHASM callback components and inserts them into the target map, keyed by "<requestID>-<index>". All ca
chasm/lib/workflow/workflow.go:151
↓ 2 callersFunctionaddCancelRequestedEvent
( ms historyi.MutableState, initiatedID int64, namespaceName namespace.Name, namespaceID namespace.ID, wo
service/history/history_engine_test.go:6845
↓ 2 callersMethodaddChangesForStateReplication
(state *persistencespb.WorkflowMutableState)
service/history/workflow/mutable_state_impl_test.go:5371
↓ 2 callersFunctionaddChildWorkflowExecutionCompletedEvent
(ms historyi.MutableState, initiatedID int64, childExecution *commonpb.WorkflowExecution, attributes *history
service/history/history_engine_test.go:6942
↓ 2 callersMethodaddCompletionCallbacks
( event *historypb.HistoryEvent, requestID string, completionCallbacks []*commonpb.Callback, )
service/history/workflow/mutable_state_impl.go:3354
↓ 2 callersMethodaddCompletionCallbacks
( ctx chasm.MutableContext, requestID string, completionCallbacks []*commonpb.Callback, maxCallbacks int,
chasm/lib/activity/activity.go:308
↓ 2 callersMethodaddConsumeAllWorkflowTasksNonConcurrently
(taskCount int)
service/matching/matching_engine_test.go:3720
↓ 2 callersFunctionaddContextTimeoutToHTTPHeader
(ctx context.Context, httpHeader http.Header)
common/nexus/nexusrpc/api.go:129
↓ 2 callersMethodaddErrorBehavior
(err error)
service/matching/fair_task_reader.go:317
↓ 2 callersMethodaddErrorBehavior
(err error)
service/matching/pri_task_reader.go:315
↓ 2 callersMethodaddNewTasks
To add tasks to the matcher: call recordNewTasksLocked with tr.lock held, then release the lock and call addNewTasks. We call addTaskToMatcher outside
service/matching/pri_task_reader.go:288
↓ 2 callersMethodaddOption
(option metric.InstrumentOption)
common/metrics/otel_options.go:15
↓ 2 callersMethodaddSearchAttributesElasticsearch
( ctx context.Context, request *adminservice.AddSearchAttributesRequest, indexName string, )
service/frontend/admin_handler.go:337
↓ 2 callersMethodaddSearchAttributesInternal
( ctx context.Context, request *operatorservice.AddSearchAttributesRequest, visManager manager.VisibilityMa
service/frontend/operator_handler.go:182
↓ 2 callersMethodaddSearchAttributesSQL
( ctx context.Context, request *adminservice.AddSearchAttributesRequest, currentSearchAttributes searchattr
service/frontend/admin_handler.go:375
↓ 2 callersFunctionaddSignaledEvent
( ms historyi.MutableState, initiatedID int64, namespaceName namespace.Name, namespaceID namespace.ID, wo
service/history/history_engine_test.go:6887
↓ 2 callersMethodaddStart
(nominalTime, actualTime time.Time, overlapPolicy enumspb.ScheduleOverlapPolicy, manual bool)
service/worker/scheduler/workflow.go:1326
↓ 2 callersMethodaddTask
addTask adds a task to the simulator, assigning defaults and an index.
tools/fairsim/sim.go:179
↓ 2 callersMethodaddTaskToMatcher
(task *internalTask)
service/matching/pri_task_reader.go:296
↓ 2 callersMethodaddTasksSemaphoreAcquired
( ctx context.Context, request *persistence.AddHistoryTasksRequest, )
service/history/shard/context_impl.go:817
↓ 2 callersMethodaddTest
(t testlogger.CleanupCapableT)
tests/testcore/shared_cluster_t.go:30
↓ 2 callersMethodaddTimer
(t *fakeTimer)
common/clock/event_time_source.go:98
↓ 2 callersFunctionaddWorkflowExecutionStartedEventWithParent
(ms historyi.MutableState, workflowExecution *commonpb.WorkflowExecution, workflowType, taskQueue string, inp
service/history/history_engine_test.go:6640
↓ 2 callersMethodaddWorkflowTaskToMatching
TODO (alex-update): Consider moving this func to a better place.
service/history/api/updateworkflow/api.go:317
↓ 2 callersMethodaddWorkflowTasks
addWorkflowTasks adds taskCount number of tasks sequentially
service/matching/matching_engine_test.go:3648
↓ 2 callersFunctionaddZipfTasks
(sim *simulator, numTasks, numKeys int, zipfS, zipfV float64)
tools/fairsim/sim_test.go:35
↓ 2 callersMethodadjustCurrent
(delta int64)
common/deadlock/deadlock.go:148
↓ 2 callersMethodadjustQueryBatchTypeEnum
(query string, batchType enumspb.BatchOperationType)
service/worker/batcher/activities.go:408
↓ 2 callersMethodadvanceAndResetLocked
advanceAndResetLocked advances the trackers position and clears out any expired intervals This method must be called with taskTracker's lock held.
service/matching/task_tracker.go:71
↓ 2 callersMethodafterAddWorkflowTaskCompletedEvent
( event *historypb.HistoryEvent, limits historyi.WorkflowTaskCompletionLimits, wftScheduleToClose time.Dura
service/history/workflow/workflow_task_state_machine.go:1318
↓ 2 callersMethodalive
()
service/worker/scanner/executor/executor.go:142
↓ 2 callersFunctionallFilesMatchSuffixes
allFilesMatchSuffixes returns true if every file in the list ends with one of the given suffixes.
tools/flakereport/bisect.go:225
↓ 2 callersMethodallReports
()
tools/testrunner/testrunner.go:204
↓ 2 callersFunctionanchorLastEventTo
anchorLastEventTo backdates Info.UpdateTime/CreateTime so that idleDeadline = anchor + idleTime; pairs with scheduledTime = anchor + idleTime to make
chasm/lib/scheduler/scheduler_idle_tasks_test.go:62
↓ 2 callersMethodannotateSearchAttributesOfScheduledWorkflow
( queryResponse *schedulespb.DescribeResponse, nsName string, )
service/frontend/workflow_handler.go:4495
↓ 2 callersMethodannotateTags
( ctx context.Context, span trace.Span, payload any, )
common/telemetry/grpc.go:161
↓ 2 callersMethodapiSpecToPersistenceSpec
(source *nexuspb.EndpointSpec)
service/frontend/nexus_endpoint_client.go:230
↓ 2 callersMethodappend
(v T)
common/dynamicconfig/gradual_change_test.go:369
↓ 2 callersFunctionappendCacheKeyPart
(sb *strings.Builder, value string)
common/metrics/tally_metrics_handler.go:148
↓ 2 callersFunctionappendConstrainedValue
(logLine *strings.Builder, value *ConstrainedValue)
common/dynamicconfig/client_diff.go:95
↓ 2 callersMethodappendContextMetadataToTrailer
(ctx context.Context, info *grpc.UnaryServerInfo)
common/rpc/interceptor/context_metadata_interceptor.go:65
↓ 2 callersFunctionappendHistoryEvents
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, execution *commonpb.W
service/history/workflow/transaction_impl.go:346
↓ 2 callersMethodappendToLatestBatch
appendToLatestBatch appends event to memLatestBatch, rolling into a new batch first if the additional event would push the current batch over maxEvent
service/history/historybuilder/event_store.go:120
↓ 2 callersMethodapply
(*TestServer)
temporaltest/options.go:12
↓ 2 callersMethodapply
(*Namespace)
common/namespace/namespace.go:23
↓ 2 callersMethodapplyDeletions
( deletedNodes map[string]struct{}, isSystemUpdates bool, )
chasm/tree.go:2523
↓ 2 callersMethodapplyEvents
( ctx context.Context, workflowKey definition.WorkflowKey, stateBuilder workflow.MutableStateRebuilder, ev
service/history/ndc/state_rebuilder.go:329
↓ 2 callersMethodapplyEvents
( ctx context.Context, namespaceID namespace.ID, requestID string, execution *commonpb.WorkflowExecution,
service/history/workflow/mutable_state_rebuilder.go:103
↓ 2 callersMethodapplyNonStartEventsToNonCurrentBranchWithoutContinueAsNew
( ctx context.Context, wfContext historyi.WorkflowContext, mutableState historyi.MutableState, branchIndex
service/history/ndc/history_replicator.go:658
↓ 2 callersMethodapplySignalRequestedIds
(signalRequestedIds []string, incomingExecutionInfo *persistencespb.WorkflowExecutionInfo)
service/history/workflow/mutable_state_impl.go:9332
↓ 2 callersMethodapplySnapshotWhenWorkflowExist
( ctx context.Context, namespaceID namespace.ID, workflowID string, runID string, archetypeID chasm.Arche
service/history/ndc/workflow_state_replicator.go:827
↓ 2 callersMethodapplySnapshotWhenWorkflowNotExist
( ctx context.Context, namespaceID namespace.ID, workflowID string, runID string, archtypeID chasm.Archet
service/history/ndc/workflow_state_replicator.go:1440
↓ 2 callersMethodapplyUpdateWithLease
applyUpdateWithLease applies an update function to a component within a held lease, persists the changes, and returns the serialized component referen
service/history/chasm_engine.go:414
↓ 2 callersMethodapplyUpdates
( updatedNodes map[string]*persistencespb.ChasmNode, isSystemUpdates bool, )
chasm/tree.go:2573
↓ 2 callersMethodapplyUpdatesToSubStateMachines
( updatedActivityInfos map[int64]*persistencespb.ActivityInfo, updatedTimerInfos map[string]*persistencespb.
service/history/workflow/mutable_state_impl.go:9224
↓ 2 callersMethodapplyUpdatesToUpdateInfos
( updatedUpdateInfos map[string]*persistencespb.UpdateInfo, isSnapshot bool, )
service/history/workflow/mutable_state_impl.go:9411
↓ 2 callersFunctionapplyWorkflowMutationBatch
( batch *gocql.Batch, shardID int32, workflowMutation *p.InternalWorkflowMutation, )
common/persistence/cassandra/util.go:13
↓ 2 callersMethodapplyWorkflowMutationTx
( ctx context.Context, tx sqlplugin.Tx, shardID int32, workflowMutation *p.InternalWorkflowMutation, )
common/persistence/sql/execution_util.go:23
↓ 2 callersFunctionapplyWorkflowSnapshotBatchAsReset
( batch *gocql.Batch, shardID int32, workflowSnapshot *p.InternalWorkflowSnapshot, )
common/persistence/cassandra/util.go:143
← previousnext →7,801–7,900 of 43,335, ranked by callers