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 callersFunctionfile_temporal_server_api_metrics_v1_message_proto_rawDescGZIP
()
api/metrics/v1/message.pb.go:85
↓ 1 callersFunctionfile_temporal_server_api_namespace_v1_message_proto_init
()
api/namespace/v1/message.pb.go:117
↓ 1 callersFunctionfile_temporal_server_api_namespace_v1_message_proto_rawDescGZIP
()
api/namespace/v1/message.pb.go:97
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_chasm_visibility_proto_init
()
api/persistence/v1/chasm_visibility.pb.go:149
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_cluster_metadata_proto_init
()
api/persistence/v1/cluster_metadata.pb.go:292
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_history_tree_proto_init
()
api/persistence/v1/history_tree.pb.go:277
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_namespaces_proto_init
()
api/persistence/v1/namespaces.pb.go:539
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_nexus_proto_init
()
api/persistence/v1/nexus.pb.go:484
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_queue_metadata_proto_init
()
api/persistence/v1/queue_metadata.pb.go:108
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_queue_metadata_proto_rawDescGZIP
()
api/persistence/v1/queue_metadata.pb.go:86
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_task_queues_proto_init
()
api/persistence/v1/task_queues.pb.go:902
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_tasks_proto_init
()
api/persistence/v1/tasks.pb.go:809
↓ 1 callersFunctionfile_temporal_server_api_persistence_v1_workflow_mutable_state_proto_init
()
api/persistence/v1/workflow_mutable_state.pb.go:535
↓ 1 callersFunctionfile_temporal_server_api_replication_v1_message_proto_init
()
api/replication/v1/message.pb.go:2444
↓ 1 callersFunctionfile_temporal_server_api_routing_v1_extension_proto_init
()
api/routing/v1/extension.pb.go:146
↓ 1 callersFunctionfile_temporal_server_api_routing_v1_extension_proto_rawDescGZIP
()
api/routing/v1/extension.pb.go:123
↓ 1 callersFunctionfile_temporal_server_api_schedule_v1_message_proto_init
()
api/schedule/v1/message.pb.go:1227
↓ 1 callersFunctionfile_temporal_server_api_taskqueue_v1_message_proto_init
()
api/taskqueue/v1/message.pb.go:1291
↓ 1 callersFunctionfile_temporal_server_api_testservice_v1_service_proto_init
()
api/testservice/v1/service.pb.go:47
↓ 1 callersFunctionfile_temporal_server_api_token_v1_message_proto_init
()
api/token/v1/message.pb.go:767
↓ 1 callersFunctionfile_temporal_server_api_visibilityservice_v1_request_response_proto_init
()
api/visibilityservice/v1/request_response.pb.go:405
↓ 1 callersFunctionfile_temporal_server_api_workflow_v1_message_proto_init
()
api/workflow/v1/message.pb.go:281
↓ 1 callersFunctionfile_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_init
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:1088
↓ 1 callersFunctionfile_temporal_server_chasm_lib_activity_proto_v1_service_proto_init
()
chasm/lib/activity/gen/activitypb/v1/service.pb.go:75
↓ 1 callersFunctionfile_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_init
()
chasm/lib/activity/gen/activitypb/v1/tasks.pb.go:286
↓ 1 callersFunctionfile_temporal_server_chasm_lib_callback_proto_v1_message_proto_init
()
chasm/lib/callback/gen/callbackpb/v1/message.pb.go:465
↓ 1 callersFunctionfile_temporal_server_chasm_lib_callback_proto_v1_tasks_proto_init
()
chasm/lib/callback/gen/callbackpb/v1/tasks.pb.go:151
↓ 1 callersFunctionfile_temporal_server_chasm_lib_nexusoperation_proto_v1_operation_proto_init
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:1001
↓ 1 callersFunctionfile_temporal_server_chasm_lib_nexusoperation_proto_v1_service_proto_init
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service.pb.go:74
↓ 1 callersFunctionfile_temporal_server_chasm_lib_nexusoperation_proto_v1_tasks_proto_init
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/tasks.pb.go:357
↓ 1 callersFunctionfile_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_init
()
chasm/lib/scheduler/gen/schedulerpb/v1/service.pb.go:89
↓ 1 callersFunctionfile_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_init
()
chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go:346
↓ 1 callersFunctionfile_temporal_server_chasm_lib_tests_proto_v1_message_proto_init
()
chasm/lib/tests/gen/testspb/v1/message.pb.go:245
↓ 1 callersFunctionfile_temporal_server_chasm_lib_tests_proto_v1_service_proto_init
()
chasm/lib/tests/gen/testspb/v1/service.pb.go:49
↓ 1 callersFunctionfile_temporal_server_chasm_lib_workflow_proto_v1_state_proto_init
()
chasm/lib/workflow/gen/workflowpb/v1/state.pb.go:214
↓ 1 callersFunctionfile_temporal_server_chasm_lib_workflow_proto_v1_update_state_proto_init
()
chasm/lib/workflow/gen/workflowpb/v1/update_state.pb.go:116
↓ 1 callersFunctionfile_temporal_server_chasm_lib_workflow_proto_v1_update_state_proto_rawDescGZIP
()
chasm/lib/workflow/gen/workflowpb/v1/update_state.pb.go:94
↓ 1 callersMethodfillIndexes
fillIndexes computes cell indexes for all D+1 rows (D active + 1 shadow). len(indexes) must == len(s.seeds) == D+1
service/matching/counter/cmsketch.go:126
↓ 1 callersMethodfillStatusMap
(statusMap map[ClusterShardKeyPair]*streamStatus, serverKey ClusterShardKey, clientsKeys []ClusterShardKey)
service/history/replication/stream_receiver_monitor.go:383
↓ 1 callersMethodfilterHistoryNodes
( lastNodeID int64, lastTransactionID int64, nodes []InternalHistoryNode, )
common/persistence/history_manager.go:1038
↓ 1 callersMethodfilterHistoryNodesReverse
( lastNodeID int64, lastTransactionID int64, nodes []InternalHistoryNode, )
common/persistence/history_manager.go:1074
↓ 1 callersMethodfilterTask
( branch persistence.HistoryBranchDetail, )
service/worker/scanner/history/scavenger.go:206
↓ 1 callersMethodfindAccessibleVertex
( vertexIndex int, )
common/testing/event_generator.go:279
↓ 1 callersFunctionfindAlteredTestSuites
findAlteredTestSuites filters files by the test directories and extracts test suite names from them
cmd/tools/test/find_altered_tests.go:118
↓ 1 callersFunctionfindLastAssertionFailureBlock
(lines []string)
tools/testrunner/log.go:374
↓ 1 callersMethodfindLastMessageIDFromListQueues
(c *cli.Context)
tools/tdbg/dlq_v2_service.go:322
↓ 1 callersFunctionfindLastTestOutputFailureBlock
(lines []string)
tools/testrunner/log.go:424
↓ 1 callersFunctionfindLatestRuns
(workflow, branch, event string, limit int)
tools/optimize-test-sharding/main.go:151
↓ 1 callersFunctionfindMatchWithCache
( cache *sync.Map, cvs []ConstrainedValue, precedence []Constraints, )
common/dynamicconfig/collection.go:236
↓ 1 callersMethodfindNewVersionStatus
findNewVersionStatus is a helper to find the new version status a version will have after it a successful sync to all its task queues.
service/worker/workerdeployment/version_workflow.go:1177
↓ 1 callersFunctionfindOperationNode
(root *hsm.Node, event *historypb.HistoryEvent)
components/nexusoperations/events.go:327
↓ 1 callersFunctionfindProtoImports
()
cmd/tools/getproto/main.go:35
↓ 1 callersFunctionfindRaceBlockStart
findRaceBlockStart searches upward for the race report delimiter.
tools/testrunner/log.go:291
↓ 1 callersFunctionfindSetWithSetIDs
(sets []*persistencespb.CompatibleVersionSet, ids []string)
service/matching/version_sets_merge.go:38
↓ 1 callersMethodfindSliceToClear
( targetPendingTasks int, )
service/history/queues/action_pending_task_count.go:117
↓ 1 callersMethodfinish
finish runs registered cleanups in LIFO order, mirroring *testing.T.
tests/testcore/cluster_poison_test.go:52
↓ 1 callersMethodfinishEvent
( eventType enumspb.EventType, )
service/history/historybuilder/event_store.go:358
↓ 1 callersMethodfirstWorkflowTaskAssignmentSpooled
(env *testcore.TestEnv)
tests/versioning_test.go:741
↓ 1 callersMethodfirstWorkflowTaskAssignmentSyncMatch
(env *testcore.TestEnv)
tests/versioning_test.go:851
↓ 1 callersMethodfirstWorkflowTaskCompletedEventID
firstWorkflowTaskCompletedEventID returns the event ID of the first WorkflowTaskCompleted event in the given run's history. Used as the reset point fo
tests/timeskipping_propagation_test.go:926
↓ 1 callersFunctionflag
(opt string)
tools/elasticsearch/handler.go:240
↓ 1 callersMethodflushBufferEvents
( ctx context.Context, wfContext historyi.WorkflowContext, mutableState historyi.MutableState, )
service/history/ndc/mutable_state_initializer.go:193
↓ 1 callersMethodformat
(normalized bool)
common/testing/objectleak/path.go:45
↓ 1 callersMethodformatCapturedMessage
formatCapturedMessage formats a single captured message as JSON for output
tests/testcore/replication_stream_recorder.go:128
↓ 1 callersFunctionformatLinks
formatLinks formats GitHub URLs as numbered markdown links
tools/flakereport/report.go:38
↓ 1 callersFunctionformatListDiff
(listA, listB any, extraA, extraB any)
common/testing/protoassert/testify_assert.go:13
↓ 1 callersMethodforwardCancelOperation
( ctx context.Context, service string, operation string, id string, options nexus.CancelOperationOptions,
service/frontend/nexus_handler.go:717
↓ 1 callersMethodforwardCompleteOperation
(ctx context.Context, r *nexusrpc.CompletionRequest, rCtx *requestContext)
service/frontend/nexus_completion_http_handler.go:333
↓ 1 callersMethodforwardStartOperation
forwardStartOperation forwards the StartOperation request to the active cluster using an HTTP request. Inputs and response values are passed as Reader
service/frontend/nexus_handler.go:587
↓ 1 callersMethodforwardTask
(task *internalTask)
service/matching/pri_matcher.go:194
↓ 1 callersMethodforwardTasks
TODO(pri): access to retrier is not synchronized
service/matching/pri_matcher.go:165
↓ 1 callersMethodfqType
fqType returns the fully qualified name of the component, which is a combination of the library name and the component type. This is used to uniquely
chasm/registrable_component.go:224
↓ 1 callersFunctionfunctionNameForPC
(pc uintptr)
common/testing/runtime/goroutine.go:132
↓ 1 callersMethodfwdrPollReqTokenC
()
service/matching/matcher.go:537
↓ 1 callersMethodgatherStatistics
( readers map[int64]Reader, )
service/history/queues/action_pending_task_count.go:89
↓ 1 callersFunctiongenAssignShard
(m *protogen.Method)
cmd/tools/protoc-gen-go-chasm/main.go:116
↓ 1 callersMethodgenClient
(w *writer, svc *protogen.Service)
cmd/tools/protoc-gen-go-chasm/main.go:181
↓ 1 callersFunctiongenerate
(ctx context.Context, gen *generator)
cmd/tools/protogen/main.go:439
↓ 1 callersMethodgenerateBackfillHistoryTask
( ctx context.Context, taskInfo *tasks.SyncVersionedTransitionTask, targetClusterID int32, )
service/history/replication/raw_task_converter.go:829
↓ 1 callersFunctiongenerateBisectSummary
generateBisectSummary creates the markdown section for bisect results to append to the GitHub summary.
tools/flakereport/writer.go:152
↓ 1 callersMethodgenerateCallbackToken
generateCallbackToken creates a callback token for the given operation reference.
chasm/lib/nexusoperation/task_handler_helpers.go:368
↓ 1 callersMethodgenerateChecksum
()
service/history/workflow/mutable_state_impl.go:9026
↓ 1 callersMethodgenerateChildWorkflowRequestID
generateChildWorkflowRequestID generates a unique request ID for child workflow execution
service/history/workflow/mutable_state_impl.go:6386
↓ 1 callersFunctiongenerateExecutionInfo
()
common/util_test.go:484
↓ 1 callersFunctiongenerateGitHubSummary
generateGitHubSummary creates markdown summary for GitHub Actions
tools/flakereport/writer.go:39
↓ 1 callersFunctiongenerateMapInit
Helper functions to regenerate testComponentSerializedNodes() function body. Use: generateMapInit(serializedNodes, "serializedNodes")
chasm/test_component_test.go:327
↓ 1 callersFunctiongenerateMutableStateChecksum
(ms historyi.MutableState)
service/history/workflow/checksum.go:18
↓ 1 callersMethodgenerateNewRunHistory
( event *historypb.HistoryEvent, nsName namespace.Name, nsID namespace.ID, workflowID string, runID strin
tests/ndc/ndc_test.go:2065
↓ 1 callersMethodgenerateNextEventBatch
()
common/testing/event_generator.go:202
↓ 1 callersMethodgenerateProtoMocks
(ctx context.Context)
cmd/tools/protogen/main.go:258
↓ 1 callersFunctiongenerateSelfSignedX509CA
GenerateSelfSignedX509CA generates a TLS serverCert that is self-signed
tests/testutils/certificate.go:17
↓ 1 callersFunctiongenerateServerX509UsingCAAndSerialNumber
GenerateServerX509UsingCA generates a TLS serverCert that is self-signed
tests/testutils/certificate.go:69
↓ 1 callersMethodgenerateVerifyVersionedTransitionTask
( taskInfo *tasks.SyncVersionedTransitionTask, mutableState historyi.MutableState, )
service/history/replication/raw_task_converter.go:780
↓ 1 callersMethodgenerateWorkflowReplicationTask
( ctx context.Context, rateLimiter quotas.RateLimiter, namespaceName string, namespaceID string, executio
service/worker/migration/activities.go:458
↓ 1 callersFunctiongetActivityInfoMap
( ctx context.Context, db sqlplugin.DB, shardID int32, namespaceID primitives.UUID, workflowID string, r
common/persistence/sql/execution_state_map.go:60
↓ 1 callersMethodgetActivityLogger
(ctx context.Context)
service/worker/batcher/activities.go:398
↓ 1 callersFunctiongetActivityState
(ai *persistencespb.ActivityInfo)
service/history/workflow/matcher/activity_evaluator.go:297
↓ 1 callersMethodgetAlias
(saFieldName string, namespaceName string)
common/searchattribute/validator.go:228
↓ 1 callersMethodgetAllClientConns
()
client/history/connections.go:42
↓ 1 callersMethodgetAllEndpointsMatchingWithPersistenceFallback
(ctx context.Context)
common/nexus/endpoint_registry.go:368
← previousnext →11,701–11,800 of 43,335, ranked by callers