Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/temporalio/temporal
/ functions
Functions
43,335 in github.com/temporalio/temporal
⨍
Functions
43,335
◇
Types & classes
5,614
↓ 2 callers
Function
VersioningBehaviorAfterOverrideTag
(behavior enumspb.VersioningBehavior)
common/metrics/tags.go:527
↓ 2 callers
Function
VersioningBehaviorBeforeOverrideTag
(behavior enumspb.VersioningBehavior)
common/metrics/tags.go:523
↓ 2 callers
Method
VisibilityTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:100
↓ 2 callers
Method
VisibilityURI
()
tests/testcore/test_cluster.go:130
↓ 2 callers
Method
Wait
(ctx context.Context, request Request)
common/quotas/request_rate_limiter_delegator.go:45
↓ 2 callers
Method
WaitN
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 callers
Function
WildCardStringToRegexp
WildCardStringToRegexp converts a given string pattern to a regular expression matching wildcards (*) with any substring.
common/util/wildcard.go:11
↓ 2 callers
Method
With
With adds a series of [Component] instances to the [Route].
common/routing/route.go:53
↓ 2 callers
Function
WithClusterHistoryTaskRecorder
()
tests/testcore/functional_test_base.go:193
↓ 2 callers
Function
WithDisableTestloggerFailure
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 callers
Function
WithDynamicConfigClient
WithDynamicConfigClient sets custom client for reading dynamic configuration.
temporal/server_option.go:139
↓ 2 callers
Function
WithFrontendAddress
WithFrontendAddress ensures that admin clients created by the factory will connect to the specified address.
tools/tdbg/factory.go:78
↓ 2 callers
Function
WithFxOptions
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 callers
Function
WithGCSettleTimeout
WithGCSettleTimeout sets the maximum time Check spends forcing GC and waiting for retained-object counts to settle.
common/testing/objectleak/leakcheck.go:51
↓ 2 callers
Function
WithGetenv
(getenv func(string) string)
tests/testutils/source_root.go:37
↓ 2 callers
Method
WithGroup
WithGroup implements slog.Handler.
common/log/slog.go:81
↓ 2 callers
Function
WithInFlightSizeLimit
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 callers
Method
WithJitter
(jitterPct float64)
common/backoff/retrypolicy.go:282
↓ 2 callers
Method
WithPredefinedSearchAttributes
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 callers
Method
WithSystemSearchAttributes
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 callers
Method
WithTimestamp
(int64)
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:36
↓ 2 callers
Function
WithTotalLimitSuggestCAN
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 callers
Function
WorkerDeploymentVersionFromStringV32
(s string)
common/worker_versioning/worker_versioning.go:1221
↓ 2 callers
Function
WorkflowBinaryChecksum
WorkflowBinaryChecksum returns tag for WorkflowBinaryChecksum
common/log/tag/tags.go:146
↓ 2 callers
Function
WorkflowEventCount
WorkflowEventCount returns tag for EventCount
common/log/tag/tags.go:350
↓ 2 callers
Function
WorkflowHistorySize
WorkflowHistorySize returns tag for HistorySize
common/log/tag/tags.go:335
↓ 2 callers
Function
WorkflowMutableStateSize
WorkflowMutableStateSize returns tag for MutableStateSize
common/log/tag/tags.go:345
↓ 2 callers
Function
WorkflowPollContextTimeout
WorkflowPollContextTimeout returns tag for WorkflowPollContextTimeout
common/log/tag/tags.go:99
↓ 2 callers
Function
WorkflowResetBaseRunID
WorkflowResetBaseRunID returns tag for WorkflowResetBaseRunID
common/log/tag/tags.go:136
↓ 2 callers
Function
WorkflowState
WorkflowState returns tag for WorkflowState
common/log/tag/tags.go:120
↓ 2 callers
Function
WorkflowTaskRequestId
WorkflowTaskRequestId returns a tag for workflow task RequestId
common/log/tag/tags.go:936
↓ 2 callers
Function
WorkflowsExistForBuildId
(ctx context.Context, visibilityManager manager.VisibilityManager, ns *namespace.Namespace, taskQueue, buildId
common/worker_versioning/worker_versioning.go:150
↓ 2 callers
Method
WriteLockExecutions
(ctx context.Context, filter ExecutionsFilter)
common/persistence/sql/sqlplugin/history_execution.go:78
↓ 2 callers
Method
WriteLockShards
(ctx context.Context, filter ShardsFilter)
common/persistence/sql/sqlplugin/history_shard.go:29
↓ 2 callers
Function
Zap
(field zap.Field)
common/log/tag/zap_tag.go:238
↓ 2 callers
Method
abortTasks
()
common/tasks/interleaved_weighted_round_robin.go:383
↓ 2 callers
Method
add
(task Task)
service/worker/scanner/executor/runq.go:32
↓ 2 callers
Method
add
(key Key, yamlCV yamlConstrainedValue)
common/dynamicconfig/yaml_loader.go:79
↓ 2 callers
Method
addAssignmentRuleWithRamp
( env *testcore.TestEnv, tq, buildID string, ramp float32, )
tests/versioning_test.go:4787
↓ 2 callers
Function
addBackfiller
addBackfiller returns an initialized backfiller, adding it to the scheduler's Backfillers.
chasm/lib/scheduler/backfiller.go:35
↓ 2 callers
Method
addBuildIDAndDeploymentInfoToSearchAttributesWithNoVisibilityTask
( stamp *commonpb.WorkerVersionStamp, usedVersion *deploymentpb.WorkerDeploymentVersion, maxSearchAttribute
service/history/workflow/mutable_state_impl.go:3993
↓ 2 callers
Function
addCallbacksToMap
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 callers
Function
addCancelRequestedEvent
( ms historyi.MutableState, initiatedID int64, namespaceName namespace.Name, namespaceID namespace.ID, wo
service/history/history_engine_test.go:6845
↓ 2 callers
Method
addChangesForStateReplication
(state *persistencespb.WorkflowMutableState)
service/history/workflow/mutable_state_impl_test.go:5371
↓ 2 callers
Function
addChildWorkflowExecutionCompletedEvent
(ms historyi.MutableState, initiatedID int64, childExecution *commonpb.WorkflowExecution, attributes *history
service/history/history_engine_test.go:6942
↓ 2 callers
Method
addCompletionCallbacks
( event *historypb.HistoryEvent, requestID string, completionCallbacks []*commonpb.Callback, )
service/history/workflow/mutable_state_impl.go:3354
↓ 2 callers
Method
addCompletionCallbacks
( ctx chasm.MutableContext, requestID string, completionCallbacks []*commonpb.Callback, maxCallbacks int,
chasm/lib/activity/activity.go:308
↓ 2 callers
Method
addConsumeAllWorkflowTasksNonConcurrently
(taskCount int)
service/matching/matching_engine_test.go:3720
↓ 2 callers
Function
addContextTimeoutToHTTPHeader
(ctx context.Context, httpHeader http.Header)
common/nexus/nexusrpc/api.go:129
↓ 2 callers
Method
addErrorBehavior
(err error)
service/matching/fair_task_reader.go:317
↓ 2 callers
Method
addErrorBehavior
(err error)
service/matching/pri_task_reader.go:315
↓ 2 callers
Method
addNewTasks
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 callers
Method
addOption
(option metric.InstrumentOption)
common/metrics/otel_options.go:15
↓ 2 callers
Method
addSearchAttributesElasticsearch
( ctx context.Context, request *adminservice.AddSearchAttributesRequest, indexName string, )
service/frontend/admin_handler.go:337
↓ 2 callers
Method
addSearchAttributesInternal
( ctx context.Context, request *operatorservice.AddSearchAttributesRequest, visManager manager.VisibilityMa
service/frontend/operator_handler.go:182
↓ 2 callers
Method
addSearchAttributesSQL
( ctx context.Context, request *adminservice.AddSearchAttributesRequest, currentSearchAttributes searchattr
service/frontend/admin_handler.go:375
↓ 2 callers
Function
addSignaledEvent
( ms historyi.MutableState, initiatedID int64, namespaceName namespace.Name, namespaceID namespace.ID, wo
service/history/history_engine_test.go:6887
↓ 2 callers
Method
addStart
(nominalTime, actualTime time.Time, overlapPolicy enumspb.ScheduleOverlapPolicy, manual bool)
service/worker/scheduler/workflow.go:1326
↓ 2 callers
Method
addTask
addTask adds a task to the simulator, assigning defaults and an index.
tools/fairsim/sim.go:179
↓ 2 callers
Method
addTaskToMatcher
(task *internalTask)
service/matching/pri_task_reader.go:296
↓ 2 callers
Method
addTasksSemaphoreAcquired
( ctx context.Context, request *persistence.AddHistoryTasksRequest, )
service/history/shard/context_impl.go:817
↓ 2 callers
Method
addTest
(t testlogger.CleanupCapableT)
tests/testcore/shared_cluster_t.go:30
↓ 2 callers
Method
addTimer
(t *fakeTimer)
common/clock/event_time_source.go:98
↓ 2 callers
Function
addWorkflowExecutionStartedEventWithParent
(ms historyi.MutableState, workflowExecution *commonpb.WorkflowExecution, workflowType, taskQueue string, inp
service/history/history_engine_test.go:6640
↓ 2 callers
Method
addWorkflowTaskToMatching
TODO (alex-update): Consider moving this func to a better place.
service/history/api/updateworkflow/api.go:317
↓ 2 callers
Method
addWorkflowTasks
addWorkflowTasks adds taskCount number of tasks sequentially
service/matching/matching_engine_test.go:3648
↓ 2 callers
Function
addZipfTasks
(sim *simulator, numTasks, numKeys int, zipfS, zipfV float64)
tools/fairsim/sim_test.go:35
↓ 2 callers
Method
adjustCurrent
(delta int64)
common/deadlock/deadlock.go:148
↓ 2 callers
Method
adjustQueryBatchTypeEnum
(query string, batchType enumspb.BatchOperationType)
service/worker/batcher/activities.go:408
↓ 2 callers
Method
advanceAndResetLocked
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 callers
Method
afterAddWorkflowTaskCompletedEvent
( event *historypb.HistoryEvent, limits historyi.WorkflowTaskCompletionLimits, wftScheduleToClose time.Dura
service/history/workflow/workflow_task_state_machine.go:1318
↓ 2 callers
Method
alive
()
service/worker/scanner/executor/executor.go:142
↓ 2 callers
Function
allFilesMatchSuffixes
allFilesMatchSuffixes returns true if every file in the list ends with one of the given suffixes.
tools/flakereport/bisect.go:225
↓ 2 callers
Method
allReports
()
tools/testrunner/testrunner.go:204
↓ 2 callers
Function
anchorLastEventTo
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 callers
Method
annotateSearchAttributesOfScheduledWorkflow
( queryResponse *schedulespb.DescribeResponse, nsName string, )
service/frontend/workflow_handler.go:4495
↓ 2 callers
Method
annotateTags
( ctx context.Context, span trace.Span, payload any, )
common/telemetry/grpc.go:161
↓ 2 callers
Method
apiSpecToPersistenceSpec
(source *nexuspb.EndpointSpec)
service/frontend/nexus_endpoint_client.go:230
↓ 2 callers
Method
append
(v T)
common/dynamicconfig/gradual_change_test.go:369
↓ 2 callers
Function
appendCacheKeyPart
(sb *strings.Builder, value string)
common/metrics/tally_metrics_handler.go:148
↓ 2 callers
Function
appendConstrainedValue
(logLine *strings.Builder, value *ConstrainedValue)
common/dynamicconfig/client_diff.go:95
↓ 2 callers
Method
appendContextMetadataToTrailer
(ctx context.Context, info *grpc.UnaryServerInfo)
common/rpc/interceptor/context_metadata_interceptor.go:65
↓ 2 callers
Function
appendHistoryEvents
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, execution *commonpb.W
service/history/workflow/transaction_impl.go:346
↓ 2 callers
Method
appendToLatestBatch
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 callers
Method
apply
(*TestServer)
temporaltest/options.go:12
↓ 2 callers
Method
apply
(*Namespace)
common/namespace/namespace.go:23
↓ 2 callers
Method
applyDeletions
( deletedNodes map[string]struct{}, isSystemUpdates bool, )
chasm/tree.go:2523
↓ 2 callers
Method
applyEvents
( ctx context.Context, workflowKey definition.WorkflowKey, stateBuilder workflow.MutableStateRebuilder, ev
service/history/ndc/state_rebuilder.go:329
↓ 2 callers
Method
applyEvents
( ctx context.Context, namespaceID namespace.ID, requestID string, execution *commonpb.WorkflowExecution,
service/history/workflow/mutable_state_rebuilder.go:103
↓ 2 callers
Method
applyNonStartEventsToNonCurrentBranchWithoutContinueAsNew
( ctx context.Context, wfContext historyi.WorkflowContext, mutableState historyi.MutableState, branchIndex
service/history/ndc/history_replicator.go:658
↓ 2 callers
Method
applySignalRequestedIds
(signalRequestedIds []string, incomingExecutionInfo *persistencespb.WorkflowExecutionInfo)
service/history/workflow/mutable_state_impl.go:9332
↓ 2 callers
Method
applySnapshotWhenWorkflowExist
( ctx context.Context, namespaceID namespace.ID, workflowID string, runID string, archetypeID chasm.Arche
service/history/ndc/workflow_state_replicator.go:827
↓ 2 callers
Method
applySnapshotWhenWorkflowNotExist
( ctx context.Context, namespaceID namespace.ID, workflowID string, runID string, archtypeID chasm.Archet
service/history/ndc/workflow_state_replicator.go:1440
↓ 2 callers
Method
applyUpdateWithLease
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 callers
Method
applyUpdates
( updatedNodes map[string]*persistencespb.ChasmNode, isSystemUpdates bool, )
chasm/tree.go:2573
↓ 2 callers
Method
applyUpdatesToSubStateMachines
( updatedActivityInfos map[int64]*persistencespb.ActivityInfo, updatedTimerInfos map[string]*persistencespb.
service/history/workflow/mutable_state_impl.go:9224
↓ 2 callers
Method
applyUpdatesToUpdateInfos
( updatedUpdateInfos map[string]*persistencespb.UpdateInfo, isSnapshot bool, )
service/history/workflow/mutable_state_impl.go:9411
↓ 2 callers
Function
applyWorkflowMutationBatch
( batch *gocql.Batch, shardID int32, workflowMutation *p.InternalWorkflowMutation, )
common/persistence/cassandra/util.go:13
↓ 2 callers
Method
applyWorkflowMutationTx
( ctx context.Context, tx sqlplugin.Tx, shardID int32, workflowMutation *p.InternalWorkflowMutation, )
common/persistence/sql/execution_util.go:23
↓ 2 callers
Function
applyWorkflowSnapshotBatchAsReset
( batch *gocql.Batch, shardID int32, workflowSnapshot *p.InternalWorkflowSnapshot, )
common/persistence/cassandra/util.go:143
← previous
next →
7,801–7,900 of 43,335, ranked by callers