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
Method
set
set sets rt to call f after delay. set to <= 0 stops the timer.
service/matching/matcher_data.go:647
↓ 2 callers
Method
setAndCheckOverrideWithExpectedOutput
(env *testcore.TestEnv, tv *testvars.TestVars, inputOverride, expectedOutputOverride *workflowpb.VersioningOve
tests/worker_deployment_version_test.go:1857
↓ 2 callers
Method
setCurrentVersionAllowNoPollersOption
( env *VersioningTestEnv, tv *testvars.TestVars, ignoreMissingTaskQueues, allowNoPollers, ensureSystemWorkf
tests/worker_deployment_test.go:3398
↓ 2 callers
Method
setDefaultParams
(t *testing.T)
service/worker/dlq/workflow_test.go:554
↓ 2 callers
Function
setDefaultPerUnitHistogramBoundaries
(clientConfig *ClientConfig)
common/metrics/config.go:376
↓ 2 callers
Method
setEnabled
(enabled bool)
common/nexus/endpoint_registry.go:121
↓ 2 callers
Method
setPriority
(task *internalTask)
service/matching/pri_backlog_manager.go:439
↓ 2 callers
Method
setReadLevelAfterGap
(newReadLevel int64)
service/matching/ack_manager.go:63
↓ 2 callers
Method
setRemoveFunc
setRemoveFunc sets the function to remove the task from the matcher. It returns true if the task is still valid and the function was set, false if the
service/matching/task.go:348
↓ 2 callers
Method
setSerializedNode
( nodePath []string, encodedPath string, serializedNode *persistencespb.ChasmNode, )
chasm/tree.go:772
↓ 2 callers
Function
setTestComponentFields
(c *TestComponent, backend *MockNodeBackend)
chasm/test_component_test.go:185
↓ 2 callers
Method
setTimerLocked
(newTmr clock.Timer)
common/dynamicconfig/gradual_change.go:191
↓ 2 callers
Method
setVersionSummaryDraining
(version string, routingUpdateTime *timestamppb.Timestamp)
service/worker/workerdeployment/workflow.go:1102
↓ 2 callers
Method
setupCache
()
service/history/api/respondactivitytaskfailed/api_test.go:452
↓ 2 callers
Method
setupCluster
(options ...TestClusterOption)
tests/testcore/functional_test_base.go:298
↓ 2 callers
Function
setupFsEmulation
(s3cli *mocks.MockS3API)
common/archiver/s3store/history_archiver_test.go:87
↓ 2 callers
Method
setupLookAheadMock
( hasLookAheadTask bool, )
service/history/queues/queue_scheduled_test.go:300
↓ 2 callers
Function
setupMutableStateWithStartedActivity
setupMutableStateWithStartedActivity creates mock shard and mutable state with an activity that is already started (StartedEventId != EmptyEventID). T
service/history/api/recordactivitytaskstarted/api_test.go:284
↓ 2 callers
Method
setupNamespaceRegistry
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:578
↓ 2 callers
Method
setupReadComponent
()
chasm/lib/nexusoperation/operation_tasks_test.go:140
↓ 2 callers
Method
setupReadComponent
()
chasm/lib/nexusoperation/cancellation_tasks_test.go:105
↓ 2 callers
Method
setupRecordActivityTaskStartedMock
(tlName string)
service/matching/matching_engine_test.go:4630
↓ 2 callers
Method
setupSQLiteDatabase
(cfg *config.SQL, conn *sqlx.DB, logger log.Logger)
common/persistence/sql/sqlplugin/sqlite/plugin.go:152
↓ 2 callers
Method
setupStartWorkflowExecutionDedup
(startTime *timestamppb.Timestamp)
service/history/history_engine2_test.go:1586
↓ 2 callers
Method
setupStartWorkflowExecutionForTerminate
()
service/history/history_engine2_test.go:1613
↓ 2 callers
Method
setupTemplate
setupTemplate handles template configuration
tools/elasticsearch/tasks.go:50
↓ 2 callers
Method
setupUpdateComponent
()
chasm/lib/nexusoperation/operation_tasks_test.go:169
↓ 2 callers
Method
setupUpdateComponent
()
chasm/lib/nexusoperation/cancellation_tasks_test.go:120
↓ 2 callers
Function
shardTotals
(smap map[string]float64, shards int, salt string)
tools/optimize-test-sharding/main.go:273
↓ 2 callers
Method
shortSHA
()
tools/ci-notify/types.go:69
↓ 2 callers
Method
shouldGenerateChecksum
()
service/history/workflow/mutable_state_impl.go:9038
↓ 2 callers
Method
shouldPrune
(t reflect.Type)
common/testing/objectleak/walker.go:86
↓ 2 callers
Method
shouldReadMoreLocked
()
service/matching/fair_task_reader.go:211
↓ 2 callers
Function
shouldReapplyEvent
shouldReapplyEvent returns true if the event should be reapplied to the workflow execution.
service/history/workflow/util.go:228
↓ 2 callers
Method
shouldRouteToExecutionQueueScheduler
(task T)
common/tasks/execution_aware_scheduler.go:124
↓ 2 callers
Method
shouldUpdateMetadataOnAppendLocked
shouldUpdateMetadataOnAppendLocked returns whether a task append should also write the metadata blob. This is always true when enough time has passed
service/matching/db.go:291
↓ 2 callers
Method
shouldVerifyChecksum
()
service/history/workflow/mutable_state_impl.go:9045
↓ 2 callers
Method
signalAndWaitForDrained
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/worker_deployment_version_test.go:715
↓ 2 callers
Method
signalDemoteVersion
signalDemoteVersion sends a signal to a version workflow to demote it with the given routing config. The version workflow will determine its new statu
service/worker/workerdeployment/workflow.go:1587
↓ 2 callers
Method
signalPropagationComplete
signalPropagationComplete sends a signal to the deployment workflow when async propagation completes
service/worker/workerdeployment/version_workflow.go:1464
↓ 2 callers
Method
slideBase
slideBase increases the base by delta, subtracting delta from all cells. Cells that would go negative are clamped to 0 (those keys are "dragged up").
service/matching/counter/cmsketch.go:227
↓ 2 callers
Function
softDeadlockTimeout
()
common/testing/await/require_ctx.go:22
↓ 2 callers
Function
sortAncestors
(ans []*persistencespb.HistoryBranchRange)
common/persistence/history_manager_util.go:126
↓ 2 callers
Function
sortAndFilterFiles
sortAndFilterFiles sort visibility record file names based on close timestamp (desc) and use hashed runID to break ties. if a nextPageToken is give, i
common/archiver/filestore/visibility_archiver.go:255
↓ 2 callers
Function
sortAndFilterVersions
sortAndFilterVersions returns a sorted list of semantic versions the fall within the range (startVerExcl, endVerIncl]. If endVerIncl is not specified,
tools/common/schema/updatetask.go:312
↓ 2 callers
Method
sortedSummaries
()
service/worker/workerdeployment/workflow.go:1757
↓ 2 callers
Function
speculativeWorkflowTaskOutcomes
( capture *testcore.GlobalMetricCapture, )
tests/update_workflow_test.go:36
↓ 2 callers
Method
split
( thisScope Scope, thatScope Scope, )
service/history/queues/tracker.go:28
↓ 2 callers
Function
splitBufferedStartsForLegacy
( starts []*schedulespb.BufferedStart, )
chasm/lib/scheduler/migration/migration.go:393
↓ 2 callers
Function
splitSearchAttributes
splitSearchAttributes splits decoded search attributes into CHASM and custom attributes.
common/persistence/visibility/visibility_manager_impl.go:246
↓ 2 callers
Method
splitTask
()
service/history/ndc/replication_task.go:49
↓ 2 callers
Function
splitUserAndChasmMemo
splitUserAndChasmMemo extracts user memo and CHASM memo from the combined memo.
common/persistence/visibility/visibility_manager_impl.go:260
↓ 2 callers
Function
standbyTimerTaskPostActionTaskDiscarded
( _ context.Context, taskInfo tasks.Task, postActionInfo any, logger log.Logger, )
service/history/ndc_standby_task_util.go:67
↓ 2 callers
Method
start
(controller *ControllerImpl)
service/history/shard/ownership.go:60
↓ 2 callers
Method
startActivityWithType
(ctx context.Context, activityID string, taskQueue string, activityType *commonpb.ActivityType)
tests/activity_standalone_test.go:6335
↓ 2 callers
Method
startAndAcceptUpdateInCluster1ThenFailoverTo2AndCompleteUpdate
Start update in cluster0, run it through to acceptance, replicate it to cluster1, then failover to 2 and complete the update there.
tests/xdc/history_replication_signals_and_updates_test.go:441
↓ 2 callers
Function
startChildWorkflowCommand
(tv *testvars.TestVars)
tests/versioning_3_test.go:2340
↓ 2 callers
Method
startDrainage
(ctx workflow.Context)
service/worker/workerdeployment/version_workflow.go:473
↓ 2 callers
Method
startPinnedWorkflow
(ctx context.Context, env *testcore.TestEnv, tv *testvars.TestVars)
tests/worker_deployment_version_test.go:511
↓ 2 callers
Function
startServerProcess
(t *testing.T, name, binary, configDir, logPath string)
tests/mixedbrain/server_util.go:33
↓ 2 callers
Function
startTestServer
(t *testing.T, opt ...grpc.ServerOption)
chasm/interceptor_test.go:97
↓ 2 callers
Method
startToCloseTimeoutTask
startToCloseTimeoutTask returns the StartToCloseTimeout task if the timeout is set. This task is created when an operation transitions to the STARTED
components/nexusoperations/statemachine.go:161
↓ 2 callers
Method
startVersion
(ctx workflow.Context, args *deploymentspb.StartWorkerDeploymentVersionRequest)
service/worker/workerdeployment/workflow.go:1719
↓ 2 callers
Method
startVersionedWorkflow
(ctx context.Context, env *testcore.TestEnv, tv *testvars.TestVars, behavior workflow.VersioningBehavior)
tests/worker_deployment_version_test.go:484
↓ 2 callers
Method
startWithMemoHelper
helper function for TestStartWithMemo and TestSignalWithStartWithMemo to reduce duplicate code
tests/workflow_memo_test.go:121
↓ 2 callers
Function
startWorkflowExecutionRequestIDMatches
(requestID string)
chasm/lib/scheduler/invoker_execute_task_test.go:575
↓ 2 callers
Function
startWorkflowRequest
(s testcore.Env, tv *testvars.TestVars)
tests/workflow_utils.go:18
↓ 2 callers
Function
statusAdmitted
()
service/history/workflow/update/status.go:19
↓ 2 callers
Function
statusCompleted
(outcome *updatepb.Outcome)
service/history/workflow/update/status.go:40
↓ 2 callers
Function
statusOfInternalWorkflowMutation
( mutation *InternalWorkflowMutation, historyStatistics *HistoryStatistics, )
common/persistence/size.go:104
↓ 2 callers
Function
stickyWorkerAvailable
We use a very short timeout for considering a sticky worker available, since tasks can also be processed on the normal queue.
service/matching/matching_engine.go:3437
↓ 2 callers
Function
stopManager
(t *testing.T, manager *PerNamespaceWorkerManager)
service/worker/pernamespaceworker_test.go:81
↓ 2 callers
Function
stringMap
(a []string, f func(string) string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:88
↓ 2 callers
Function
stringMap
(a []string, f func(string) string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:55
↓ 2 callers
Function
stringMap
(a []string, f func(string) string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:54
↓ 2 callers
Method
structuredRef
(Component)
chasm/context.go:67
↓ 2 callers
Function
subtractStatsByPriority
(into, sub map[int32]*taskqueuepb.TaskQueueStats)
service/matching/task_queue_partition_manager.go:1855
↓ 2 callers
Function
suiteRunKey
suiteRunKey returns a string that uniquely identifies a single (CI run × DB config) pair. Each workflow run may spawn multiple matrix jobs sharing the
tools/flakereport/parser.go:420
↓ 2 callers
Method
summary
summary returns a shorthand summary string suitable for logging.
common/membership/ringpop/hostinfo.go:51
↓ 2 callers
Method
syncActivityToReplicationTask
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:8486
↓ 2 callers
Method
syncExecutionInfo
(current *persistencespb.WorkflowExecutionInfo, incoming *persistencespb.WorkflowExecutionInfo, isSnapshot boo
service/history/workflow/mutable_state_impl.go:9441
↓ 2 callers
Function
syncOfferTask
( ctx context.Context, tm *TaskMatcher, task *internalTask, taskChan chan *internalTask, forwardFunc func
service/matching/matcher.go:189
↓ 2 callers
Method
syncOfferTask
( ctx context.Context, task *internalTask, returnNoPollerErr bool, )
service/matching/pri_matcher.go:447
↓ 2 callers
Method
syncSingleActivityState
( workflowKey *definition.WorkflowKey, mutableState historyi.MutableState, activitySyncInfo *historyservice
service/history/ndc/activity_state_replicator.go:268
↓ 2 callers
Method
syncStateInBatches
(totalWorkers int)
service/worker/workerdeployment/version_workflow_test.go:89
↓ 2 callers
Method
syncSubField
syncSubField syncs node n with value from fieldV parameter. If fieldV is a component, then it will sync all subcomponents recursively. It returns: - b
chasm/tree.go:1074
↓ 2 callers
Method
syncUnversionedRampInBatches
(totalWorkers int)
service/worker/workerdeployment/workflow_test.go:409
↓ 2 callers
Method
syncVersionDataToTaskQueues
syncVersionDataToTaskQueues is a helper that syncs the provided version data to all task queues. This function does NOT acquire the workflow lock - th
service/worker/workerdeployment/version_workflow.go:1249
↓ 2 callers
Function
tagsToMap
(t1 []Tag, e excludeTags)
common/metrics/tally_metrics_handler.go:283
↓ 2 callers
Function
taskAddErrResult
(err error)
service/matching/task_queue_partition_manager.go:694
↓ 2 callers
Function
taskBaseMetricTagsWithoutArchetype
( task tasks.Task, namespaceRegistry namespace.Registry, currentClusterName string, chasmRegistry *chasm.R
service/history/queues/executable.go:865
↓ 2 callers
Function
taskCountsByCategory
(t *map[tasks.Category][]InternalHistoryTask)
common/persistence/size.go:222
↓ 2 callers
Function
taskFairLevel
taskFairLevel returns the fair level for a task, or the zero fairLevel for tasks with no event (query, nexus, and poll-forwarder tasks).
service/matching/matcher_data.go:148
↓ 2 callers
Method
tearDownLocked
(t *testing.T)
tests/testcore/test_cluster_pool.go:148
↓ 2 callers
Function
telemetryUnaryOverrideOperationTag
telemetryUnaryOverrideOperationTag is used to override scope used for reporting a metric. Ideally this method should never be used.
common/rpc/interceptor/telemetry.go:116
↓ 2 callers
Method
terminalFailure
terminalFailure returns the failure for a closed activity. The failure may be stored in Outcome.Failed (terminated, canceled, timed out) or in LastAtt
chasm/lib/activity/activity.go:1046
↓ 2 callers
Method
terminateWorkflow
( mutableState historyi.MutableState, terminateReason string, )
service/history/ndc/workflow_resetter.go:629
↓ 2 callers
Method
terminateWorkflow
( env *testcore.TestEnv, )
tests/workflow_alias_search_attribute_test.go:116
↓ 2 callers
Method
testAppendFlushFinishEventWithoutBufferMultiBatch
( flushBuffer bool, )
service/history/historybuilder/history_builder_test.go:1729
↓ 2 callers
Method
testAppendFlushFinishEventWithoutBufferSingleBatch
( flushBuffer bool, )
service/history/historybuilder/history_builder_test.go:1686
← previous
next →
8,901–9,000 of 43,335, ranked by callers