MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 2 callersFunctionhistoryMutated
(request *archiver.ArchiveHistoryRequest, historyBatches []*historypb.History, isLast bool)
common/archiver/filestore/util.go:211
↓ 2 callersFunctionhostDownErrorTest
(s *cachingRedirectorSuite, clientOp ClientOperation[historyservice.HistoryServiceClient], verify func(err err
client/history/caching_redirector_test.go:127
↓ 2 callersFunctionhoursAgo
hoursAgo formats a timestamp as "Xh ago" relative to now.
tools/flakereport/report.go:15
↓ 2 callersFunctionhttpEnabled
(cfg *config.Config, serviceName primitives.ServiceName)
service/frontend/fx.go:994
↓ 2 callersFunctionhttpHeaderToNexusHeader
(httpHeader http.Header, excludePrefixes ...string)
common/nexus/nexusrpc/api.go:106
↓ 2 callersMethodidleDeadline
idleDeadline returns when the schedule becomes eligible to close. Sentinels anchor on CreateTime - they have no Invoker (and thus no recentActions).
chasm/lib/scheduler/scheduler.go:507
↓ 2 callersMethodidlePollNexus
(env *testcore.TestEnv, ctx context.Context, tv *testvars.TestVars, versioned bool, timeout time.Duration,
tests/versioning_3_test.go:4936
↓ 2 callersMethodinFlightCount
()
service/history/workflow/update/registry.go:508
↓ 2 callersMethodincAttempt
()
service/history/queues/executable.go:827
↓ 2 callersMethodindependentActivityTaskAssignmentSpooled
( env *testcore.TestEnv, versionedWf bool, )
tests/versioning_test.go:967
↓ 2 callersMethodindependentActivityTaskAssignmentSyncMatch
( env *testcore.TestEnv, versionedWf bool, )
tests/versioning_test.go:1161
↓ 2 callersMethodindex
(index int)
common/testing/objectleak/path.go:28
↓ 2 callersFunctionindexNodeIDToNode
( transactionIDToNode map[int64]historyNodeMetadata, )
common/persistence/history_node_util.go:43
↓ 2 callersMethodinitAssertions
()
service/history/chasm_engine_test.go:141
↓ 2 callersMethodinitAssertions
TODO: remove once `parallelsuite` and testEnv is rolled out everywhere
tests/testcore/functional_test_base.go:394
↓ 2 callersMethodinitAssertions
()
chasm/field_test.go:59
↓ 2 callersMethodinitAssertions
()
chasm/fields_iterator_test.go:33
↓ 2 callersMethodinitAssertions
()
chasm/tree_test.go:81
↓ 2 callersMethodinitAssertions
()
chasm/visibility_test.go:51
↓ 2 callersFunctioninitCurrentClusterMetadataRecord
( ctx context.Context, clusterMetadataManager persistence.ClusterMetadataManager, svc *config.Config, init
temporal/fx.go:736
↓ 2 callersFunctioninitLocalRepo
initLocalRepo creates a bare git repo with one commit on the default branch and one commit on a side branch. Both commits exist as objects in the bare
cmd/tools/check-dependencies/main_test.go:130
↓ 2 callersMethodinitSuite
nolint:revive // see copySuite above.
common/testing/parallelsuite/suite.go:28
↓ 2 callersMethodinitializeBuilders
( namespaceEntry *namespace.Namespace, workflowIdentifier definition.WorkflowKey, now time.Time, )
service/history/ndc/state_rebuilder.go:307
↓ 2 callersMethodinsertEndpointLocked
(entry *persistencespb.NexusEndpointEntry)
service/matching/nexus_endpoint_client.go:190
↓ 2 callersMethodinsertInitialQueueMetadataRecord
( ctx context.Context, queueType persistence.QueueType, blob *commonpb.DataBlob, )
common/persistence/cassandra/queue_store.go:268
↓ 2 callersFunctioninvokeImportWorkflowExecutionCall
( ctx context.Context, historyEngine historyi.Engine, workflowKey definition.WorkflowKey, historyBatches [
service/history/replication/eventhandler/event_importer.go:157
↓ 2 callersMethodinvokeSideEffectTaskFn
( ctx context.Context, registrableTask *RegistrableTask, executionKey ExecutionKey, chasmTask *tasks.Chasm
chasm/tree.go:3499
↓ 2 callersFunctionisAlreadyStartedError
(err error)
chasm/lib/scheduler/invoker_tasks.go:753
↓ 2 callersFunctionisArchivalConfigValid
( clusterStatus string, enableRead bool, namespaceDefaultStatus string, domianDefaultURI string, specifie
common/config/archival.go:29
↓ 2 callersMethodisBacklogNegligible
isBacklogNegligible returns true if the age of the task backlog is less than the threshold. call with lock held.
service/matching/matcher_data.go:583
↓ 2 callersFunctionisCloseTransferTaskAckedForWorkflow
( shardContext historyi.ShardContext, closeTransferTask *tasks.CloseExecutionTask, )
service/history/replication/raw_task_converter.go:900
↓ 2 callersFunctionisComponentTaskExpired
isComponentTaskExpired returns true when the task's scheduled time is equal or before the reference time. The caller should also make sure to account
chasm/tree.go:2900
↓ 2 callersFunctionisConnNeedsRefreshError
(code, message string)
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:30
↓ 2 callersMethodisData
()
chasm/tree.go:653
↓ 2 callersFunctionisDestinationDown
(err error)
components/nexusoperations/executors.go:1027
↓ 2 callersFunctionisDestinationDown
(err error)
chasm/lib/nexusoperation/task_handler_helpers.go:43
↓ 2 callersMethodisDetached
()
chasm/tree.go:661
↓ 2 callersFunctionisDone
(ctx context.Context)
service/worker/batcher/activities.go:786
↓ 2 callersMethodisDrainedLocked
()
service/matching/pri_task_reader.go:436
↓ 2 callersFunctionisDraining
(host *hostInfo)
common/membership/ringpop/service_resolver.go:526
↓ 2 callersFunctionisEnabled
(tp trace.TracerProvider)
common/telemetry/grpc.go:194
↓ 2 callersFunctionisGoTestSuite
isGoTestSuite returns true if the name looks like a Go testify suite name (starts with "Test" and contains "Suite"). e.g. TestDeploymentVersionSuiteV0
tools/flakereport/parser.go:62
↓ 2 callersMethodisHeldOpen
isHeldOpen reports whether the schedule must stay open regardless of having no current work: - Paused: customer expects to resume. - Pending backfill:
chasm/lib/scheduler/scheduler.go:497
↓ 2 callersFunctionisInfoUpdated
(subStateMachine lastUpdatedStateTransitionGetter, versionedTransition *persistencespb.VersionedTransition)
service/history/replication/sync_state_retriever.go:552
↓ 2 callersMethodisLegacyCustomSearchAttribute
(name string)
common/searchattribute/mapper.go:85
↓ 2 callersFunctionisMessageIDConflictError
(err error)
common/persistence/persistence-tests/persistence_test_base.go:343
↓ 2 callersFunctionisNonRetryableError
isNonRetryableError determines if an error should not be retried based on the operation type
service/worker/batcher/activities.go:669
↓ 2 callersFunctionisProtoInternalField
(fieldName string)
chasm/test_component_test.go:416
↓ 2 callersFunctionisRateLimitedError
(err error)
chasm/lib/scheduler/invoker_tasks.go:758
↓ 2 callersMethodisRealSchedulerInV1KeySpace
isRealSchedulerInV1KeySpace checks if a running V1 scheduler workflow (not a dummy sentinel) exists for the given schedule ID.
service/frontend/workflow_handler.go:3708
↓ 2 callersFunctionisRetryableError
(err error)
common/archiver/gcloud/util.go:214
↓ 2 callersFunctionisScheduleIDToWorkflowIDColumn
isScheduleIDToWorkflowIDColumn returns true if col refers to the ScheduleId search attribute that maps to WorkflowId (the built-in virtual SA), as opp
service/worker/scheduler/schedule_id_query_rewriter.go:155
↓ 2 callersMethodisSent
isSent checks if Update was sent to worker.
service/history/workflow/update/update.go:594
↓ 2 callersFunctionisStatusSkippableFromReactivation
(s enumspb.WorkerDeploymentVersionStatus)
common/worker_versioning/worker_versioning.go:450
↓ 2 callersMethodisTLSEnabled
()
common/rpc/encryption/local_store_cert_provider.go:528
↓ 2 callersFunctionisTestResultBoundary
(line string)
tools/testrunner/log.go:319
↓ 2 callersMethodisTooBig
(m proto.Message)
service/worker/scheduler/activities.go:360
↓ 2 callersFunctionisUnhealthyError
(err error)
common/persistence/health_signal_aggregator.go:142
↓ 2 callersFunctionisUpdateNeeded
(metadata *persistence.GetClusterMetadataResponse)
service/frontend/version_checker.go:122
↓ 2 callersMethodisUserError
(err error)
service/history/queues/executable.go:398
↓ 2 callersMethodisValidExpirationTime
isValidExpirationTime returns true when the workflow is still running and expirationTime has been reached. Callers pass fields from an execution (e.g.
service/history/timer_queue_task_executor_base.go:167
↓ 2 callersMethodisValidWorkflowRunTimeoutTask
( mutableState historyi.MutableState, task *tasks.WorkflowRunTimeoutTask, )
service/history/timer_queue_task_executor_base.go:180
↓ 2 callersMethodisVersionMissingTaskQueues
(ctx workflow.Context, prevCurrentVersion string, newCurrentVersion string)
service/worker/workerdeployment/workflow.go:1709
↓ 2 callersMethodisWorkflowReset
()
service/history/ndc/replication_task.go:45
↓ 2 callersFunctioniterateRanges
(ranges []*schedulepb.Range, f func(i int))
service/worker/scheduler/calendar.go:370
↓ 2 callersFunctionjoinHandlers
(handlers ...func(task *workflowservice.PollWorkflowTaskQueueResponse) ([]*T, error))
tests/xdc/history_replication_signals_and_updates_test.go:1014
↓ 2 callersMethodknownCountLocked
()
service/matching/fair_task_reader.go:658
↓ 2 callersMethodlist
(token []byte, count int)
service/worker/scanner/taskqueue/mocks_test.go:52
↓ 2 callersMethodlistAllClusterMetadataFromDB
( ctx context.Context, )
common/cluster/metadata.go:538
↓ 2 callersMethodlistClosedWorkflowExecutions
(env *testcore.TestEnv, start, end time.Time, id string, expectedNumber int)
tests/cron_test.go:610
↓ 2 callersFunctionlistExecutionsForReplication
(ctx workflow.Context, executionsCh workflow.Channel, params *ForceReplicationParams)
service/worker/migration/force_replication_workflow.go:408
↓ 2 callersMethodlistExecutionsInternal
( ctx context.Context, request *listExecutionsRequestInternal, )
common/persistence/visibility/store/sql/visibility_store.go:362
↓ 2 callersMethodlistExecutionsInternalLegacy
( ctx context.Context, request *listExecutionsRequestInternal, )
common/persistence/visibility/store/sql/visibility_store.go:469
↓ 2 callersFunctionlistFiles
(dirPath string)
common/archiver/filestore/util.go:88
↓ 2 callersMethodlistTaskQueuePartitions
(request *matchingservice.ListTaskQueuePartitionsRequest, taskQueueType enumspb.TaskQueueType)
service/matching/matching_engine.go:1661
↓ 2 callersMethodlistWorkerDeployments
(env *VersioningTestEnv, request *workflowservice.ListWorkerDeploymentsRequest)
tests/worker_deployment_test.go:3573
↓ 2 callersMethodlistenerKey
()
service/matching/matching_engine.go:374
↓ 2 callersFunctionloadAndUnmarshalContent
(content []byte, filename string, config any)
common/config/loader.go:254
↓ 2 callersMethodloadAndValidateMutableStateNoReload
loadAndValidateMutableState loads mutable state and validates it. Propagages errors returned from validate. Does **not** reload mutable state if valid
service/history/statemachine_environment.go:186
↓ 2 callersMethodloadAndVersionCheckMutableState
loadAndVersionCheckMutableState loads the mutable state for the given task and performs a version check to verify that the mutable state's last write
service/history/archival_queue_task_executor.go:296
↓ 2 callersMethodloadCerts
()
common/rpc/encryption/local_store_cert_provider.go:203
↓ 2 callersMethodloadEndpoints
loadEndpoints initializes the in-memory view of endpoints data. It first tries to load from matching service and falls back to querying persistence di
common/nexus/endpoint_registry.go:272
↓ 2 callersFunctionloadMutableStateForTask
( ctx context.Context, shardContext historyi.ShardContext, wfContext historyi.WorkflowContext, task tasks.
service/history/ndc_task_util.go:129
↓ 2 callersMethodloadServerCACerts
(isWorker bool)
common/rpc/encryption/local_store_cert_provider.go:319
↓ 2 callersMethodloadSubqueuesLocked
(subqueues []persistencespb.SubqueueInfo)
service/matching/pri_backlog_manager.go:181
↓ 2 callersMethodloadSubqueuesLocked
(subqueues []persistencespb.SubqueueInfo)
service/matching/fair_backlog_manager.go:168
↓ 2 callersFunctionlockAndCheckExecution
( ctx context.Context, tx sqlplugin.Tx, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_util.go:629
↓ 2 callersMethodlockCurrentExecution
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, businessID string, a
service/history/chasm_engine.go:791
↓ 2 callersFunctionlockMetadata
( ctx context.Context, tx sqlplugin.Tx, )
common/persistence/sql/metadata.go:282
↓ 2 callersMethodlockWorkflowExecution
( ctx context.Context, workflowCtx historyi.WorkflowContext, cacheKey Key, lockPriority locks.Priority, )
service/history/workflow/cache/cache.go:318
↓ 2 callersFunctionlogBeta
logBeta returns log(Beta(a, b)) = lgamma(a) + lgamma(b) - lgamma(a+b).
tools/flakereport/bisect.go:21
↓ 2 callersMethodlogCerts
(certs CertExpirationMap, expired bool, errorTime time.Time)
common/rpc/encryption/local_store_tls_provider.go:447
↓ 2 callersFunctionlogError
( logger log.Logger, msg string, executionInfo *persistencespb.WorkflowExecutionInfo, executionState *pers
service/history/workflow/mutable_state_impl.go:9954
↓ 2 callersMethodlogInfo
TODO: Deprecate following logging methods and use ms.logger directly.
service/history/workflow/mutable_state_impl.go:9076
↓ 2 callersFunctionlogMetadataPropagationStatus
( ctx context.Context, method string, trailerMetadata map[string]string, propagatedMetadata map[string]str
common/rpc/interceptor/trailer_to_context_metadata_interceptor.go:107
↓ 2 callersMethodlogReportedProblemsChange
logReportedProblemsChange logs changes to the TemporalReportedProblems search attribute
service/history/workflow/mutable_state_impl.go:7074
↓ 2 callersMethodlogTargets
logTargets returns the tests that should receive Log/Logf, or nil when no test target applies and the caller should write to stderr. The caller must h
tests/testcore/shared_cluster_t.go:52
↓ 2 callersMethodlogs
()
common/testing/await/require_ctx_test.go:560
↓ 2 callersMethodlookupEndpoint
lookupEndpint gets an endpoint from the registry, preferring to look up by ID and falling back to name lookup. The fallback is a temporary workaround
components/nexusoperations/executors.go:937
↓ 2 callersMethodlookupSideEffectTask
( ctx context.Context, callerName string, chasmTask *tasks.ChasmTask, )
chasm/tree.go:3473
← previousnext →8,401–8,500 of 43,335, ranked by callers