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
↓ 2 callers
Function
file_temporal_server_api_common_v1_api_category_proto_rawDescGZIP
()
api/common/v1/api_category.pb.go:181
↓ 2 callers
Function
file_temporal_server_api_enums_v1_cluster_proto_rawDescGZIP
()
api/enums/v1/cluster.pb.go:191
↓ 2 callers
Function
file_temporal_server_api_enums_v1_dlq_proto_rawDescGZIP
()
api/enums/v1/dlq.pb.go:169
↓ 2 callers
Function
file_temporal_server_api_historyservice_v1_request_response_proto_init
()
api/historyservice/v1/request_response.pb.go:11935
↓ 2 callers
Function
file_temporal_server_api_matchingservice_v1_request_response_proto_init
()
api/matchingservice/v1/request_response.pb.go:6644
↓ 2 callers
Function
file_temporal_server_api_persistence_v1_chasm_visibility_proto_rawDescGZIP
()
api/persistence/v1/chasm_visibility.pb.go:128
↓ 2 callers
Function
file_temporal_server_api_persistence_v1_cluster_metadata_proto_rawDescGZIP
()
api/persistence/v1/cluster_metadata.pb.go:260
↓ 2 callers
Function
file_temporal_server_api_persistence_v1_executions_proto_init
()
api/persistence/v1/executions.pb.go:5677
↓ 2 callers
Function
file_temporal_server_api_persistence_v1_predicates_proto_init
()
api/persistence/v1/predicates.pb.go:831
↓ 2 callers
Function
file_temporal_server_api_persistence_v1_queues_proto_init
()
api/persistence/v1/queues.pb.go:619
↓ 2 callers
Function
file_temporal_server_api_testservice_v1_request_response_proto_init
()
api/testservice/v1/request_response.pb.go:149
↓ 2 callers
Function
file_temporal_server_api_testservice_v1_request_response_proto_rawDescGZIP
()
api/testservice/v1/request_response.pb.go:128
↓ 2 callers
Function
file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_init
()
chasm/lib/activity/gen/activitypb/v1/request_response.pb.go:665
↓ 2 callers
Function
file_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_rawDescGZIP
()
chasm/lib/callback/gen/callbackpb/v1/tasks.pb.go:130
↓ 2 callers
Function
file_temporal_server_chasm_lib_nexusoperation_proto_v1_request_response_proto_init
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/request_response.pb.go:675
↓ 2 callers
Function
file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_init
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:846
↓ 2 callers
Function
file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init
()
chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go:1024
↓ 2 callers
Function
file_temporal_server_chasm_lib_tests_proto_v1_request_response_proto_init
()
chasm/lib/tests/gen/testspb/v1/request_response.pb.go:160
↓ 2 callers
Function
file_temporal_server_chasm_lib_tests_proto_v1_request_response_proto_rawDescGZIP
()
chasm/lib/tests/gen/testspb/v1/request_response.pb.go:139
↓ 2 callers
Method
fillFields
fillFields fill fields parameter with fields read from tags. Optimized for performance.
common/log/zap_logger.go:113
↓ 2 callers
Method
fillNextTimeCacheV2
(start time.Time)
service/worker/scheduler/workflow.go:591
↓ 2 callers
Function
filterCompleted
filterCompleted removes workflow runs that are not completed
tools/ci-notify/github.go:96
↓ 2 callers
Method
filterWorkers
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 callers
Method
finalGC
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 callers
Method
findMatch
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 callers
Function
findMatchWithConstrainedDefaults
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 callers
Method
findNamedGrpcConnCfg
(name string)
common/telemetry/config.go:349
↓ 2 callers
Function
findNestedField
(t reflect.Type, name string, path string, maxDepth int)
cmd/tools/genrpcwrappers/main.go:170
↓ 2 callers
Method
findNewVersionStatusFromRoutingConfig
(rg *deploymentpb.RoutingConfig)
service/worker/workerdeployment/version_workflow.go:1157
↓ 2 callers
Method
findWFTEvent
(eventType enumspb.EventType, workflowEvents []*persistence.WorkflowEvents)
service/history/workflow/workflow_test/mutable_state_impl_test.go:284
↓ 2 callers
Method
finish
finish drains remaining tasks, calculates normalized stats, and prints stats.
tools/fairsim/sim.go:214
↓ 2 callers
Method
finishInternal
(res taskResponse, consumedToken bool)
service/matching/task.go:382
↓ 2 callers
Function
finishParseJSONValue
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 callers
Method
firstDispatchTime
()
chasm/lib/activity/activity.go:742
↓ 2 callers
Function
flag
(opt string)
tools/sql/handler.go:180
↓ 2 callers
Method
forgetDeploymentVersionsFromDeploymentData
( env *testcore.TestEnv, tv *testvars.TestVars, deploymentName string, forgetUnversionedRamp bool, revisi
tests/versioning_3_test.go:4433
↓ 2 callers
Method
forkAndGenerateBranchToken
( ctx context.Context, namespaceID namespace.ID, workflowID string, forkBranchToken []byte, forkNodeID in
service/history/ndc/workflow_resetter.go:604
↓ 2 callers
Function
formatPath
formatPath returns a human-readable representation of a path.
service/history/hsm/tree.go:78
↓ 2 callers
Function
formatReportLines
formatReportLines returns a plain-text bullet line per report.
tools/flakereport/report.go:24
↓ 2 callers
Method
forwardPolls
( ctx context.Context, targetPriority, effectivePriority priorityKey, ft pollForwarderType, target *tqid.N
service/matching/pri_matcher.go:289
↓ 2 callers
Method
fprint
(w io.Writer, verbose bool)
tools/fairsim/sim.go:446
↓ 2 callers
Function
fromAdminClientAPIResponse
(response *adminservice.GetNamespaceResponse)
service/history/replication/eager_namespace_refresher_test.go:250
↓ 2 callers
Function
functionName
(fn any)
common/testing/runtime/goroutine.go:120
↓ 2 callers
Function
gatherBuildIds
(data *persistencespb.VersioningData)
service/matching/version_sets.go:63
↓ 2 callers
Function
genFileList
(protoImports []string)
cmd/tools/getproto/main.go:73
↓ 2 callers
Function
generateConfig
(t *testing.T, tmpDir string, ports portSet, activePorts portSet)
tests/mixedbrain/config_util.go:80
↓ 2 callers
Method
generateConflictToken
()
chasm/lib/scheduler/scheduler.go:923
↓ 2 callers
Function
generateKey
(resourceType int32, id string)
common/definition/resource_dedup.go:68
↓ 2 callers
Function
generateRequestID
(scheduler *Scheduler, backfillID string, nominal, actual time.Time)
chasm/lib/scheduler/util.go:16
↓ 2 callers
Method
generateRequestIdRefLink
(runID string)
service/history/api/startworkflow/api.go:826
↓ 2 callers
Function
generateShardIDs
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 callers
Method
generateStatusMap
(inboundKeys map[ClusterShardKeyPair]struct{})
service/history/replication/stream_receiver_monitor.go:371
↓ 2 callers
Function
generateSubStateMachineTask
( mutableState historyi.MutableState, stateMachineRegistry *hsm.Registry, node *hsm.Node, subStateMachineP
service/history/workflow/task_generator.go:930
↓ 2 callers
Function
generateSuiteBreakdownTable
generateSuiteBreakdownTable creates a markdown table of per-suite flake data
tools/flakereport/report.go:72
↓ 2 callers
Function
generateSuiteReports
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 callers
Method
generateTaskID
()
service/history/shard/task_key_generator.go:167
↓ 2 callers
Function
genericFrontendServiceProvider
( params ServiceProviderParamsCommon, serviceName primitives.ServiceName, )
temporal/fx.go:548
↓ 2 callers
Method
getActiveCluster
(ctx context.Context)
tests/xdc/history_replication_signals_and_updates_test.go:1008
↓ 2 callers
Function
getActiveRedirectRuleBySrc
(src string, data *persistencespb.VersioningData)
service/matching/version_rule_test.go:168
↓ 2 callers
Function
getActivityIDs
(updateRequest *workflowservice.UpdateActivityOptionsRequest, ms historyi.MutableState)
service/history/api/updateactivityoptions/api.go:345
↓ 2 callers
Function
getActivityLogger
(ctx context.Context)
service/worker/parentclosepolicy/workflow.go:220
↓ 2 callers
Method
getAllEndpoints
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 callers
Method
getAllEndpointsMatching
getAllEndpointsMatching paginates over all endpoints returned by matching. It always does a simple get.
common/nexus/endpoint_registry.go:379
↓ 2 callers
Method
getBacklogCount
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/task_queue_test.go:167
↓ 2 callers
Function
getBatchOperationState
(workflowState enumspb.WorkflowExecutionStatus)
service/frontend/workflow_handler.go:6752
↓ 2 callers
Method
getBranchByKey
(m *sync.Map, k int)
common/persistence/persistence-tests/history_v2_persistence.go:653
↓ 2 callers
Function
getBuildIdTaskReachability
( ctx context.Context, rc *reachabilityCalculator, metricsHandler metrics.Handler, logger log.Logger, bui
service/matching/reachability.go:87
↓ 2 callers
Method
getBuildIds
(versions *taskqueuepb.TaskQueueVersionSelection)
service/matching/matching_engine.go:1629
↓ 2 callers
Method
getClientKeepAliveConfig
(serviceName primitives.ServiceName)
common/rpc/rpc.go:303
↓ 2 callers
Method
getClientTLSSettings
(isWorker bool)
common/rpc/encryption/local_store_cert_provider.go:306
↓ 2 callers
Method
getClosedVisibilityRequest
( ctx context.Context, base *manager.VisibilityRequestBase, mutableState historyi.MutableState, namespaceE
service/history/visibility_queue_task_executor.go:555
↓ 2 callers
Function
getClusterArchivalState
(str string)
common/archiver/archival_metadata.go:188
↓ 2 callers
Function
getClusterMetadata
(ctx workflow.Context, params ForceReplicationParams)
service/worker/migration/force_replication_workflow.go:392
↓ 2 callers
Function
getCompletionCallbacksAsProtoSlice
(ctx context.Context, ms historyi.MutableState)
service/history/workflow/util.go:247
↓ 2 callers
Method
getConsistencySettings
()
common/config/persistence.go:212
↓ 2 callers
Function
getContextState
(tb testing.TB, timeout time.Duration)
common/testing/testcontext/context.go:100
↓ 2 callers
Function
getCreateTime
(f *taskqueuespb.TaskForwardInfo)
service/matching/task.go:196
↓ 2 callers
Function
getCurrentBranchLastWriteVersion
( versionHistories *historyspb.VersionHistories, transitions []*persistencespb.VersionedTransition, )
common/persistence/execution_manager.go:1263
↓ 2 callers
Function
getCurrentUserFromEnv
()
tools/tdbg/util.go:32
↓ 2 callers
Function
getCurrentWorkflowExecutionContext
( ctx context.Context, shardContext historyi.ShardContext, workflowCache wcache.Cache, namespaceID string,
service/history/statemachine_environment.go:103
↓ 2 callers
Method
getDLQWorkflowID
( key *commonspb.HistoryDLQKey, )
service/frontend/admin_handler.go:2429
↓ 2 callers
Function
getEffectiveWeight
(overrides fairnessWeightOverrides, pri *commonpb.Priority)
service/matching/fairness_util.go:18
↓ 2 callers
Function
getEndpointIDIssues
(ID string)
service/frontend/nexus_endpoint_client.go:376
↓ 2 callers
Method
getEndpointList
(iter gocql.Iter)
common/persistence/cassandra/nexus_endpoint_store.go:343
↓ 2 callers
Method
getEventSlices
(version int64, timeDrift time.Duration)
tests/ndc/replication_migration_back_test.go:454
↓ 2 callers
Function
getExpectedTables
(versioningEnabled bool, wantTables []string)
tools/common/schema/test/setuptest.go:141
↓ 2 callers
Function
getFreePort
(host string)
common/testing/freeport/freeport.go:36
↓ 2 callers
Function
getFrontendConnectionDetails
( cfg *config.Config, tlsConfigProvider encryption.TLSConfigProvider, resolver *membership.GRPCResolver, )
common/resource/fx.go:467
↓ 2 callers
Method
getFutureActionTimes
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 callers
Method
getHistory
( ctx context.Context, remoteClusterName string, namespaceID namespace.ID, workflowID string, runID strin
service/history/replication/eventhandler/remote_history_paginated_fetcher.go:168
↓ 2 callers
Method
getHistoryForQueryTask
( ctx context.Context, nsID namespace.ID, task *internalTask, isStickyEnabled bool, )
service/matching/matching_engine.go:863
↓ 2 callers
Method
getHistoryFromRemotePaginationFn
( ctx context.Context, remoteClusterName string, namespaceID namespace.ID, workflowID string, runID strin
service/history/ndc/workflow_state_replicator.go:1875
↓ 2 callers
Method
getLastEvent
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 callers
Method
getLastMessageID
(c *cli.Context, action string)
tools/tdbg/dlq_v2_service.go:300
↓ 2 callers
Method
getLastMessageID
( ctx context.Context, queueType persistence.QueueType, )
common/persistence/cassandra/queue_store.go:109
↓ 2 callers
Method
getLastSlowSubmissionTimestamp
(priority enumsspb.TaskPriority)
service/history/replication/stream_receiver.go:409
↓ 2 callers
Method
getListInfo
(inWorkflowContext bool)
service/worker/scheduler/workflow.go:1168
↓ 2 callers
Method
getMaxReplicationTaskID
()
service/history/shard/context_impl.go:1751
↓ 2 callers
Method
getMaxVersions
(ctx workflow.Context)
service/worker/workerdeployment/workflow.go:1505
↓ 2 callers
Method
getMergedEphemeralData
()
service/matching/user_data_manager.go:817
← previous
next →
8,201–8,300 of 43,335, ranked by callers