MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 2 callersFunctionfile_temporal_server_api_common_v1_api_category_proto_rawDescGZIP
()
api/common/v1/api_category.pb.go:181
↓ 2 callersFunctionfile_temporal_server_api_enums_v1_cluster_proto_rawDescGZIP
()
api/enums/v1/cluster.pb.go:191
↓ 2 callersFunctionfile_temporal_server_api_enums_v1_dlq_proto_rawDescGZIP
()
api/enums/v1/dlq.pb.go:169
↓ 2 callersFunctionfile_temporal_server_api_historyservice_v1_request_response_proto_init
()
api/historyservice/v1/request_response.pb.go:11935
↓ 2 callersFunctionfile_temporal_server_api_matchingservice_v1_request_response_proto_init
()
api/matchingservice/v1/request_response.pb.go:6644
↓ 2 callersFunctionfile_temporal_server_api_persistence_v1_chasm_visibility_proto_rawDescGZIP
()
api/persistence/v1/chasm_visibility.pb.go:128
↓ 2 callersFunctionfile_temporal_server_api_persistence_v1_cluster_metadata_proto_rawDescGZIP
()
api/persistence/v1/cluster_metadata.pb.go:260
↓ 2 callersFunctionfile_temporal_server_api_persistence_v1_executions_proto_init
()
api/persistence/v1/executions.pb.go:5677
↓ 2 callersFunctionfile_temporal_server_api_persistence_v1_predicates_proto_init
()
api/persistence/v1/predicates.pb.go:831
↓ 2 callersFunctionfile_temporal_server_api_persistence_v1_queues_proto_init
()
api/persistence/v1/queues.pb.go:619
↓ 2 callersFunctionfile_temporal_server_api_testservice_v1_request_response_proto_init
()
api/testservice/v1/request_response.pb.go:149
↓ 2 callersFunctionfile_temporal_server_api_testservice_v1_request_response_proto_rawDescGZIP
()
api/testservice/v1/request_response.pb.go:128
↓ 2 callersFunctionfile_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_init
()
chasm/lib/activity/gen/activitypb/v1/request_response.pb.go:665
↓ 2 callersFunctionfile_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_rawDescGZIP
()
chasm/lib/callback/gen/callbackpb/v1/tasks.pb.go:130
↓ 2 callersFunctionfile_temporal_server_chasm_lib_nexusoperation_proto_v1_request_response_proto_init
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/request_response.pb.go:675
↓ 2 callersFunctionfile_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_init
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:846
↓ 2 callersFunctionfile_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init
()
chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go:1024
↓ 2 callersFunctionfile_temporal_server_chasm_lib_tests_proto_v1_request_response_proto_init
()
chasm/lib/tests/gen/testspb/v1/request_response.pb.go:160
↓ 2 callersFunctionfile_temporal_server_chasm_lib_tests_proto_v1_request_response_proto_rawDescGZIP
()
chasm/lib/tests/gen/testspb/v1/request_response.pb.go:139
↓ 2 callersMethodfillFields
fillFields fill fields parameter with fields read from tags. Optimized for performance.
common/log/zap_logger.go:113
↓ 2 callersMethodfillNextTimeCacheV2
(start time.Time)
service/worker/scheduler/workflow.go:591
↓ 2 callersFunctionfilterCompleted
filterCompleted removes workflow runs that are not completed
tools/ci-notify/github.go:96
↓ 2 callersMethodfilterWorkers
filterWorkers returns all WorkerHeartbeats in a namespace for which predicate(hb) returns true. System workers are excluded unless includeSystemWorker
service/matching/workers/registry_impl.go:325
↓ 2 callersMethodfinalGC
finalGC does a single synchronous gc. Used when unloading a draining queue that won't be reloaded.
service/matching/pri_task_reader.go:555
↓ 2 callersMethodfindMatch
findMatch returns the highest-priority task+poller pair that is not rate-limited. If no ready pair is found, returns (nil, nil, minDelay) where minDel
service/matching/matcher_data.go:411
↓ 2 callersFunctionfindMatchWithConstrainedDefaults
Returns matched value out of cvs, matched default out of defaultCVs, and also the priorities of each of the matches (lower matched first). For no matc
common/dynamicconfig/collection.go:314
↓ 2 callersMethodfindNamedGrpcConnCfg
(name string)
common/telemetry/config.go:349
↓ 2 callersFunctionfindNestedField
(t reflect.Type, name string, path string, maxDepth int)
cmd/tools/genrpcwrappers/main.go:170
↓ 2 callersMethodfindNewVersionStatusFromRoutingConfig
(rg *deploymentpb.RoutingConfig)
service/worker/workerdeployment/version_workflow.go:1157
↓ 2 callersMethodfindWFTEvent
(eventType enumspb.EventType, workflowEvents []*persistence.WorkflowEvents)
service/history/workflow/workflow_test/mutable_state_impl_test.go:284
↓ 2 callersMethodfinish
finish drains remaining tasks, calculates normalized stats, and prints stats.
tools/fairsim/sim.go:214
↓ 2 callersMethodfinishInternal
(res taskResponse, consumedToken bool)
service/matching/task.go:382
↓ 2 callersFunctionfinishParseJSONValue
finishParseJSONValue finishes JSON parsing after json.Decode. json.Decode returns: bool, for JSON booleans json.Number, for JSON numbers (because o
common/persistence/visibility/store/elasticsearch/visibility_store.go:1244
↓ 2 callersMethodfirstDispatchTime
()
chasm/lib/activity/activity.go:742
↓ 2 callersFunctionflag
(opt string)
tools/sql/handler.go:180
↓ 2 callersMethodforgetDeploymentVersionsFromDeploymentData
( env *testcore.TestEnv, tv *testvars.TestVars, deploymentName string, forgetUnversionedRamp bool, revisi
tests/versioning_3_test.go:4433
↓ 2 callersMethodforkAndGenerateBranchToken
( ctx context.Context, namespaceID namespace.ID, workflowID string, forkBranchToken []byte, forkNodeID in
service/history/ndc/workflow_resetter.go:604
↓ 2 callersFunctionformatPath
formatPath returns a human-readable representation of a path.
service/history/hsm/tree.go:78
↓ 2 callersFunctionformatReportLines
formatReportLines returns a plain-text bullet line per report.
tools/flakereport/report.go:24
↓ 2 callersMethodforwardPolls
( ctx context.Context, targetPriority, effectivePriority priorityKey, ft pollForwarderType, target *tqid.N
service/matching/pri_matcher.go:289
↓ 2 callersMethodfprint
(w io.Writer, verbose bool)
tools/fairsim/sim.go:446
↓ 2 callersFunctionfromAdminClientAPIResponse
(response *adminservice.GetNamespaceResponse)
service/history/replication/eager_namespace_refresher_test.go:250
↓ 2 callersFunctionfunctionName
(fn any)
common/testing/runtime/goroutine.go:120
↓ 2 callersFunctiongatherBuildIds
(data *persistencespb.VersioningData)
service/matching/version_sets.go:63
↓ 2 callersFunctiongenFileList
(protoImports []string)
cmd/tools/getproto/main.go:73
↓ 2 callersFunctiongenerateConfig
(t *testing.T, tmpDir string, ports portSet, activePorts portSet)
tests/mixedbrain/config_util.go:80
↓ 2 callersMethodgenerateConflictToken
()
chasm/lib/scheduler/scheduler.go:923
↓ 2 callersFunctiongenerateKey
(resourceType int32, id string)
common/definition/resource_dedup.go:68
↓ 2 callersFunctiongenerateRequestID
(scheduler *Scheduler, backfillID string, nominal, actual time.Time)
chasm/lib/scheduler/util.go:16
↓ 2 callersMethodgenerateRequestIdRefLink
(runID string)
service/history/api/startworkflow/api.go:826
↓ 2 callersFunctiongenerateShardIDs
NOTE generateShardIDs is different than common.MapShardID common.MapShardID guarantee to return the corresponding shard IDs for give shard ID this fun
service/history/replication/poller_manager.go:59
↓ 2 callersMethodgenerateStatusMap
(inboundKeys map[ClusterShardKeyPair]struct{})
service/history/replication/stream_receiver_monitor.go:371
↓ 2 callersFunctiongenerateSubStateMachineTask
( mutableState historyi.MutableState, stateMachineRegistry *hsm.Registry, node *hsm.Node, subStateMachineP
service/history/workflow/task_generator.go:930
↓ 2 callersFunctiongenerateSuiteBreakdownTable
generateSuiteBreakdownTable creates a markdown table of per-suite flake data
tools/flakereport/report.go:72
↓ 2 callersFunctiongenerateSuiteReports
generateSuiteReports creates per-suite flake breakdown from all failures and test runs. Suite flake rate = % of (CI run × DB config) pairs where the s
tools/flakereport/parser.go:427
↓ 2 callersMethodgenerateTaskID
()
service/history/shard/task_key_generator.go:167
↓ 2 callersFunctiongenericFrontendServiceProvider
( params ServiceProviderParamsCommon, serviceName primitives.ServiceName, )
temporal/fx.go:548
↓ 2 callersMethodgetActiveCluster
(ctx context.Context)
tests/xdc/history_replication_signals_and_updates_test.go:1008
↓ 2 callersFunctiongetActiveRedirectRuleBySrc
(src string, data *persistencespb.VersioningData)
service/matching/version_rule_test.go:168
↓ 2 callersFunctiongetActivityIDs
(updateRequest *workflowservice.UpdateActivityOptionsRequest, ms historyi.MutableState)
service/history/api/updateactivityoptions/api.go:345
↓ 2 callersFunctiongetActivityLogger
(ctx context.Context)
service/worker/parentclosepolicy/workflow.go:220
↓ 2 callersMethodgetAllEndpoints
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:412
↓ 2 callersMethodgetAllEndpointsMatching
getAllEndpointsMatching paginates over all endpoints returned by matching. It always does a simple get.
common/nexus/endpoint_registry.go:379
↓ 2 callersMethodgetBacklogCount
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/task_queue_test.go:167
↓ 2 callersFunctiongetBatchOperationState
(workflowState enumspb.WorkflowExecutionStatus)
service/frontend/workflow_handler.go:6752
↓ 2 callersMethodgetBranchByKey
(m *sync.Map, k int)
common/persistence/persistence-tests/history_v2_persistence.go:653
↓ 2 callersFunctiongetBuildIdTaskReachability
( ctx context.Context, rc *reachabilityCalculator, metricsHandler metrics.Handler, logger log.Logger, bui
service/matching/reachability.go:87
↓ 2 callersMethodgetBuildIds
(versions *taskqueuepb.TaskQueueVersionSelection)
service/matching/matching_engine.go:1629
↓ 2 callersMethodgetClientKeepAliveConfig
(serviceName primitives.ServiceName)
common/rpc/rpc.go:303
↓ 2 callersMethodgetClientTLSSettings
(isWorker bool)
common/rpc/encryption/local_store_cert_provider.go:306
↓ 2 callersMethodgetClosedVisibilityRequest
( ctx context.Context, base *manager.VisibilityRequestBase, mutableState historyi.MutableState, namespaceE
service/history/visibility_queue_task_executor.go:555
↓ 2 callersFunctiongetClusterArchivalState
(str string)
common/archiver/archival_metadata.go:188
↓ 2 callersFunctiongetClusterMetadata
(ctx workflow.Context, params ForceReplicationParams)
service/worker/migration/force_replication_workflow.go:392
↓ 2 callersFunctiongetCompletionCallbacksAsProtoSlice
(ctx context.Context, ms historyi.MutableState)
service/history/workflow/util.go:247
↓ 2 callersMethodgetConsistencySettings
()
common/config/persistence.go:212
↓ 2 callersFunctiongetContextState
(tb testing.TB, timeout time.Duration)
common/testing/testcontext/context.go:100
↓ 2 callersFunctiongetCreateTime
(f *taskqueuespb.TaskForwardInfo)
service/matching/task.go:196
↓ 2 callersFunctiongetCurrentBranchLastWriteVersion
( versionHistories *historyspb.VersionHistories, transitions []*persistencespb.VersionedTransition, )
common/persistence/execution_manager.go:1263
↓ 2 callersFunctiongetCurrentUserFromEnv
()
tools/tdbg/util.go:32
↓ 2 callersFunctiongetCurrentWorkflowExecutionContext
( ctx context.Context, shardContext historyi.ShardContext, workflowCache wcache.Cache, namespaceID string,
service/history/statemachine_environment.go:103
↓ 2 callersMethodgetDLQWorkflowID
( key *commonspb.HistoryDLQKey, )
service/frontend/admin_handler.go:2429
↓ 2 callersFunctiongetEffectiveWeight
(overrides fairnessWeightOverrides, pri *commonpb.Priority)
service/matching/fairness_util.go:18
↓ 2 callersFunctiongetEndpointIDIssues
(ID string)
service/frontend/nexus_endpoint_client.go:376
↓ 2 callersMethodgetEndpointList
(iter gocql.Iter)
common/persistence/cassandra/nexus_endpoint_store.go:343
↓ 2 callersMethodgetEventSlices
(version int64, timeDrift time.Duration)
tests/ndc/replication_migration_back_test.go:454
↓ 2 callersFunctiongetExpectedTables
(versioningEnabled bool, wantTables []string)
tools/common/schema/test/setuptest.go:141
↓ 2 callersFunctiongetFreePort
(host string)
common/testing/freeport/freeport.go:36
↓ 2 callersFunctiongetFrontendConnectionDetails
( cfg *config.Config, tlsConfigProvider encryption.TLSConfigProvider, resolver *membership.GRPCResolver, )
common/resource/fx.go:467
↓ 2 callersMethodgetFutureActionTimes
Returns up to `n` future action times. After workflow version `AccurateFutureActionTimes`, No more than the schedule's `RemainingActions` will be ret
service/worker/scheduler/workflow.go:1086
↓ 2 callersMethodgetHistory
( ctx context.Context, remoteClusterName string, namespaceID namespace.ID, workflowID string, runID strin
service/history/replication/eventhandler/remote_history_paginated_fetcher.go:168
↓ 2 callersMethodgetHistoryForQueryTask
( ctx context.Context, nsID namespace.ID, task *internalTask, isStickyEnabled bool, )
service/matching/matching_engine.go:863
↓ 2 callersMethodgetHistoryFromRemotePaginationFn
( ctx context.Context, remoteClusterName string, namespaceID namespace.ID, workflowID string, runID strin
service/history/ndc/workflow_state_replicator.go:1875
↓ 2 callersMethodgetLastEvent
Returns the time of the last "event" to happen to the schedule. An event here is the schedule getting created or updated, or an action. This value is
service/worker/scheduler/workflow.go:1669
↓ 2 callersMethodgetLastMessageID
(c *cli.Context, action string)
tools/tdbg/dlq_v2_service.go:300
↓ 2 callersMethodgetLastMessageID
( ctx context.Context, queueType persistence.QueueType, )
common/persistence/cassandra/queue_store.go:109
↓ 2 callersMethodgetLastSlowSubmissionTimestamp
(priority enumsspb.TaskPriority)
service/history/replication/stream_receiver.go:409
↓ 2 callersMethodgetListInfo
(inWorkflowContext bool)
service/worker/scheduler/workflow.go:1168
↓ 2 callersMethodgetMaxReplicationTaskID
()
service/history/shard/context_impl.go:1751
↓ 2 callersMethodgetMaxVersions
(ctx workflow.Context)
service/worker/workerdeployment/workflow.go:1505
↓ 2 callersMethodgetMergedEphemeralData
()
service/matching/user_data_manager.go:817
← previousnext →8,201–8,300 of 43,335, ranked by callers