MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 3 callersFunctionfile_temporal_server_api_enums_v1_common_proto_rawDescGZIP
()
api/enums/v1/common.pb.go:245
↓ 3 callersFunctionfile_temporal_server_api_enums_v1_replication_proto_rawDescGZIP
()
api/enums/v1/replication.pb.go:295
↓ 3 callersFunctionfile_temporal_server_api_enums_v1_task_proto_rawDescGZIP
()
api/enums/v1/task.pb.go:437
↓ 3 callersFunctionfile_temporal_server_api_enums_v1_workflow_proto_rawDescGZIP
()
api/enums/v1/workflow.pb.go:256
↓ 3 callersFunctionfile_temporal_server_api_health_v1_message_proto_rawDescGZIP
()
api/health/v1/message.pb.go:275
↓ 3 callersFunctionfile_temporal_server_api_persistence_v1_chasm_proto_init
()
api/persistence/v1/chasm.pb.go:1065
↓ 3 callersFunctionfile_temporal_server_api_persistence_v1_history_tree_proto_rawDescGZIP
()
api/persistence/v1/history_tree.pb.go:251
↓ 3 callersFunctionfile_temporal_server_api_persistence_v1_update_proto_init
()
api/persistence/v1/update.pb.go:425
↓ 3 callersFunctionfile_temporal_server_api_persistence_v1_workflow_mutable_state_proto_rawDescGZIP
()
api/persistence/v1/workflow_mutable_state.pb.go:449
↓ 3 callersFunctionfile_temporal_server_api_workflow_v1_message_proto_rawDescGZIP
()
api/workflow/v1/message.pb.go:254
↓ 3 callersFunctionfile_temporal_server_chasm_lib_tests_proto_v1_message_proto_rawDescGZIP
()
chasm/lib/tests/gen/testspb/v1/message.pb.go:219
↓ 3 callersFunctionfile_temporal_server_chasm_lib_workflow_proto_v1_state_proto_rawDescGZIP
()
chasm/lib/workflow/gen/workflowpb/v1/state.pb.go:192
↓ 3 callersFunctionfindAndResolveWithConstrainedDefaults
( c *Collection, key Key, convert func(value any) (T, error), cvs []ConstrainedValue, defaultCVs []TypedC
common/dynamicconfig/collection.go:347
↓ 3 callersMethodfindBuildIdsToRemove
Queries visibility for each build ID in versioning data and returns a list of those that are safe for removal.
service/worker/scanner/build_ids/scavenger.go:245
↓ 3 callersMethodfindLCAVersionHistoryItemFromItemsTestBase
( versionHistoryItemsA [][]*historyspb.VersionHistoryItem, versionHistoryItemsB []*historyspb.VersionHistory
common/persistence/versionhistory/version_history_test.go:815
↓ 3 callersFunctionfindStartRequestID
findStartRequestID returns the request ID associated with the WorkflowExecutionStarted event from the RequestIds map, or the create request ID if not
service/history/ndc/state_rebuilder.go:404
↓ 3 callersMethodfindVersionTaskQueue
( taskQueues []*workflowservice.DescribeWorkerDeploymentVersionResponse_VersionTaskQueue, tqName string, tq
tests/versioning_test_env.go:51
↓ 3 callersMethodfire
()
common/timer/remote_gate.go:123
↓ 3 callersMethodflattenWeightedChannelsLocked
()
common/tasks/interleaved_weighted_round_robin.go:264
↓ 3 callersMethodforEachNamespace
forEachNamespace runs `query` against one namespace (scoped to the Scheduler archetype) and passes the resulting count to resultsFilter. Rate-limited
service/worker/scanner/scheduleinvariants/invariants.go:262
↓ 3 callersMethodforceReadPartition
(partitionCount, partitionID int)
client/matching/loadbalancer.go:168
↓ 3 callersMethodforceTerminateWorkflow
( ctx context.Context, shardContext historyi.ShardContext, failureReason string, )
service/history/workflow/context.go:1158
↓ 3 callersMethodfork
persistence helper
common/persistence/persistence-tests/history_v2_persistence.go:818
↓ 3 callersFunctionformatCount
(count int, label string)
common/testing/objectleak/report.go:219
↓ 3 callersMethodfrontendAddr
()
tests/mixedbrain/config_util.go:67
↓ 3 callersMethodfwdrAddReqTokenC
()
service/matching/matcher.go:544
↓ 3 callersMethodgenerateEventBlobs
( workflowID string, runID string, workflowType string, taskqueue string, batch *historypb.History, )
tests/ndc/ndc_test.go:2121
↓ 3 callersFunctiongenerateFailure
(kind failureType, data string)
tools/testrunner/junit.go:78
↓ 3 callersMethodgenerateOutboundStreamKeys
()
service/history/replication/stream_receiver_monitor.go:210
↓ 3 callersMethodgenerateSummary
()
tools/testrunner/testrunner.go:258
↓ 3 callersMethodgenerateTaskIDLocked
()
service/history/shard/context_impl.go:1147
↓ 3 callersMethodgenerateTaskKey
( category tasks.Category, )
service/history/shard/task_key_manager.go:62
↓ 3 callersMethodgenerateVisibilityRow
( request *store.InternalVisibilityRequestBase, )
common/persistence/visibility/store/sql/visibility_store.go:753
↓ 3 callersFunctiongenerateWorkflowAlreadyStartedError
( errMsg string, requestIDs map[string]*persistencespb.RequestIDInfo, workflowKey definition.WorkflowKey, )
service/history/api/workflow_id_dedup.go:233
↓ 3 callersMethodgenerateWorkflowExecution
generateWorkflowExecution makes a sample workflowExecution and WorkflowType for the required tests
service/matching/matching_engine_test.go:3579
↓ 3 callersMethodgetActivityScheduledEvent
( ms historyi.MutableState, scheduledEventID int64, )
service/history/history_engine_test.go:6632
↓ 3 callersMethodgetApproximateBacklogCountsBySubqueue
getApproximateBacklogCountsBySubqueue return the approximate backlog count for each subqueue. The index corresponds to the subqueue id.
service/matching/db.go:456
↓ 3 callersFunctiongetBackoffInterval
TODO treat 0 as 0, not infinite
service/history/workflow/retry.go:32
↓ 3 callersFunctiongetCacheExitPoint
(open, hit bool)
service/matching/reachability.go:158
↓ 3 callersMethodgetCatchupWindow
()
service/worker/scheduler/workflow.go:1305
↓ 3 callersFunctiongetCategory
getCategory first searches the registry for the category by the [tasks.Category.Name].
tools/tdbg/commands.go:447
↓ 3 callersMethodgetCompiledSpec
(specBuilder *scheduler.SpecBuilder)
chasm/lib/scheduler/scheduler.go:406
↓ 3 callersMethodgetCreateTime
()
service/matching/task.go:260
↓ 3 callersFunctiongetCurrentDefault
(res *workflowservice.GetWorkerBuildIdCompatibilityResponse)
tests/versioning_test.go:5025
↓ 3 callersMethodgetCurrentTaskIDBlock
getCurrentTaskIDBlock returns the current taskIDBlock. Safe to be called concurrently.
service/matching/task_writer.go:229
↓ 3 callersFunctiongetDLQFlags
(taskCategoryRegistry tasks.TaskCategoryRegistry)
tools/tdbg/tdbg_commands.go:891
↓ 3 callersMethodgetDLQKey
()
tools/tdbg/dlq_v2_service.go:292
↓ 3 callersFunctiongetDefaultBuildId
getDefaultBuildId gets the build ID mentioned in the first fully-ramped Assignment Rule. If there is no default Build ID, the result for the unversion
service/matching/reachability.go:281
↓ 3 callersFunctiongetDeletedRedirectRuleBySrc
(src string, data *persistencespb.VersioningData)
service/matching/version_rule_test.go:177
↓ 3 callersMethodgetEligibleBufferedStarts
getEligibleBufferedStarts returns all BufferedStarts that are marked for execution (Attempt > 0), haven't been started yet (no RunId), and aren't pres
chasm/lib/scheduler/invoker.go:360
↓ 3 callersMethodgetFirstWFTaskCompleteEventID
getFirstWFTaskCompleteEventID scans the workflow history and returns the event ID of the first WorkflowTaskCompleted event.
tests/nexus_workflow_update_test.go:179
↓ 3 callersFunctiongetFirstWorkflowTaskEventID
( ctx context.Context, namespaceStr string, workflowExecution *commonpb.WorkflowExecution, frontendClient
service/worker/batcher/activities.go:878
↓ 3 callersMethodgetHistoryForRunId
(ctx context.Context, runId string)
tests/xdc/history_replication_signals_and_updates_test.go:953
↓ 3 callersMethodgetLastEvent
()
service/history/ndc/replication_task.go:35
↓ 3 callersFunctiongetLastVersionHistoryItem
(v []*historyspb.VersionHistoryItem)
common/persistence/versionhistory/version_history.go:221
↓ 3 callersFunctiongetLastWorkflowTaskEventID
( ctx context.Context, namespaceStr string, workflowExecution *commonpb.WorkflowExecution, frontendClient
service/worker/batcher/activities.go:838
↓ 3 callersMethodgetMaxMessageID
(ctx context.Context, queueType persistence.QueueV2Type, queueName string, tc sqlplugin.TableCRUD)
common/persistence/sql/queue_v2.go:373
↓ 3 callersMethodgetMaxMessageID
(ctx context.Context, queueType persistence.QueueV2Type, queueName string)
common/persistence/cassandra/queue_v2_store.go:454
↓ 3 callersFunctiongetMetricsContext
getMetricsContext extracts metrics context from golang context.
common/metrics/grpc.go:125
↓ 3 callersMethodgetMetricsHandler
()
service/history/api/startworkflow/api.go:160
↓ 3 callersMethodgetNamespace
getNamespace retrieves the information from the cache if it exists
common/namespace/nsregistry/registry.go:723
↓ 3 callersMethodgetNamespaceByID
getNamespaceByID retrieves the information from the cache if it exists.
common/namespace/nsregistry/registry.go:733
↓ 3 callersMethodgetNewEvents
()
service/history/ndc/replication_task.go:39
↓ 3 callersMethodgetNextPage
()
common/collection/paging_iterator.go:91
↓ 3 callersMethodgetNextTime
(after time.Time)
service/worker/scheduler/workflow.go:644
↓ 3 callersMethodgetOrCreateEntry
(shardID int32)
client/history/caching_redirector.go:130
↓ 3 callersMethodgetOrInitRateLimiter
( now time.Time, req Request, )
common/quotas/map_request_rate_limiter_impl.go:106
↓ 3 callersMethodgetOrReadthroughNamespaceByID
getOrReadthroughNamespaceByID retrieves the namespace information if it exists or reads through to the persistence layer and updates internal entry if
common/namespace/nsregistry/registry.go:783
↓ 3 callersFunctiongetOutputFile
(outputFile string, writer io.Writer)
tools/tdbg/dlq_service.go:144
↓ 3 callersMethodgetPaginationFn
( ctx context.Context, firstEventID int64, nextEventID int64, branchToken []byte, namespaceName string, )
service/history/ndc/state_rebuilder.go:356
↓ 3 callersFunctiongetPartitionBoundaryStart
(partition uint32, totalPartitions uint32)
common/persistence/sql/task_util.go:19
↓ 3 callersMethodgetPhysicalQueue
(ctx context.Context, buildId string, deployment *deploymentpb.Deployment)
service/matching/task_queue_partition_manager.go:1970
↓ 3 callersFunctiongetPriority
( class, subClass Priority, )
common/tasks/priority.go:77
↓ 3 callersMethodgetQueryNoLock
(id string)
service/history/workflow/query_registry.go:167
↓ 3 callersMethodgetQueue
( ctx context.Context, queueType persistence.QueueV2Type, name string, )
common/persistence/cassandra/queue_v2_store.go:370
↓ 3 callersMethodgetQueueMetadata
( ctx context.Context, tc sqlplugin.TableCRUD, queueType persistence.QueueV2Type, queueName string, )
common/persistence/sql/queue_v2.go:318
↓ 3 callersMethodgetRandomShard
getRandomShard returns a random shard ID for history APIs that are shard-agnostic (e.g. namespace or DLQ v2 APIs).
client/history/client.go:282
↓ 3 callersMethodgetShardContext
( ref chasm.ComponentRef, )
service/history/chasm_engine.go:1135
↓ 3 callersMethodgetSourceCluster
()
service/history/ndc/replication_task.go:37
↓ 3 callersMethodgetSyncStateResult
( ctx context.Context, namespaceID string, execution *commonpb.WorkflowExecution, mutableState historyi.Mu
service/history/replication/sync_state_retriever.go:184
↓ 3 callersMethodgetTargetNamespaceID
( targetNamespace namespace.Name, targetNamespaceID namespace.ID, )
service/history/workflow/task_generator.go:899
↓ 3 callersFunctiongetTaskLoggingTags
(err error, task taskDetail)
service/worker/scanner/history/scavenger.go:381
↓ 3 callersMethodgetTaskQueueVersionData
( env *testcore.TestEnv, tv *testvars.TestVars, tqType enumspb.TaskQueueType, version *deploymentpb.Worker
tests/worker_deployment_version_test.go:3068
↓ 3 callersMethodgetTimerSequence
()
service/history/workflow/task_generator.go:895
↓ 3 callersMethodgetUpdateCount
getUpdateCount returns how many times UpdateTaskQueue was called
service/matching/matching_engine_test.go:5538
↓ 3 callersMethodgetUserTimerTimeout
( timerInfo *persistencespb.TimerInfo, )
service/history/workflow/timer_sequence.go:216
↓ 3 callersMethodgetValueLocked
(key Key)
common/dynamicconfig/memory_client.go:35
↓ 3 callersMethodgetVersionedTransition
()
service/history/ndc/replication_task.go:41
↓ 3 callersMethodgetWorkerDeploymentInfoVersionSummary
(versionSummary *deploymentspb.WorkerDeploymentVersionSummary)
service/worker/workerdeployment/workflow.go:1811
↓ 3 callersFunctiongetWorkerOptions
(p *Processor)
service/worker/parentclosepolicy/processor.go:81
↓ 3 callersFunctiongetWorkflowVersion
(ctx workflow.Context, unsafeWorkflowVersionGetter func() DeploymentWorkflowVersion)
service/worker/workerdeployment/workflow.go:81
↓ 3 callersFunctiongiven2ActualIdx
given2ActualIdx takes in the user-given index, which only counts active assignment rules, and converts it to the actual index of that rule in the assi
service/matching/version_rule_helpers.go:460
↓ 3 callersMethodgoContext
()
chasm/context_mock.go:64
↓ 3 callersFunctiongobSerialize
(x any)
common/persistence/sql/common.go:83
↓ 3 callersMethodhandleCommandRequestCancelActivity
( _ context.Context, attr *commandpb.RequestCancelActivityTaskCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:664
↓ 3 callersMethodhandleIndividualTasks
()
service/history/replication/batchable_task.go:142
↓ 3 callersMethodhandleLocalAPIInvocation
( ctx context.Context, req any, handler grpc.UnaryHandler, methodName string, )
common/rpc/interceptor/redirection.go:252
↓ 3 callersMethodhandlePropagationComplete
handlePropagationComplete handles the propagation complete signal from version workflows
service/worker/workerdeployment/workflow.go:160
↓ 3 callersMethodhandleReadError
(err error)
service/history/shard/context_impl.go:1362
↓ 3 callersMethodhandleRegisterVersionFailures
(outcome *updatepb.Outcome)
service/worker/workerdeployment/client.go:385
← previousnext →6,301–6,400 of 43,335, ranked by callers