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
↓ 1 callers
Method
checkTestShard
checkTestShard supports test sharding based on environment variables.
tests/testcore/functional_test_base.go:408
↓ 1 callers
Function
checkVersionForStickyAdd
Looks up a version set in versioning data based on a build ID associated with a task to determine if a task for a sticky queue should be bounced back
service/matching/version_sets.go:430
↓ 1 callers
Function
checkVersionForStickyPoll
Looks up a version set in versioning data based on worker version capabilities to determine how to redirect a poll request, but specific for sticky qu
service/matching/version_sets.go:364
↓ 1 callers
Method
checkVersionHistoryItem
checkVersionHistoryItem will check if incoming tasks Version history is on the same branch as the current one
service/history/replication/executable_history_task.go:391
↓ 1 callers
Method
checkVersionIsCurrent
(ctx context.Context, env *testcore.TestEnv, tv *testvars.TestVars)
tests/worker_deployment_version_test.go:1728
↓ 1 callers
Method
checkVersionIsRamping
(ctx context.Context, env *testcore.TestEnv, tv *testvars.TestVars)
tests/worker_deployment_version_test.go:1745
↓ 1 callers
Function
checkVersionMembershipViaUserData
checkVersionMembershipViaUserData is the fallback for when matching doesn't support CheckTaskQueueVersionMembership (e.g. during rolling deployments).
common/worker_versioning/worker_versioning.go:358
↓ 1 callers
Function
checkVersionSetLimits
(g *persistencespb.VersioningData, maxSets, maxBuildIds int)
service/matching/version_sets.go:45
↓ 1 callers
Function
checkVisibilityDatabase
( cfg config.Persistence, r resolver.ServiceResolver, logger log.Logger, )
common/persistence/sql/version_checker.go:40
↓ 1 callers
Method
checkWorkflowKey
(incomingWorkflowKey definition.WorkflowKey)
service/history/replication/executable_history_task.go:398
↓ 1 callers
Function
checksumLabels
checksumLabels returns a checksum of a labels map
common/membership/ringpop/hostinfo.go:66
↓ 1 callers
Method
chooseTargetQueueByFlag
chooseTargetQueueByFlag picks the target queue and dispatch revision number. If UseRevisionNumberForWorkerVersioning is enabled, it uses the revision
service/matching/task_queue_partition_manager.go:2345
↓ 1 callers
Function
cleanSpec
cleanSpec sets default values in ranges for the DescribeSchedule response.
chasm/lib/scheduler/scheduler.go:700
↓ 1 callers
Function
cleanTaskQueue
(proto *taskqueuepb.TaskQueue, taskType enumspb.TaskQueueType)
service/history/workflow/workflow_task_state_machine.go:1590
↓ 1 callers
Method
cleanUpWorkflowPastRetention
( ctx context.Context, mutableState *persistencespb.WorkflowMutableState, )
service/worker/scanner/history/scavenger.go:329
↓ 1 callers
Method
cleanup
(restoreOld bool)
cmd/tools/protogen/main.go:386
↓ 1 callers
Method
cleanupCachedTasks
()
chasm/tree.go:2778
↓ 1 callers
Method
cleanupExecutionInfo
cleanupExecutionInfo cleans up workflow execution info after visibility close task has been processed and acked by visibility store.
service/history/visibility_queue_task_executor.go:623
↓ 1 callers
Method
cleanupLoop
()
common/quotas/map_request_rate_limiter_impl.go:137
↓ 1 callers
Method
cleanupLoop
()
common/tasks/interleaved_weighted_round_robin.go:192
↓ 1 callers
Method
cleanupPQ
()
service/history/queues/rescheduler.go:243
↓ 1 callers
Method
cleanupTransaction
()
chasm/tree.go:2346
↓ 1 callers
Method
clear
()
service/history/queues/tracker.go:108
↓ 1 callers
Method
clearPerKeyRateLimitsLocked
clearPerKeyRateLimitsLocked removes all fairness per-key rate limits.
service/matching/ratelimit_manager.go:316
↓ 1 callers
Method
clearStickyTaskQueue
(ctx context.Context, wfContext historyi.WorkflowContext)
service/history/api/respondworkflowtaskcompleted/api.go:1087
↓ 1 callers
Method
cloneWithTags
(tags []tag.Tag)
common/log/zap_logger.go:201
↓ 1 callers
Method
close
()
tests/testcore/clients.go:119
↓ 1 callers
Method
closeTime
(ctx chasm.Context)
chasm/lib/nexusoperation/operation.go:672
↓ 1 callers
Method
closeTransactionApplyPendingComponentMetadata
closeTransactionApplyPendingComponentMetadata walks the tree and applies any staged framework metadata (request links, user metadata) to each componen
chasm/tree.go:1498
↓ 1 callers
Method
closeTransactionCleanupInvalidTasks
( validateContext Context, )
chasm/tree.go:2077
↓ 1 callers
Method
closeTransactionForceUpdateVisibility
( immutableContext Context, rootLifecycleChanged bool, )
chasm/tree.go:1780
↓ 1 callers
Method
closeTransactionGenerateChasmRetentionTask
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8196
↓ 1 callers
Method
closeTransactionGeneratePhysicalPureTask
( firstPureTask *persistencespb.ChasmComponentAttributes_Task, firstTaskNode *Node, archetypeID ArchetypeID
chasm/tree.go:2219
↓ 1 callers
Method
closeTransactionGeneratePhysicalSideEffectTask
( sideEffectTask *persistencespb.ChasmComponentAttributes_Task, nodePath []string, archetypeID ArchetypeID,
chasm/tree.go:2195
↓ 1 callers
Method
closeTransactionHandleActivityUserTimerTasks
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8889
↓ 1 callers
Method
closeTransactionHandleBufferedEventsLimit
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8826
↓ 1 callers
Method
closeTransactionHandleNewTasks
( nextVersionedTransition *persistencespb.VersionedTransition, validateContext Context, taskOffset *int64,
chasm/tree.go:2121
↓ 1 callers
Method
closeTransactionHandleRootLifecycleChange
( immutableContext Context, )
chasm/tree.go:1727
↓ 1 callers
Method
closeTransactionHandleSpeculativeWorkflowTask
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:7832
↓ 1 callers
Method
closeTransactionHandleTimeSkipping
( ctx context.Context, transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8908
↓ 1 callers
Method
closeTransactionHandleUnknownVersionedTransition
()
service/history/workflow/mutable_state_impl.go:7939
↓ 1 callers
Method
closeTransactionHandleWorkflowResetTask
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8857
↓ 1 callers
Method
closeTransactionHandleWorkflowTask
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:7785
↓ 1 callers
Method
closeTransactionHandleWorkflowTaskScheduling
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:7803
↓ 1 callers
Method
closeTransactionPrepareEvents
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8399
↓ 1 callers
Method
closeTransactionPrepareTasks
( transactionPolicy historyi.TransactionPolicy, eventBatches [][]*historypb.HistoryEvent, clearBufferEvents
service/history/workflow/mutable_state_impl.go:8157
↓ 1 callers
Method
closeTransactionRegenerateTimerTasksForTimeSkipping
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8947
↓ 1 callers
Method
closeTransactionSerializeNodes
()
chasm/tree.go:1871
↓ 1 callers
Method
closeTransactionTrackTombstones
( transactionPolicy historyi.TransactionPolicy, chasmNodesMutation chasm.NodesMutation, )
service/history/workflow/mutable_state_impl.go:8030
↓ 1 callers
Method
closeTransactionUpdateComponentTasks
( nextVersionedTransition *persistencespb.VersionedTransition, )
chasm/tree.go:1911
↓ 1 callers
Method
closeTransactionUpdateLastRunningClock
( transactionPolicy historyi.TransactionPolicy, workflowEventsSeq []*persistence.WorkflowEvents, )
service/history/workflow/mutable_state_impl.go:8003
↓ 1 callers
Method
closeTransactionUpdateTransitionHistory
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:7846
↓ 1 callers
Method
closeTransactionWithPolicyCheck
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8792
↓ 1 callers
Method
clusterReplicationConfig
()
tests/xdc/replication_enable_test.go:114
↓ 1 callers
Method
collect
collect returns an ordered subset of the input operation log based on the deletion status tracked in this operation tree. The original chronological o
service/history/hsm/tree.go:785
↓ 1 callers
Function
collectArtifactJobs
collectArtifactJobs collects all artifact jobs from workflow runs
tools/flakereport/flakereport.go:144
↓ 1 callers
Function
collectBuildIdInfo
(sets []*persistencespb.CompatibleVersionSet)
service/matching/version_sets_merge.go:55
↓ 1 callers
Function
collectSamples
(name string, family *dto.MetricFamily, m *dto.Metric, samples map[string]sample, histogramSamples map[string]
common/metrics/metricstest/metricstest.go:125
↓ 1 callers
Method
collectTestCases
()
tools/testrunner/junit.go:217
↓ 1 callers
Function
combineUnique
combineUnique combines the given strings into a single string by hashing the length of each string and the string itself. This is used to generate a u
common/persistence/history_task_queue_manager.go:231
↓ 1 callers
Method
commandTypes
( commands []*commandpb.Command, )
service/history/api/command_attr_validator.go:676
↓ 1 callers
Method
commit
( ctx context.Context, memNDCWorkflow Workflow, mutableStateSpec MutableStateInitializationSpec, )
service/history/ndc/history_importer.go:318
↓ 1 callers
Function
commitOrder
commitOrder returns commit SHAs between oldSHA (exclusive) and HEAD (inclusive), in chronological order (oldest first). Shells out to: git log --rever
tools/flakereport/git.go:14
↓ 1 callers
Method
compact
compact filters the operation log based on deletion status. For any operation path: - If any parent in the path is deleted, the operation is excluded
service/history/hsm/tree.go:729
↓ 1 callers
Method
compareActivityAttempts
(attempts int, operator string)
service/history/workflow/matcher/activity_evaluator.go:240
↓ 1 callers
Method
compareActivityId
(activityId string, operation string)
service/history/workflow/matcher/activity_evaluator.go:213
↓ 1 callers
Method
compareActivityState
(status string, operator string)
service/history/workflow/matcher/activity_evaluator.go:218
↓ 1 callers
Method
compareActivityTaskQueue
(taskQueue string, operator string)
service/history/workflow/matcher/activity_evaluator.go:235
↓ 1 callers
Method
compareActivityType
(activityType string, operation string)
service/history/workflow/matcher/activity_evaluator.go:208
↓ 1 callers
Method
compareBackoffInterval
(intervalInSec int, operator string)
service/history/workflow/matcher/activity_evaluator.go:245
↓ 1 callers
Method
compareLastFailure
(val string, operator string)
service/history/workflow/matcher/activity_evaluator.go:255
↓ 1 callers
Function
comparePureTasks
(a, b *persistencespb.ChasmComponentAttributes_Task)
chasm/tree.go:3030
↓ 1 callers
Function
compareQueryString
(inStr string, expectedStr string, operation string, colName string)
service/matching/workers/worker_query_engine.go:393
↓ 1 callers
Function
compareSideEffectTasks
(a, b *persistencespb.ChasmComponentAttributes_Task)
chasm/tree.go:3023
↓ 1 callers
Method
compareStartTime
(val string, operation string)
service/history/workflow/matcher/activity_evaluator.go:265
↓ 1 callers
Method
compareStartTime
(val string, operation string)
service/history/workflow/matcher/mutable_state_evaluator.go:208
↓ 1 callers
Method
compareVersionHistory
( namespaceID namespace.ID, workflowID string, runID string, scheduledEventID int64, mutableState history
service/history/ndc/activity_state_replicator.go:383
↓ 1 callers
Method
compareWorkflowID
(workflowID string, operation string)
service/history/workflow/matcher/mutable_state_evaluator.go:188
↓ 1 callers
Method
compareWorkflowStatus
(status string, operation string)
service/history/workflow/matcher/mutable_state_evaluator.go:193
↓ 1 callers
Method
compareWorkflowType
(workflowType string, operation string)
service/history/workflow/matcher/mutable_state_evaluator.go:183
↓ 1 callers
Method
completeChasmOperation
( ctx context.Context, logger log.Logger, completion *tokenspb.NexusOperationCompletion, successPayload *c
service/frontend/nexus_completion_http_handler.go:287
↓ 1 callers
Method
completeHSMOperation
( ctx context.Context, completion *tokenspb.NexusOperationCompletion, successPayload *commonpb.Payload, re
service/frontend/nexus_completion_http_handler.go:254
↓ 1 callers
Method
completeHistoryImmediateTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/sql/execution_tasks.go:139
↓ 1 callers
Method
completeHistoryScheduledTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/sql/execution_tasks.go:257
↓ 1 callers
Method
completeHistoryTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/cassandra/mutable_state_task_store.go:842
↓ 1 callers
Method
completeNexusOperation
(ctx context.Context, result any, callbackUrl, callbackToken string)
tests/xdc/nexus_state_replication_test.go:726
↓ 1 callers
Method
completeReplicationTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/sql/execution_tasks.go:560
↓ 1 callers
Method
completeReplicationTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/cassandra/mutable_state_task_store.go:470
↓ 1 callers
Method
completeReplicationTaskLoop
()
service/history/replication/task_processor_manager.go:210
↓ 1 callers
Method
completeTasks
( ctx context.Context, key *p.TaskQueueKey, exclusiveMaxTaskID int64, limit int, )
service/worker/scanner/taskqueue/db.go:19
↓ 1 callers
Method
completeTimerTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/sql/execution_tasks.go:421
↓ 1 callers
Method
completeTimerTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/cassandra/mutable_state_task_store.go:411
↓ 1 callers
Method
completeTransferTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/sql/execution_tasks.go:348
↓ 1 callers
Method
completeTransferTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/cassandra/mutable_state_task_store.go:328
↓ 1 callers
Method
completeVisibilityTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/sql/execution_tasks.go:735
↓ 1 callers
Method
completeVisibilityTask
( ctx context.Context, request *p.CompleteHistoryTaskRequest, )
common/persistence/cassandra/mutable_state_task_store.go:664
↓ 1 callers
Method
completeWorkflowTasksAndScheduleActivities
( env *taskQueueStatsContext, tqName string, deploymentName string, buildID string, activityCount int, )
tests/task_queue_stats_test.go:1004
↓ 1 callers
Method
component
(fqn string)
chasm/registry.go:204
↓ 1 callers
Method
componentContextValue
(key any)
chasm/registry.go:384
↓ 1 callers
Method
componentLinks
componentLinks returns the union of links across all requests stored on the given component's metadata. Pending writes staged in the current transacti
chasm/tree.go:1415
← previous
next →
11,101–11,200 of 43,335, ranked by callers