MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersMethodcomponentNodePath
componentNodePath implements the CHASM Context interface
chasm/tree.go:1569
↓ 1 callersMethodcomponentRequestLinks
componentRequestLinks returns the links stored on the given component's metadata for the specific requestID, preferring a pending write staged in the
chasm/tree.go:1457
↓ 1 callersMethodcomponentUserMetadata
componentUserMetadata returns the user metadata stored on the given component, preferring a pending write staged in the current transaction.
chasm/tree.go:1476
↓ 1 callersFunctioncomputeDeclinedTargetVersionUpgrade
computeDeclinedTargetVersionUpgrade determines what declined-upgrade value to pass to the next run when it inherits PINNED behavior: - If the current
service/history/workflow/mutable_state_impl.go:2840
↓ 1 callersFunctionconcat
(a, b string)
common/config/loader.go:312
↓ 1 callersFunctionconfiguredFaultInjector
(cfg *config.FaultInjectionDataStoreConfig)
common/persistence/faultinjection/store_fault_generator.go:52
↓ 1 callersMethodconflictResolveAsCurrent
( ctx context.Context, targetWorkflow Workflow, newWorkflow Workflow, )
service/history/ndc/transaction_manager_existing_workflow.go:355
↓ 1 callersMethodconflictResolveAsZombie
( ctx context.Context, currentWorkflow Workflow, targetWorkflow Workflow, newWorkflow Workflow, archetype
service/history/ndc/transaction_manager_existing_workflow.go:387
↓ 1 callersMethodconflictResolveEventReapply
( ctx context.Context, shardContext historyi.ShardContext, conflictResolveMode persistence.ConflictResolveW
service/history/workflow/context.go:845
↓ 1 callersFunctionconflictResolveWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, resetWorkflowFailoverVersion int64, newWorkflow
service/history/workflow/transaction_impl.go:411
↓ 1 callersMethodconflictResolveWorkflowExecutionTx
( ctx context.Context, tx sqlplugin.Tx, request *p.InternalConflictResolveWorkflowExecutionRequest, )
common/persistence/sql/execution.go:476
↓ 1 callersMethodconstructHistoryBatches
(batchInfo []int, page page, firstEventID int64)
common/archiver/history_iterator_test.go:639
↓ 1 callersFunctionconstructHistoryKeyPrefixWithVersion
(path, namespaceID, workflowID, runID string, version int64)
common/archiver/s3store/util.go:120
↓ 1 callersMethodcontainsHistoryEvents
( expectedHistoryEvents []*historypb.HistoryEvent, expectedEventsAttributes []map[string]any, actualHistory
common/testing/historyrequire/history_require.go:281
↓ 1 callersMethodcontext
()
common/testing/testcontext/context.go:170
↓ 1 callersMethodcontextValues
contextValues builds the CHASM context values exposed to scheduler components.
chasm/lib/scheduler/config.go:50
↓ 1 callersFunctioncontextWithCancelOnChannelClose
contextWithCancelOnChannelClose returns a child Context and CancelFunc just like context.WithCancel, but additionally propagates cancellation from ano
service/matching/matcher.go:645
↓ 1 callersFunctionconvertAlerts
(alerts []versioninfo.Alert)
service/frontend/version_checker.go:190
↓ 1 callersMethodconvertAndExpr
(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:99
↓ 1 callersMethodconvertAndExpr
(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:92
↓ 1 callersMethodconvertAndExpr
(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:103
↓ 1 callersFunctionconvertBackfillersCHASMToLegacy
( backfillers map[string]*schedulerpb.BackfillerState, migrationTime time.Time, )
chasm/lib/scheduler/migration/migration.go:440
↓ 1 callersFunctionconvertBackfillsLegacyToCHASM
( legacyBackfills []*schedulepb.BackfillRequest)
chasm/lib/scheduler/migration/migration.go:338
↓ 1 callersFunctionconvertBool
(val any)
common/dynamicconfig/collection.go:646
↓ 1 callersFunctionconvertBufferedStartsLegacyToCHASM
convertBufferedStartsLegacyToCHASM transforms V1 buffered starts to V2 format. V2 requires request_id, workflow_id, attempt, and backoff_time fields.
chasm/lib/scheduler/migration/migration.go:188
↓ 1 callersFunctionconvertCIBreakersToReports
convertCIBreakersToReports converts CI breaker failures to TestReport slice. totalWorkflowRuns is the total number of CI runs analyzed (denominator fo
tools/flakereport/parser.go:375
↓ 1 callersMethodconvertCloseTime
(timestamp time.Time, op string, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:183
↓ 1 callersFunctionconvertClusterReplicationConfigToProto
( input []string, )
service/frontend/admin_handler.go:2500
↓ 1 callersMethodconvertComparisonExpr
(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:106
↓ 1 callersMethodconvertComparisonExpr
(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:99
↓ 1 callersMethodconvertComparisonExpr
(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:110
↓ 1 callersFunctionconvertComparisonExprValue
convertComparisonExprValue returns a string, int64, float64, bool or a slice with each value of one of those types.
common/persistence/visibility/store/query/converter_legacy.go:515
↓ 1 callersFunctionconvertCrashesToReports
convertCrashesToReports converts crash failures to TestReport slice. Crashes are job-level events. The rate is unique-jobs-with-crash / total jobs of
tools/flakereport/parser.go:346
↓ 1 callersFunctionconvertFailoverHistoryToReplicationProto
( failoverHistoy []*persistencespb.FailoverStatus, )
service/frontend/admin_handler.go:2510
↓ 1 callersFunctionconvertFailoverHistoryToReplicationProto
( failoverHistoy []*persistencespb.FailoverStatus, )
common/namespace/nsreplication/transmission_task_handler.go:134
↓ 1 callersFunctionconvertGetHistoryError
( workflowKey definition.WorkflowKey, logger log.Logger, err error, )
service/history/replication/raw_task_converter.go:611
↓ 1 callersFunctionconvertHistoryNode
( message map[string]any, )
common/persistence/cassandra/history_store.go:403
↓ 1 callersMethodconvertInExpr
( leftExpr sqlparser.Expr, values sqlparser.ValTuple, )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:212
↓ 1 callersMethodconvertInExpr
( leftExpr sqlparser.Expr, values sqlparser.ValTuple, )
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:122
↓ 1 callersMethodconvertInternalGetClusterMetadataResponse
( resp *InternalGetClusterMetadataResponse, )
common/persistence/cluster_metadata_store.go:189
↓ 1 callersMethodconvertInternalListResponse
( internalResponse *store.InternalListExecutionsResponse, namespaceName namespace.Name, )
common/persistence/visibility/visibility_manager_impl.go:423
↓ 1 callersFunctionconvertKeyTypeToStringMap
(m map[any]any)
common/dynamicconfig/yaml_loader.go:139
↓ 1 callersFunctionconvertKeyTypeToStringSlice
(s []any)
common/dynamicconfig/yaml_loader.go:155
↓ 1 callersMethodconvertKeywordListComparisonExpr
(expr *sqlparser.ComparisonExpr)
common/persistence/visibility/store/sql/query_converter_legacy.go:24
↓ 1 callersFunctionconvertLastCompletionCHASMToLegacy
( result *schedulerpb.LastCompletionResult, )
chasm/lib/scheduler/migration/migration.go:479
↓ 1 callersFunctionconvertLastCompletionLegacyToCHASM
convertLastCompletionLegacyToCHASM transforms V1 completion result to V2 format. V1 uses Payloads (plural), V2 uses single Payload.
chasm/lib/scheduler/migration/migration.go:363
↓ 1 callersFunctionconvertLinkWorkflowEventEventReferenceToURLQuery
(eventRef *commonpb.Link_WorkflowEvent_EventReference)
common/nexus/link_converter.go:256
↓ 1 callersFunctionconvertLinkWorkflowEventRequestIdReferenceToURLQuery
(requestIDRef *commonpb.Link_WorkflowEvent_RequestIdReference)
common/nexus/link_converter.go:283
↓ 1 callersFunctionconvertMappingBody
(esMapping map[string]any, indexName string)
common/persistence/visibility/store/elasticsearch/client/client_v7.go:406
↓ 1 callersMethodconvertNotFoundError
(err error, ref chasm.ComponentRef)
service/history/chasm_engine.go:1316
↓ 1 callersMethodconvertOne
( sourceClusterName string, sourceShardKey ClusterShardKey, replicationTask *replicationspb.ReplicationTask
service/history/replication/executable_task_converter.go:54
↓ 1 callersMethodconvertParenExpr
(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:95
↓ 1 callersMethodconvertParenExpr
(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:88
↓ 1 callersMethodconvertParenExpr
(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:99
↓ 1 callersFunctionconvertPrometheusConfigToTally
( clientConfig *ClientConfig, config *PrometheusConfig, )
common/metrics/config.go:323
↓ 1 callersFunctionconvertQueueMetadata
( message map[string]any, serializer serialization.Serializer, )
common/persistence/cassandra/queue_store.go:387
↓ 1 callersFunctionconvertRecentActionsToBufferedStarts
convertRecentActionsToBufferedStarts converts V1's RecentActions list to V2's BufferedStarts format. In V2, completed actions are represented as Buffe
chasm/lib/scheduler/migration/migration.go:283
↓ 1 callersFunctionconvertSanitizeOptionsToTally
(config *PrometheusConfig)
common/metrics/config.go:315
↓ 1 callersMethodconvertSelect
(sel *sqlparser.Select)
common/persistence/visibility/store/query/converter_legacy.go:213
↓ 1 callersMethodconvertSelectStmt
(sel *sqlparser.Select)
common/persistence/visibility/store/sql/query_converter_legacy.go:198
↓ 1 callersFunctionconvertSlogToZapLevel
convertSlogToZapLevel maps slog Levels to zap Levels. Note that there is some room between slog levels while zap levels are continuous, so we can't 1:
common/log/slog.go:131
↓ 1 callersMethodconvertSpeculativeWorkflowTaskToNormal
()
service/history/workflow/workflow_task_state_machine.go:1517
↓ 1 callersFunctionconvertStatusStr
(statusStr string)
common/archiver/filestore/query_parser.go:206
↓ 1 callersFunctionconvertString
(val any)
common/dynamicconfig/collection.go:639
↓ 1 callersMethodconvertTag
(tag Tag)
common/metrics/otel_metrics_handler.go:232
↓ 1 callersMethodconvertTaskEquivalents
( ctx context.Context, taskInfo *tasks.SyncVersionedTransitionTask, targetClusterID int32, )
service/history/replication/raw_task_converter.go:916
↓ 1 callersMethodconvertTextComparisonExpr
(expr *sqlparser.ComparisonExpr)
common/persistence/visibility/store/sql/query_converter_legacy.go:26
↓ 1 callersMethodconvertToChasmExecutionInfo
convertInternalExecutionToChasmInfo converts a store.InternalExecutionInfo to ChasmExecutionInfo.
common/persistence/visibility/visibility_manager_impl.go:192
↓ 1 callersMethodconvertToCountChasmExecutionsResponse
( internal *store.InternalCountExecutionsResponse, )
common/persistence/visibility/visibility_manager_impl.go:347
↓ 1 callersMethodconvertToCountWorkflowExecutionsResponse
( internal *store.InternalCountExecutionsResponse, )
common/persistence/visibility/visibility_manager_impl.go:327
↓ 1 callersMethodconvertToHistoryMultiOperationItem
( ctx context.Context, namespaceID namespace.ID, namespaceName namespace.Name, op *workflowservice.Execute
service/frontend/workflow_handler.go:839
↓ 1 callersMethodconvertToHistoryMultiOperationRequest
( ctx context.Context, namespaceID namespace.ID, request *workflowservice.ExecuteMultiOperationRequest, )
service/frontend/workflow_handler.go:797
↓ 1 callersMethodconvertToJsonOverlapsExpr
( expr *sqlparser.ComparisonExpr, )
common/persistence/visibility/store/sql/query_converter_legacy_mysql.go:142
↓ 1 callersMethodconvertToMultiOperationResponse
( historyResp *historyservice.ExecuteMultiOperationResponse, namespaceName namespace.Name, )
service/frontend/workflow_handler.go:908
↓ 1 callersFunctionconvertURLQueryToLinkWorkflowEventEventReference
(queryValues url.Values)
common/nexus/link_converter.go:266
↓ 1 callersFunctionconvertURLQueryToLinkWorkflowEventRequestIdReference
(queryValues url.Values)
common/nexus/link_converter.go:291
↓ 1 callersFunctionconvertYamlConstraints
nolint:revive // cognitive-complexity, it's just a big switch
common/dynamicconfig/yaml_loader.go:168
↓ 1 callersMethodcopyChasmLibProtos
()
cmd/tools/protogen/main.go:204
↓ 1 callersFunctioncopyChildWorkflowInfos
( input map[int64]*persistencespb.ChildExecutionInfo, )
service/history/transfer_queue_active_task_executor.go:2010
↓ 1 callersFunctioncopyConnections
( originalMap map[string][]Edge, )
common/testing/history_event_util.go:946
↓ 1 callersFunctioncopyEdges
(edges []Edge)
common/testing/history_event_util.go:974
↓ 1 callersFunctioncopyExitVertices
( originalMap map[string]bool, )
common/testing/history_event_util.go:957
↓ 1 callersFunctioncopyPersistenceConfig
copyPersistenceConfig makes a deep copy of persistence config. This is just a temp fix for the race condition of persistence config. The race conditio
tests/testcore/onebox.go:877
↓ 1 callersMethodcopySuite
nolint:revive // ctx is last so callers can pass nil to mean "no override"; SA1012 forbids passing nil as the first ctx arg.
common/testing/parallelsuite/suite.go:26
↓ 1 callersFunctioncopyToRebuildMutableState
( rebuiltMutableState historyi.MutableState, currentMutableState *persistencespb.WorkflowMutableState, )
service/history/ndc/state_rebuilder.go:215
↓ 1 callersMethodcountAborted
(updateID string, reason AbortReason)
service/history/workflow/update/util.go:66
↓ 1 callersMethodcountAcceptanceMsg
()
service/history/workflow/update/util.go:36
↓ 1 callersMethodcountChasmExecutions
( ctx context.Context, request *visibilityservice.CountChasmExecutionsRequest, mapper *chasm.VisibilitySear
common/persistence/visibility/store/sql/visibility_store.go:249
↓ 1 callersMethodcountChasmExecutionsLegacy
( ctx context.Context, request *visibilityservice.CountChasmExecutionsRequest, mapper *chasm.VisibilitySear
common/persistence/visibility/store/sql/visibility_store.go:302
↓ 1 callersFunctioncountQualifyingBisectReports
countQualifyingBisectReports returns the number of non-skipped reports.
tools/flakereport/writer.go:106
↓ 1 callersMethodcountRateLimited
()
service/history/workflow/update/util.go:48
↓ 1 callersMethodcountRegistrySizeLimited
(updateCount, registrySize, payloadSize int)
service/history/workflow/update/util.go:52
↓ 1 callersMethodcountRejectionMsg
()
service/history/workflow/update/util.go:40
↓ 1 callersMethodcountRequestMsg
()
service/history/workflow/update/util.go:32
↓ 1 callersMethodcountResponseMsg
()
service/history/workflow/update/util.go:44
↓ 1 callersMethodcountSchedulesChasm
countSchedulesChasm counts schedules using CHASM APIs
service/frontend/workflow_handler.go:5237
↓ 1 callersMethodcountSchedulesWorkflow
countSchedulesWorkflow counts schedules using direct visibility query (V1 path)
service/frontend/workflow_handler.go:5266
↓ 1 callersMethodcountSent
()
service/history/workflow/update/util.go:75
↓ 1 callersMethodcountSentAgain
()
service/history/workflow/update/util.go:79
↓ 1 callersFunctioncountTestRuns
countTestRuns counts total runs (including successes) by normalized test name
tools/flakereport/parser.go:144
← previousnext →11,201–11,300 of 43,335, ranked by callers