MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 2 callersFunctiontestCapture
(panicObj any)
common/log/panic_test.go:20
↓ 2 callersMethodtestChannelSize
( channel chan struct{}, )
common/locks/condition_variable_test.go:52
↓ 2 callersMethodtestChildWorkflowInheritanceExpectNoInherit
(crossTq bool, parentBehavior enumspb.VersioningBehavior)
tests/versioning_3_test.go:2025
↓ 2 callersFunctiontestCreateScheduleDuplicateSdkError
CreateSchedule is special-cased in the SDKs to translate serviceerror.WorkflowExecutionAlreadyStarted into temporal.ErrScheduleAlreadyRunning. This te
tests/schedule_test.go:2458
↓ 2 callersMethodtestFailAddTaskWithHistoryError
( tqName string, expectSyncMatch bool, recordError error, expectedError error, )
service/matching/matching_engine_test.go:490
↓ 2 callersMethodtestListResultForUpsertSearchAttributes
(env *testcore.TestEnv, listRequest *workflowservice.ListWorkflowExecutionsRequest)
tests/advanced_visibility_test.go:1531
↓ 2 callersMethodtestListWorkflowHelper
( env *testcore.TestEnv, numOfWorkflows, pageSize int, startRequest *workflowservice.StartWorkflowExecution
tests/advanced_visibility_test.go:796
↓ 2 callersFunctiontestMapBaggage
roughly 1.7s/7.5s for mutex/sync baggageCount := 1000 threadCount := 20 updatesPerThread := 1000
common/metrics/baggage_bench_test.go:92
↓ 2 callersFunctiontestNoopRequestRateLimiterImpl
(t *testing.T, rl quotas.RequestRateLimiter)
common/quotas/noop_request_rate_limiter_impl_test.go:18
↓ 2 callersMethodtestPollerScalingOnPromotedVersionConsidersUnversionedQueueBacklog
( expectedStatus enumspb.WorkerDeploymentVersionStatus, promoteDeploymentVersion func(env *testcore.TestEnv,
tests/poller_scaling_test.go:236
↓ 2 callersMethodtestQueryWithPinnedOverride
(env *testcore.TestEnv, sticky bool)
tests/versioning_3_test.go:466
↓ 2 callersMethodtestRemoteSyncMatch
(taskSource enumsspb.TaskSource)
service/matching/matcher_test.go:140
↓ 2 callersFunctiontestResetWithAdditionalCallback
(t *testing.T, newContext contextFactory, enableCHASMCallbacks bool)
tests/schedule_test.go:1932
↓ 2 callersMethodtestResetWorkflowSignalReapplyBuffer
( env *testcore.TestEnv, tv *testvars.TestVars, reapplyType enumspb.ResetReapplyType, )
tests/reset_workflow_test.go:729
↓ 2 callersFunctiontestRoundTrip
(t *testing.T, address string)
chasm/interceptor_test.go:74
↓ 2 callersFunctiontestScheduledWorkflowDoubleReset
(t *testing.T, newContext contextFactory, enableCHASMCallbacks bool)
tests/schedule_test.go:1775
↓ 2 callersMethodtestServerTLSRefresh
(factory *TestFactory, ca *tls.Certificate, certDir string, serialNumber int64)
common/rpc/test/rpc_localstore_tls_test.go:608
↓ 2 callersMethodtestTokenGenerator
(alg keyAlgorithm)
common/authorization/default_jwt_claim_mapper_test.go:83
↓ 2 callersMethodtestTokenWithAdminPermissions
(alg keyAlgorithm)
common/authorization/default_jwt_claim_mapper_test.go:122
↓ 2 callersMethodtestTokenWithReaderWriterWorkerPermissions
(alg keyAlgorithm)
common/authorization/default_jwt_claim_mapper_test.go:169
↓ 2 callersMethodtestTransitionDuringTransientTask
TestTransitionDuringTransientTask verifies that a deployment version transition to v1 is properly set when a workflow task fails and is retried, and t
tests/versioning_3_test.go:6351
↓ 2 callersMethodtestTransitionFromActivity
(sticky bool)
tests/versioning_3_test.go:1620
↓ 2 callersMethodtestUnpinnedQuery
(env *testcore.TestEnv, sticky bool)
tests/versioning_3_test.go:515
↓ 2 callersMethodtestUnpinnedWorkflow
(env *testcore.TestEnv, sticky bool)
tests/versioning_3_test.go:636
↓ 2 callersMethodtestUnpinnedWorkflowWithRamp
(env *testcore.TestEnv, toUnversioned bool)
tests/versioning_3_test.go:1144
↓ 2 callersMethodtestWorkflowTaskRedirectInRetry
( env *testcore.TestEnv, firstTask bool, )
tests/versioning_test.go:1345
↓ 2 callersMethodtestWorkflowWithPinnedOverride
(env *testcore.TestEnv, sticky bool)
tests/versioning_3_test.go:299
↓ 2 callersFunctiontestingTParamName
testingTParamName returns the name of the *testing.T parameter, or "" if not found.
tools/parallelize/parallelize.go:134
↓ 2 callersMethodtoArchivalRegisterEvent
( state enumspb.ArchivalState, URI string, defaultState enumspb.ArchivalState, defaultURI string, )
service/frontend/namespace_handler.go:1007
↓ 2 callersMethodtoArchivalUpdateEvent
( state enumspb.ArchivalState, URI string, defaultURI string, )
service/frontend/namespace_handler.go:1028
↓ 2 callersFunctiontoStr
(t *testing.T, v attribute.Value)
common/telemetry/grpc_test.go:114
↓ 2 callersMethodtoWorkflowMutableState
(internState *InternalWorkflowMutableState)
common/persistence/execution_manager.go:1144
↓ 2 callersFunctiontopLevelTestName
topLevelTestName extracts the suite/top-level test name from a test name. For "TestSuiteV0/TestMethod" returns "TestSuiteV0". For "TestFoo" (no slash)
tools/flakereport/parser.go:52
↓ 2 callersMethodtrackAuthInfoByCall
(env *testcore.TestEnv)
tests/tls_test.go:78
↓ 2 callersMethodtransitionTasks
transitionTasks returns tasks that are emitted as transition outputs.
components/nexusoperations/statemachine.go:129
↓ 2 callersFunctiontrimNodes
( nodeIDToNodes map[int64][]historyNodeMetadata, nodeChain []historyNodeMetadata, )
common/persistence/history_node_util.go:115
↓ 2 callersMethodtruncateRetryableActivityFailure
( activityFailure *failurepb.Failure, )
service/history/workflow/mutable_state_impl.go:7115
↓ 2 callersMethodtryDeleteNextBatch
(ackLevel int64, ignoreTimeCond bool)
service/matching/task_gc.go:58
↓ 2 callersMethodtryDeleteTaskQueue
(key *p.TaskQueueKey, state *taskQueueState)
service/worker/scanner/taskqueue/handler.go:80
↓ 2 callersMethodtryDeleteVersion
(ctx workflow.Context)
service/worker/workerdeployment/workflow.go:1520
↓ 2 callersMethodtryEnqueue
( ctx context.Context, queueType persistence.QueueType, messageID int64, blob *commonpb.DataBlob, )
common/persistence/cassandra/queue_store.go:89
↓ 2 callersFunctionunmanagedFieldsOf
unmanagedFieldsOf yields all non-CHASM managed fields of a struct.
chasm/fields_iterator.go:104
↓ 2 callersFunctionunmarshalProtoByTypeName
unmarshalProtoByTypeName resolves a proto type by its full name from the global registry and unmarshals the given bytes into it.
tools/tdbg/proto_decoder.go:120
↓ 2 callersMethodunmatched
()
common/testing/objectleak/pattern.go:66
↓ 2 callersMethodunsetCurrentDeployment
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/versioning_3_test.go:4164
↓ 2 callersMethodunversionedPollActivityAndHandle
( env *testcore.TestEnv, tv *testvars.TestVars, async chan<- struct{}, handler func(task *workflowservice.
tests/versioning_3_test.go:4808
↓ 2 callersMethodupdateAckLevel
( ctx context.Context, metadata *persistence.InternalQueueMetadata, queueType persistence.QueueType, )
common/persistence/cassandra/queue_store.go:307
↓ 2 callersMethodupdateAckLevelWithRetry
( ctx context.Context, lastProcessedMessageID int64, clusterName string, isDLQ bool, )
common/persistence/namespace_replication_queue.go:164
↓ 2 callersMethodupdateActivityInfoForRetries
( ai *persistencespb.ActivityInfo, nextScheduledTime time.Time, nextAttempt int32, activityFailure *failur
service/history/workflow/mutable_state_impl.go:6888
↓ 2 callersFunctionupdateActivityInfos
( batch *gocql.Batch, activityInfos map[int64]*commonpb.DataBlob, deleteIDs map[int64]struct{}, shardID in
common/persistence/cassandra/util.go:610
↓ 2 callersFunctionupdateActivityOptions
( ms historyi.MutableState, ai *persistencespb.ActivityInfo, activityOptions *activitypb.ActivityOptions, )
service/history/api/updateactivityoptions/api.go:361
↓ 2 callersFunctionupdateChasmNodes
( batch *gocql.Batch, upsertNodes map[string]p.InternalChasmNode, deleteNodes map[string]struct{}, shardID
common/persistence/cassandra/util.go:982
↓ 2 callersFunctionupdateChildExecutionInfos
( batch *gocql.Batch, childExecutionInfos map[int64]*commonpb.DataBlob, deleteIDs map[int64]struct{}, shar
common/persistence/cassandra/util.go:758
↓ 2 callersMethodupdateComponentInExecution
( ctx context.Context, execution *execution, ref chasm.ComponentRef, updateFn func(chasm.MutableContext, c
chasm/chasmtest/test_engine.go:596
↓ 2 callersFunctionupdateCurrentClusterMetadataRecord
( ctx context.Context, clusterMetadataManager persistence.ClusterMetadataManager, svc *config.Config, init
temporal/fx.go:784
↓ 2 callersFunctionupdateCurrentExecution
( ctx context.Context, tx sqlplugin.Tx, row sqlplugin.CurrentExecutionsRow, )
common/persistence/sql/execution_util.go:1060
↓ 2 callersMethodupdateEntryTTL
(entry *entryImpl)
common/cache/lru.go:432
↓ 2 callersMethodupdateEphemeralData
updateEphemeralData updates the ephemeral data owned by this partition. The update function will be given a non-nil clone of the current data, which i
service/matching/user_data_manager.go:801
↓ 2 callersFunctionupdateExecution
( batch *gocql.Batch, shardID int32, namespaceID string, workflowID string, runID string, executionInfoB
common/persistence/cassandra/util.go:405
↓ 2 callersMethodupdateExecution
( ctx context.Context, tx sqlplugin.Tx, namespaceID string, workflowID string, executionInfo *commonpb.Da
common/persistence/sql/execution_util.go:1169
↓ 2 callersMethodupdateFairAckLevel
(subqueue subqueueIndex, newAckLevel fairLevel, countDelta, knownCount int64, oldestTime time.Time)
service/matching/db.go:364
↓ 2 callersMethodupdateHeap
(key string, count int64)
service/matching/counter/map.go:55
↓ 2 callersMethodupdateIDToNamespace
( iDToNamespace map[namespace.ID]*namespace.Namespace, id namespace.ID, newNS *namespace.Namespace, )
common/namespace/nsregistry/registry.go:712
↓ 2 callersFunctionupdateIndexSearchAttributes
updateIndexSearchAttributes updates the IndexSearchAttributes if needed. Returns true if any change was made.
temporal/fx.go:870
↓ 2 callersMethodupdateKeys
()
common/authorization/default_token_key_provider.go:113
↓ 2 callersFunctionupdateMetadata
( ctx context.Context, tx sqlplugin.Tx, oldNotificationVersion int64, )
common/persistence/sql/metadata.go:260
↓ 2 callersMethodupdateMetadata
(env *testcore.TestEnv, tv *testvars.TestVars, upsertEntries map[string]*commonpb.Payload, removeEntries []str
tests/worker_deployment_version_test.go:130
↓ 2 callersMethodupdateNamespace
( ctx context.Context, request *persistence.InternalUpdateNamespaceRequest, operationName string, )
common/persistence/sql/metadata.go:140
↓ 2 callersMethodupdateOnlyWasAbortedByClosingWorkflow
(err error)
service/history/api/multioperation/api.go:166
↓ 2 callersMethodupdateQuota
(newQuota T)
common/quotas/calculator/logged_calculator.go:93
↓ 2 callersFunctionupdateRequestCancelInfos
( batch *gocql.Batch, requestCancelInfos map[int64]*commonpb.DataBlob, deleteIDs map[int64]struct{}, shard
common/persistence/cassandra/util.go:823
↓ 2 callersFunctionupdateSignalInfos
( batch *gocql.Batch, signalInfos map[int64]*commonpb.DataBlob, deleteIDs map[int64]struct{}, shardID int3
common/persistence/cassandra/util.go:888
↓ 2 callersFunctionupdateSignalsRequested
( batch *gocql.Batch, signalReqIDs map[string]struct{}, deleteSignalReqIDs map[string]struct{}, shardID in
common/persistence/cassandra/util.go:1020
↓ 2 callersMethodupdateSimpleRateLimitWithBurstLocked
UpdateSimpleRateLimit updates the overall queue rate limits for the simpleRateLimiter implementation
service/matching/ratelimit_manager.go:266
↓ 2 callersMethodupdateStateFromRoutingConfig
updateStateFromRoutingConfig updates the version state based on routing config received from Deployment. returns true if any information that affects
service/worker/workerdeployment/version_workflow.go:988
↓ 2 callersFunctionupdateTimerInfos
( batch *gocql.Batch, timerInfos map[string]*commonpb.DataBlob, deleteInfos map[string]struct{}, shardID i
common/persistence/cassandra/util.go:693
↓ 2 callersMethodupdateTweakables
()
service/worker/scheduler/workflow.go:1290
↓ 2 callersMethodupdateVersionStatusAfterDrainageStatusChange
(ctx workflow.Context, newStatus enumspb.VersionDrainageStatus)
service/worker/workerdeployment/version_workflow.go:1194
↓ 2 callersMethodupdateVersionSummary
(summary *deploymentspb.WorkerDeploymentVersionSummary)
service/worker/workerdeployment/workflow.go:206
↓ 2 callersFunctionupdateVersionToClusterName
(clusterInfo map[string]ClusterInformation, failoverVersionIncrement int64)
common/cluster/metadata.go:522
↓ 2 callersMethodupdateVersioningOverride
( override *workflowpb.VersioningOverride, )
service/history/workflow/mutable_state_impl.go:5973
↓ 2 callersMethodupdateWorkerCount
(targetWorkerNum int)
common/tasks/sequential_scheduler.go:201
↓ 2 callersMethodupdateWorkerCount
(targetWorkerNum int)
common/tasks/fifo_scheduler.go:111
↓ 2 callersMethodupdateWorkflowMode
()
service/history/workflow/context.go:863
↓ 2 callersMethodupsertCustomSearchAttributesAliases
( current map[string]string, upsert map[string]string, )
service/frontend/namespace_handler.go:984
↓ 2 callersMethodupsertMyMembership
( ctx context.Context, request *persistence.UpsertClusterMembershipRequest, )
common/membership/ringpop/monitor.go:233
↓ 2 callersFunctionuseClassicMatcher
TODO(pri): cleanup; delete this
service/matching/matching_engine_test.go:6125
↓ 2 callersFunctionuseFairness
(config *Config)
service/matching/matching_engine_test.go:6129
↓ 2 callersMethodusingBuildIdQueue
(taskType enumspb.TaskQueueType, buildId string)
service/matching/forwarder_test.go:501
↓ 2 callersMethoduuidString
(_ string)
common/testing/testvars/test_vars.go:91
↓ 2 callersMethodvalidate
()
common/namespace/archival_config_state_machine.go:53
↓ 2 callersFunctionvalidateAndNormalizeCancelRequest
(req *workflowservice.RequestCancelNexusOperationExecutionRequest, config *Config)
chasm/lib/nexusoperation/validator.go:256
↓ 2 callersFunctionvalidateAndNormalizeCancelRequest
( req *workflowservice.RequestCancelActivityExecutionRequest, maxIDLengthLimit int, blobSizeLimitError dyna
chasm/lib/activity/validator.go:399
↓ 2 callersFunctionvalidateAndNormalizeDeleteRequest
(req *workflowservice.DeleteNexusOperationExecutionRequest, config *Config)
chasm/lib/nexusoperation/validator.go:181
↓ 2 callersFunctionvalidateAndNormalizeDescribeRequest
( req *workflowservice.DescribeNexusOperationExecutionRequest, namespaceID string, config *Config, )
chasm/lib/nexusoperation/validator.go:197
↓ 2 callersFunctionvalidateAndNormalizePollRequest
(req *workflowservice.PollNexusOperationExecutionRequest, config *Config)
chasm/lib/nexusoperation/validator.go:229
↓ 2 callersFunctionvalidateAndNormalizeStartRequest
revive:disable-next-line:cognitive-complexity,cyclomatic
chasm/lib/nexusoperation/validator.go:65
↓ 2 callersFunctionvalidateAndNormalizeTerminateRequest
(req *workflowservice.TerminateNexusOperationExecutionRequest, config *Config)
chasm/lib/nexusoperation/validator.go:287
↓ 2 callersFunctionvalidateAndNormalizeTerminateRequest
( req *workflowservice.TerminateActivityExecutionRequest, maxIDLengthLimit int, blobSizeLimitError dynamicc
chasm/lib/activity/validator.go:472
↓ 2 callersFunctionvalidateAndSetForceReplicationParams
(ctx workflow.Context, params *ForceReplicationParams)
service/worker/migration/force_replication_workflow.go:340
← previousnext →9,001–9,100 of 43,335, ranked by callers