MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 1 callersMethodgetAllEndpointsPersistence
getAllEndpointsPersistence paginates over all endpoints returned by persistence. Should only be used as a fall-back if matching service is unavailable
common/nexus/endpoint_registry.go:396
↓ 1 callersMethodgetAllPartitionRpcNames
( ns namespace.Name, taskQueue *taskqueuepb.TaskQueue, taskQueueType enumspb.TaskQueueType, )
service/matching/matching_engine.go:2820
↓ 1 callersFunctiongetAllowedPragmas
()
temporaltest/internal/lite_server.go:347
↓ 1 callersMethodgetAndPinAckLevel
()
service/matching/fair_task_reader.go:626
↓ 1 callersMethodgetAndPinAckLevels
()
service/matching/fair_backlog_manager.go:244
↓ 1 callersMethodgetApproximateBacklogCountAndMaxReadLevel
(subqueue subqueueIndex)
service/matching/db.go:467
↓ 1 callersMethodgetArchiveTaskRequest
getArchiveTaskRequest returns an archival request for the given archive execution task.
service/history/archival_queue_task_executor.go:112
↓ 1 callersMethodgetBaseBranchToken
( ctx context.Context, baseLastEventID int64, baseLastEventVersion int64, incomingFirstEventID int64, inc
service/history/ndc/resetter.go:141
↓ 1 callersFunctiongetBoundariesForPartition
nolint:revive,confusing-results // moving old code
common/persistence/sql/task_util.go:32
↓ 1 callersMethodgetBranchToAppend
( ctx context.Context, wfCtx historyi.WorkflowContext, localMutableState historyi.MutableState, sourceVers
service/history/ndc/workflow_state_replicator.go:1399
↓ 1 callersFunctiongetBranchToken
( ctx context.Context, shardContext historyi.ShardContext, workflowKey definition.WorkflowKey, workflowCac
service/history/replication/raw_task_converter.go:539
↓ 1 callersMethodgetBranchToken
( env *archivalTestEnv, nsName namespace.Name, execution *commonpb.WorkflowExecution, )
tests/archival_test.go:543
↓ 1 callersFunctiongetBufferedEvents
( ctx context.Context, db sqlplugin.DB, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_non_map.go:129
↓ 1 callersMethodgetBuildIdReachability
( ctx context.Context, request buildIdReachabilityRequest, )
service/frontend/task_reachability.go:95
↓ 1 callersMethodgetByIndexes
(indexes []int)
service/matching/counter/cmsketch.go:190
↓ 1 callersFunctiongetCanceledContext
()
common/archiver/gcloud/history_archiver_test.go:70
↓ 1 callersFunctiongetCanceledContext
()
common/archiver/filestore/history_archiver_test.go:625
↓ 1 callersFunctiongetCanceledContext
()
common/archiver/s3store/history_archiver_test.go:772
↓ 1 callersFunctiongetCategoriesList
(taskCategoryRegistry tasks.TaskCategoryRegistry)
tools/tdbg/dlq_v2_service.go:372
↓ 1 callersFunctiongetCategoryByID
( c *cli.Context, taskCategoryRegistry tasks.TaskCategoryRegistry, categoryIDString string, )
tools/tdbg/dlq_v2_service.go:386
↓ 1 callersFunctiongetChainUnaryHandler
( interceptors []grpc.UnaryServerInterceptor, curr int, info *grpc.UnaryServerInfo, finalHandler grpc.Unar
service/frontend/http_api_server.go:494
↓ 1 callersFunctiongetChasmNodeMap
( ctx context.Context, db sqlplugin.DB, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:516
↓ 1 callersFunctiongetChildExecutionInfoMap
( ctx context.Context, db sqlplugin.DB, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:239
↓ 1 callersFunctiongetCommands
( clientFactory ClientFactory, dlqServiceProvider *DLQServiceProvider, taskCategoryRegistry tasks.TaskCateg
tools/tdbg/tdbg_commands.go:17
↓ 1 callersMethodgetCompletedBatchOperationStats
(memo map[string]*commonpb.Payload)
service/frontend/workflow_handler.go:5983
↓ 1 callersFunctiongetConfigFiles
getConfigFiles returns the list of config files to process in the hierarchy order
common/config/loader.go:283
↓ 1 callersMethodgetCreateTaskBatchCount
getCreateTaskBatchCount returns how many times CreateTask was called
service/matching/matching_engine_test.go:5514
↓ 1 callersFunctiongetCurrentBranchToken
( versionHistories *historyspb.VersionHistories, )
common/persistence/execution_manager.go:1249
↓ 1 callersMethodgetCurrentTime
TODO: deprecate this function and always use t.Now() Only test code sets t.clusterName to be non-current cluster name and advance the time by setting
service/history/transfer_queue_standby_task_executor.go:666
↓ 1 callersMethodgetCurrentVersionSummary
()
service/worker/workerdeployment/workflow.go:1787
↓ 1 callersMethodgetCurrentWorkflowLease
( ctx context.Context, consistencyPredicate MutableStateConsistencyPredicate, namespaceID string, workflow
service/history/api/consistency_checker.go:228
↓ 1 callersMethodgetDLQList
()
common/persistence/dlq_metrics_emitter.go:124
↓ 1 callersFunctiongetDLQV2Service
( c *cli.Context, clientFactory ClientFactory, taskCategoryRegistry tasks.TaskCategoryRegistry, writer io.
tools/tdbg/dlq_service.go:76
↓ 1 callersMethodgetDatetimeFormat
()
common/persistence/visibility/store/sql/query_converter_legacy_mysql.go:83
↓ 1 callersMethodgetDatetimeFormat
()
common/persistence/visibility/store/sql/query_converter_legacy_sqlite.go:48
↓ 1 callersMethodgetDatetimeFormat
()
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:64
↓ 1 callersFunctiongetDbFields
()
common/persistence/sql/sqlplugin/visibility.go:221
↓ 1 callersMethodgetDedicated
(t *testing.T, dynamicConfig map[dynamicconfig.Key]any, clusterOpts []TestClusterOption)
tests/testcore/test_cluster_pool.go:244
↓ 1 callersFunctiongetDefaultTestParams
(t *testing.T)
service/history/api/addtasks/api_test.go:236
↓ 1 callersMethodgetDeleted
()
common/namespace/nsregistry/registry_watch_test.go:73
↓ 1 callersMethodgetDeploymentWorkflowFunc
()
service/worker/workerdeployment/workflow_test.go:628
↓ 1 callersMethodgetDeserializedEvents
()
service/history/replication/executable_backfill_history_events_task.go:233
↓ 1 callersMethodgetElapsedTime
()
common/backoff/retrypolicy.go:235
↓ 1 callersMethodgetEndpointNameIssues
(name string)
service/frontend/nexus_endpoint_client.go:313
↓ 1 callersMethodgetEntryVertex
()
common/testing/event_generator.go:229
↓ 1 callersFunctiongetErrorType
(err error)
tests/testcore/taskpoller.go:546
↓ 1 callersFunctiongetEventsBlob
( ctx context.Context, shardID int32, branchToken []byte, firstEventID int64, nextEventID int64, executi
service/history/replication/raw_task_converter.go:575
↓ 1 callersFunctiongetFieldNameFromStruct
(structPtr any, fieldPtr any)
common/util.go:752
↓ 1 callersMethodgetFirstHistoryEventsBatch
getFirstHistoryEventsBatch retrieves the first batch of history events It first checks versionedTransition's EventBatch, and if the first event is eve
service/history/ndc/workflow_state_replicator.go:580
↓ 1 callersMethodgetFresherVersionHistoryItems
(versionHistoryItemsA []*historyspb.VersionHistoryItem, versionHistoryItemsB []*historyspb.VersionHistoryItem)
service/history/replication/executable_history_task.go:338
↓ 1 callersFunctiongetFrontendInterceptors
()
temporal/server_test.go:207
↓ 1 callersMethodgetFuture
(ctx context.Context, ns *namespace.Namespace, taskQueue string)
service/frontend/task_reachability.go:41
↓ 1 callersMethodgetGaugeAdapter
(gauge string)
common/metrics/otel_metrics_handler.go:100
↓ 1 callersFunctiongetGlobalFileCore
()
common/testing/testlogger/testlogger.go:237
↓ 1 callersMethodgetGroupByFieldTypes
getGroupByFieldTypes resolves the search attribute types for the given field names. It handles alias resolution and merges chasm types if a chasmMappe
common/persistence/visibility/store/sql/visibility_store.go:652
↓ 1 callersFunctiongetGrpcServerData
(grpcServerT reflect.Type)
cmd/tools/genrpcserverinterceptors/main.go:91
↓ 1 callersFunctiongetHighestVersion
(dirPath string, request *archiver.GetHistoryRequest)
common/archiver/filestore/history_archiver.go:284
↓ 1 callersMethodgetHighestVersion
(ctx context.Context, URI archiver.URI, request *archiver.GetHistoryRequest)
common/archiver/gcloud/history_archiver.go:316
↓ 1 callersMethodgetHighestVersion
(ctx context.Context, URI archiver.URI, request *archiver.GetHistoryRequest)
common/archiver/s3store/history_archiver.go:351
↓ 1 callersMethodgetHistoryEventFromStore
( ctx context.Context, shardID int32, key EventKey, firstEventID int64, branchToken []byte, )
service/history/events/cache.go:168
↓ 1 callersMethodgetHistoryFromLocalPaginationFn
( ctx context.Context, branchToken []byte, lastEventID int64, )
service/history/ndc/workflow_state_replicator.go:1853
↓ 1 callersMethodgetHistoryImmediateTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/sql/execution_tasks.go:80
↓ 1 callersMethodgetHistoryImmedidateTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/cassandra/mutable_state_task_store.go:747
↓ 1 callersMethodgetHistoryRequest
( ref []byte, requestID string, )
components/callbacks/chasm_invocation.go:83
↓ 1 callersMethodgetHistoryRequest
( refBytes []byte, requestID string, )
chasm/lib/callback/invocable_internal.go:132
↓ 1 callersMethodgetHistoryScheduledTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/sql/execution_tasks.go:198
↓ 1 callersMethodgetHistoryScheduledTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/cassandra/mutable_state_task_store.go:793
↓ 1 callersMethodgetHistorySizeInfo
()
service/history/workflow/workflow_task_state_machine.go:1491
↓ 1 callersMethodgetHistoryTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/cassandra/mutable_state_task_store.go:733
↓ 1 callersMethodgetHostInfo
(partitionKey string)
service/matching/matching_engine.go:2812
↓ 1 callersMethodgetHostInfoProvider
()
common/membership/ringpop/factory.go:249
↓ 1 callersFunctiongetHostsConfig
()
common/membership/ringpop/factory_test.go:127
↓ 1 callersMethodgetID
()
service/history/workflow/query.go:27
↓ 1 callersMethodgetIDByKey
(m *sync.Map, k int)
common/persistence/persistence-tests/history_v2_persistence.go:660
↓ 1 callersMethodgetIdleExpiration
getIdleExpiration returns an idle close time and whether the schedule is idle. Generator-only: nextWakeup must reflect the spec's next pending wakeup
chasm/lib/scheduler/scheduler.go:518
↓ 1 callersFunctiongetImportName
(i string)
cmd/tools/getproto/main.go:60
↓ 1 callersMethodgetIncomingEphemeralDataVersion
()
service/matching/user_data_manager.go:824
↓ 1 callersFunctiongetJitterRand
()
common/backoff/retrypolicy.go:299
↓ 1 callersMethodgetJoinTime
(maxPropagationTime time.Duration)
common/membership/ringpop/factory.go:132
↓ 1 callersMethodgetLastEvent
( client workflowservice.WorkflowServiceClient, namespace string, execution *commonpb.WorkflowExecution, )
tests/xdc/failover_test.go:1720
↓ 1 callersMethodgetLastEventTime
getLastEventTime returns the time of the last "event" to happen to the schedule. An event here is the schedule getting created or updated, or an actio
chasm/lib/scheduler/scheduler.go:474
↓ 1 callersMethodgetLastUpdatedTime
()
service/history/shard/context_impl.go:1356
↓ 1 callersMethodgetLatestRunsForWorkflows
getLatestRunsForWorkflows gets the latest run IDs for the given workflow IDs
tests/workflow_reset_test.go:594
↓ 1 callersMethodgetLatestVersionSummary
()
service/worker/workerdeployment/workflow.go:1778
↓ 1 callersFunctiongetListenIP
(cfg *config.RPC, logger log.Logger)
common/rpc/rpc.go:192
↓ 1 callersMethodgetListenIP
()
common/membership/ringpop/factory.go:213
↓ 1 callersMethodgetLocallyDesiredWorkers
(args refreshArgs)
service/worker/pernamespaceworker.go:281
↓ 1 callersFunctiongetLoggerOptions
(logLevel string, logger log.Logger)
common/persistence/visibility/store/elasticsearch/client/client_v7.go:352
↓ 1 callersFunctiongetMaxDatetimeValue
()
common/persistence/visibility/store/sql/query_converter_util_legacy.go:107
↓ 1 callersMethodgetMaxFairReadLevelLocked
(subqueue subqueueIndex)
service/matching/db.go:137
↓ 1 callersMethodgetMessageCountAndLastID
( ctx context.Context, row *sqlplugin.QueueV2MetadataRow, )
common/persistence/sql/queue_v2.go:439
↓ 1 callersMethodgetMessageCountAndLastID
( ctx context.Context, queueType persistence.QueueV2Type, queueName string, partition *persistencespb.Queu
common/persistence/cassandra/queue_v2_store.go:436
↓ 1 callersFunctiongetMethodNames
(tp reflect.Type)
common/api/metadata_test.go:92
↓ 1 callersMethodgetMetric
(name string)
common/metrics/registry.go:72
↓ 1 callersMethodgetMetricsHandler
()
common/dynamicconfig/file_based_client.go:109
↓ 1 callersMethodgetMetricsHandler
getMetricsHandler returns a metrics handler with a namespace tag
common/authorization/interceptor.go:334
↓ 1 callersFunctiongetMinMySQLDateTime
()
common/persistence/sql/sqlplugin/mysql/typeconv.go:35
↓ 1 callersFunctiongetMinPostgreSQLDateTime
()
common/persistence/sql/sqlplugin/postgresql/typeconv.go:37
↓ 1 callersFunctiongetMinSQLiteDateTime
()
common/persistence/sql/sqlplugin/sqlite/typeconv.go:35
↓ 1 callersFunctiongetModifiedTestFiles
getModifiedTestFiles runs 'git diff' to find modified '_test.go' files between two references
cmd/tools/test/find_altered_tests.go:98
← previousnext →11,801–11,900 of 43,335, ranked by callers