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
componentNodePath
componentNodePath implements the CHASM Context interface
chasm/tree.go:1569
↓ 1 callers
Method
componentRequestLinks
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 callers
Method
componentUserMetadata
componentUserMetadata returns the user metadata stored on the given component, preferring a pending write staged in the current transaction.
chasm/tree.go:1476
↓ 1 callers
Function
computeDeclinedTargetVersionUpgrade
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 callers
Function
concat
(a, b string)
common/config/loader.go:312
↓ 1 callers
Function
configuredFaultInjector
(cfg *config.FaultInjectionDataStoreConfig)
common/persistence/faultinjection/store_fault_generator.go:52
↓ 1 callers
Method
conflictResolveAsCurrent
( ctx context.Context, targetWorkflow Workflow, newWorkflow Workflow, )
service/history/ndc/transaction_manager_existing_workflow.go:355
↓ 1 callers
Method
conflictResolveAsZombie
( ctx context.Context, currentWorkflow Workflow, targetWorkflow Workflow, newWorkflow Workflow, archetype
service/history/ndc/transaction_manager_existing_workflow.go:387
↓ 1 callers
Method
conflictResolveEventReapply
( ctx context.Context, shardContext historyi.ShardContext, conflictResolveMode persistence.ConflictResolveW
service/history/workflow/context.go:845
↓ 1 callers
Function
conflictResolveWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, resetWorkflowFailoverVersion int64, newWorkflow
service/history/workflow/transaction_impl.go:411
↓ 1 callers
Method
conflictResolveWorkflowExecutionTx
( ctx context.Context, tx sqlplugin.Tx, request *p.InternalConflictResolveWorkflowExecutionRequest, )
common/persistence/sql/execution.go:476
↓ 1 callers
Method
constructHistoryBatches
(batchInfo []int, page page, firstEventID int64)
common/archiver/history_iterator_test.go:639
↓ 1 callers
Function
constructHistoryKeyPrefixWithVersion
(path, namespaceID, workflowID, runID string, version int64)
common/archiver/s3store/util.go:120
↓ 1 callers
Method
containsHistoryEvents
( expectedHistoryEvents []*historypb.HistoryEvent, expectedEventsAttributes []map[string]any, actualHistory
common/testing/historyrequire/history_require.go:281
↓ 1 callers
Method
context
()
common/testing/testcontext/context.go:170
↓ 1 callers
Method
contextValues
contextValues builds the CHASM context values exposed to scheduler components.
chasm/lib/scheduler/config.go:50
↓ 1 callers
Function
contextWithCancelOnChannelClose
contextWithCancelOnChannelClose returns a child Context and CancelFunc just like context.WithCancel, but additionally propagates cancellation from ano
service/matching/matcher.go:645
↓ 1 callers
Function
convertAlerts
(alerts []versioninfo.Alert)
service/frontend/version_checker.go:190
↓ 1 callers
Method
convertAndExpr
(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:99
↓ 1 callers
Method
convertAndExpr
(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:92
↓ 1 callers
Method
convertAndExpr
(andExpr *sqlparser.AndExpr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:103
↓ 1 callers
Function
convertBackfillersCHASMToLegacy
( backfillers map[string]*schedulerpb.BackfillerState, migrationTime time.Time, )
chasm/lib/scheduler/migration/migration.go:440
↓ 1 callers
Function
convertBackfillsLegacyToCHASM
( legacyBackfills []*schedulepb.BackfillRequest)
chasm/lib/scheduler/migration/migration.go:338
↓ 1 callers
Function
convertBool
(val any)
common/dynamicconfig/collection.go:646
↓ 1 callers
Function
convertBufferedStartsLegacyToCHASM
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 callers
Function
convertCIBreakersToReports
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 callers
Method
convertCloseTime
(timestamp time.Time, op string, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:183
↓ 1 callers
Function
convertClusterReplicationConfigToProto
( input []string, )
service/frontend/admin_handler.go:2500
↓ 1 callers
Method
convertComparisonExpr
(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:106
↓ 1 callers
Method
convertComparisonExpr
(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:99
↓ 1 callers
Method
convertComparisonExpr
(compExpr *sqlparser.ComparisonExpr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:110
↓ 1 callers
Function
convertComparisonExprValue
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 callers
Function
convertCrashesToReports
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 callers
Function
convertFailoverHistoryToReplicationProto
( failoverHistoy []*persistencespb.FailoverStatus, )
service/frontend/admin_handler.go:2510
↓ 1 callers
Function
convertFailoverHistoryToReplicationProto
( failoverHistoy []*persistencespb.FailoverStatus, )
common/namespace/nsreplication/transmission_task_handler.go:134
↓ 1 callers
Function
convertGetHistoryError
( workflowKey definition.WorkflowKey, logger log.Logger, err error, )
service/history/replication/raw_task_converter.go:611
↓ 1 callers
Function
convertHistoryNode
( message map[string]any, )
common/persistence/cassandra/history_store.go:403
↓ 1 callers
Method
convertInExpr
( leftExpr sqlparser.Expr, values sqlparser.ValTuple, )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:212
↓ 1 callers
Method
convertInExpr
( leftExpr sqlparser.Expr, values sqlparser.ValTuple, )
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:122
↓ 1 callers
Method
convertInternalGetClusterMetadataResponse
( resp *InternalGetClusterMetadataResponse, )
common/persistence/cluster_metadata_store.go:189
↓ 1 callers
Method
convertInternalListResponse
( internalResponse *store.InternalListExecutionsResponse, namespaceName namespace.Name, )
common/persistence/visibility/visibility_manager_impl.go:423
↓ 1 callers
Function
convertKeyTypeToStringMap
(m map[any]any)
common/dynamicconfig/yaml_loader.go:139
↓ 1 callers
Function
convertKeyTypeToStringSlice
(s []any)
common/dynamicconfig/yaml_loader.go:155
↓ 1 callers
Method
convertKeywordListComparisonExpr
(expr *sqlparser.ComparisonExpr)
common/persistence/visibility/store/sql/query_converter_legacy.go:24
↓ 1 callers
Function
convertLastCompletionCHASMToLegacy
( result *schedulerpb.LastCompletionResult, )
chasm/lib/scheduler/migration/migration.go:479
↓ 1 callers
Function
convertLastCompletionLegacyToCHASM
convertLastCompletionLegacyToCHASM transforms V1 completion result to V2 format. V1 uses Payloads (plural), V2 uses single Payload.
chasm/lib/scheduler/migration/migration.go:363
↓ 1 callers
Function
convertLinkWorkflowEventEventReferenceToURLQuery
(eventRef *commonpb.Link_WorkflowEvent_EventReference)
common/nexus/link_converter.go:256
↓ 1 callers
Function
convertLinkWorkflowEventRequestIdReferenceToURLQuery
(requestIDRef *commonpb.Link_WorkflowEvent_RequestIdReference)
common/nexus/link_converter.go:283
↓ 1 callers
Function
convertMappingBody
(esMapping map[string]any, indexName string)
common/persistence/visibility/store/elasticsearch/client/client_v7.go:406
↓ 1 callers
Method
convertNotFoundError
(err error, ref chasm.ComponentRef)
service/history/chasm_engine.go:1316
↓ 1 callers
Method
convertOne
( sourceClusterName string, sourceShardKey ClusterShardKey, replicationTask *replicationspb.ReplicationTask
service/history/replication/executable_task_converter.go:54
↓ 1 callers
Method
convertParenExpr
(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:95
↓ 1 callers
Method
convertParenExpr
(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:88
↓ 1 callers
Method
convertParenExpr
(parenExpr *sqlparser.ParenExpr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:99
↓ 1 callers
Function
convertPrometheusConfigToTally
( clientConfig *ClientConfig, config *PrometheusConfig, )
common/metrics/config.go:323
↓ 1 callers
Function
convertQueueMetadata
( message map[string]any, serializer serialization.Serializer, )
common/persistence/cassandra/queue_store.go:387
↓ 1 callers
Function
convertRecentActionsToBufferedStarts
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 callers
Function
convertSanitizeOptionsToTally
(config *PrometheusConfig)
common/metrics/config.go:315
↓ 1 callers
Method
convertSelect
(sel *sqlparser.Select)
common/persistence/visibility/store/query/converter_legacy.go:213
↓ 1 callers
Method
convertSelectStmt
(sel *sqlparser.Select)
common/persistence/visibility/store/sql/query_converter_legacy.go:198
↓ 1 callers
Function
convertSlogToZapLevel
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 callers
Method
convertSpeculativeWorkflowTaskToNormal
()
service/history/workflow/workflow_task_state_machine.go:1517
↓ 1 callers
Function
convertStatusStr
(statusStr string)
common/archiver/filestore/query_parser.go:206
↓ 1 callers
Function
convertString
(val any)
common/dynamicconfig/collection.go:639
↓ 1 callers
Method
convertTag
(tag Tag)
common/metrics/otel_metrics_handler.go:232
↓ 1 callers
Method
convertTaskEquivalents
( ctx context.Context, taskInfo *tasks.SyncVersionedTransitionTask, targetClusterID int32, )
service/history/replication/raw_task_converter.go:916
↓ 1 callers
Method
convertTextComparisonExpr
(expr *sqlparser.ComparisonExpr)
common/persistence/visibility/store/sql/query_converter_legacy.go:26
↓ 1 callers
Method
convertToChasmExecutionInfo
convertInternalExecutionToChasmInfo converts a store.InternalExecutionInfo to ChasmExecutionInfo.
common/persistence/visibility/visibility_manager_impl.go:192
↓ 1 callers
Method
convertToCountChasmExecutionsResponse
( internal *store.InternalCountExecutionsResponse, )
common/persistence/visibility/visibility_manager_impl.go:347
↓ 1 callers
Method
convertToCountWorkflowExecutionsResponse
( internal *store.InternalCountExecutionsResponse, )
common/persistence/visibility/visibility_manager_impl.go:327
↓ 1 callers
Method
convertToHistoryMultiOperationItem
( ctx context.Context, namespaceID namespace.ID, namespaceName namespace.Name, op *workflowservice.Execute
service/frontend/workflow_handler.go:839
↓ 1 callers
Method
convertToHistoryMultiOperationRequest
( ctx context.Context, namespaceID namespace.ID, request *workflowservice.ExecuteMultiOperationRequest, )
service/frontend/workflow_handler.go:797
↓ 1 callers
Method
convertToJsonOverlapsExpr
( expr *sqlparser.ComparisonExpr, )
common/persistence/visibility/store/sql/query_converter_legacy_mysql.go:142
↓ 1 callers
Method
convertToMultiOperationResponse
( historyResp *historyservice.ExecuteMultiOperationResponse, namespaceName namespace.Name, )
service/frontend/workflow_handler.go:908
↓ 1 callers
Function
convertURLQueryToLinkWorkflowEventEventReference
(queryValues url.Values)
common/nexus/link_converter.go:266
↓ 1 callers
Function
convertURLQueryToLinkWorkflowEventRequestIdReference
(queryValues url.Values)
common/nexus/link_converter.go:291
↓ 1 callers
Function
convertYamlConstraints
nolint:revive // cognitive-complexity, it's just a big switch
common/dynamicconfig/yaml_loader.go:168
↓ 1 callers
Method
copyChasmLibProtos
()
cmd/tools/protogen/main.go:204
↓ 1 callers
Function
copyChildWorkflowInfos
( input map[int64]*persistencespb.ChildExecutionInfo, )
service/history/transfer_queue_active_task_executor.go:2010
↓ 1 callers
Function
copyConnections
( originalMap map[string][]Edge, )
common/testing/history_event_util.go:946
↓ 1 callers
Function
copyEdges
(edges []Edge)
common/testing/history_event_util.go:974
↓ 1 callers
Function
copyExitVertices
( originalMap map[string]bool, )
common/testing/history_event_util.go:957
↓ 1 callers
Function
copyPersistenceConfig
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 callers
Method
copySuite
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 callers
Function
copyToRebuildMutableState
( rebuiltMutableState historyi.MutableState, currentMutableState *persistencespb.WorkflowMutableState, )
service/history/ndc/state_rebuilder.go:215
↓ 1 callers
Method
countAborted
(updateID string, reason AbortReason)
service/history/workflow/update/util.go:66
↓ 1 callers
Method
countAcceptanceMsg
()
service/history/workflow/update/util.go:36
↓ 1 callers
Method
countChasmExecutions
( ctx context.Context, request *visibilityservice.CountChasmExecutionsRequest, mapper *chasm.VisibilitySear
common/persistence/visibility/store/sql/visibility_store.go:249
↓ 1 callers
Method
countChasmExecutionsLegacy
( ctx context.Context, request *visibilityservice.CountChasmExecutionsRequest, mapper *chasm.VisibilitySear
common/persistence/visibility/store/sql/visibility_store.go:302
↓ 1 callers
Function
countQualifyingBisectReports
countQualifyingBisectReports returns the number of non-skipped reports.
tools/flakereport/writer.go:106
↓ 1 callers
Method
countRateLimited
()
service/history/workflow/update/util.go:48
↓ 1 callers
Method
countRegistrySizeLimited
(updateCount, registrySize, payloadSize int)
service/history/workflow/update/util.go:52
↓ 1 callers
Method
countRejectionMsg
()
service/history/workflow/update/util.go:40
↓ 1 callers
Method
countRequestMsg
()
service/history/workflow/update/util.go:32
↓ 1 callers
Method
countResponseMsg
()
service/history/workflow/update/util.go:44
↓ 1 callers
Method
countSchedulesChasm
countSchedulesChasm counts schedules using CHASM APIs
service/frontend/workflow_handler.go:5237
↓ 1 callers
Method
countSchedulesWorkflow
countSchedulesWorkflow counts schedules using direct visibility query (V1 path)
service/frontend/workflow_handler.go:5266
↓ 1 callers
Method
countSent
()
service/history/workflow/update/util.go:75
↓ 1 callers
Method
countSentAgain
()
service/history/workflow/update/util.go:79
↓ 1 callers
Function
countTestRuns
countTestRuns counts total runs (including successes) by normalized test name
tools/flakereport/parser.go:144
← previous
next →
11,201–11,300 of 43,335, ranked by callers