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 callersMethodcleanup
cleanup uses a two-phase approach to minimize lock contention: 1. RLock: collect candidates for eviction 2. For each candidate: Lock, re-check, delete
common/quotas/map_request_rate_limiter_impl.go:155
↓ 3 callersMethodcleanupReplicationTasks
()
service/history/replication/task_processor_manager.go:252
↓ 3 callersMethodcleanupWorkflowExecution
(ctx context.Context, namespaceID string, workflowID string, runID string)
service/history/replication/task_executor.go:392
↓ 3 callersMethodclientDataConverterStartWorker
(env *testcore.TestEnv, tl string, dataConverter converter.DataConverter)
tests/client_data_converter_test.go:81
↓ 3 callersFunctioncloneTaskQueueStats
(in *taskqueuepb.TaskQueueStats)
service/matching/task_queue_partition_manager.go:1718
↓ 3 callersFunctioncloseShard
(s *testcore.TestEnv, wid string)
tests/update_workflow_test.go:58
↓ 3 callersMethodcloseTransactionTrackLastUpdateVersionedTransition
( transactionPolicy historyi.TransactionPolicy, )
service/history/workflow/mutable_state_impl.go:7873
↓ 3 callersFunctionclustersConfig
(clusterNames ...string)
tests/ndc/cluster_config.go:10
↓ 3 callersFunctioncollectBlock
collectBlock builds a block from start until the stop condition is met.
tools/testrunner/log.go:303
↓ 3 callersMethodcollectTestCaseFailures
()
tools/testrunner/junit.go:227
↓ 3 callersFunctioncollectTestNames
(suites []junit.Testsuite)
tools/testrunner/junit_test.go:217
↓ 3 callersMethodcompareMembers
(hosts []*hostInfo)
common/membership/ringpop/service_resolver.go:447
↓ 3 callersMethodcompileSpec
()
service/worker/scheduler/workflow.go:420
↓ 3 callersMethodcompleteWorkflowTask
( env *testcore.TestEnv, tv *testvars.TestVars, task *workflowservice.PollWorkflowTaskQueueResponse, reque
tests/versioning_3_test.go:2327
↓ 3 callersFunctioncompleteWorkflowWithActivities
completeWorkflowWithActivities drives a workflow through a single activity then completes it.
tests/history_node_cleanup_test.go:207
↓ 3 callersMethodcomponentOf
(componentGoType reflect.Type)
chasm/registry.go:224
↓ 3 callersFunctioncomputeConfigScalingGroupsToWCISpec
(scalingGroups map[string]*computepb.ComputeConfigScalingGroup)
service/worker/workerdeployment/compute_util.go:11
↓ 3 callersMethodcomputeEffectiveRPSAndSourceLocked
Computes the effectiveRPS and its source by evaluating all possible rate limit configurations. - If an API-level RPS is configured, effectiveRPS = min
service/matching/ratelimit_manager.go:134
↓ 3 callersFunctionconstructHistoryFilenamePrefix
(namespaceID, workflowID, runID string)
common/archiver/gcloud/util.go:32
↓ 3 callersFunctionconstructTimeBasedSearchKey
(namespaceID, tag string, t time.Time, precision string)
common/archiver/gcloud/util.go:40
↓ 3 callersFunctionconstructVisibilityFilename
(namespace, workflowTypeName, workflowID, runID, tag string, t time.Time)
common/archiver/gcloud/util.go:106
↓ 3 callersFunctionconstructVisibilityFilename
(closeTimestamp time.Time, runID string)
common/archiver/filestore/util.go:172
↓ 3 callersFunctionconvertAttrToField
(attr slog.Attr)
common/log/slog.go:154
↓ 3 callersMethodconvertComparisonExpr
( expr *sqlparser.ComparisonExpr, )
common/persistence/visibility/store/query/converter.go:385
↓ 3 callersFunctionconvertComponentRef
( r R, )
chasm/engine.go:429
↓ 3 callersFunctionconvertFloat
(val any)
common/dynamicconfig/collection.go:606
↓ 3 callersFunctionconvertKeyTypeToString
(v any)
common/dynamicconfig/yaml_loader.go:128
↓ 3 callersMethodconvertPollWorkflowTaskQueueResponse
convertPollWorkflowTaskQueueResponse converts a PollWorkflowTaskQueueResponse to PollWorkflowTaskQueueResponseWithRawHistory. This is used when forwar
service/matching/matching_engine.go:3161
↓ 3 callersMethodconvertServerErr
(err error, msg string)
service/worker/dlq/workflow.go:416
↓ 3 callersFunctionconvertWithCache
(c *Collection, key Key, convert func(any) (T, error), cvp *ConstrainedValue)
common/dynamicconfig/collection.go:549
↓ 3 callersFunctionconvertWorkflowStateReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.SyncWorkflowStateTask, workflow
service/history/replication/raw_task_converter.go:206
↓ 3 callersMethodcountGroupByExecutions
( ctx context.Context, queryParams *esQueryParams, chasmMapper *chasm.VisibilitySearchAttributesMapper, )
common/persistence/visibility/store/elasticsearch/visibility_store.go:500
↓ 3 callersMethodcounterFactory
()
service/matching/physical_task_queue_manager.go:861
↓ 3 callersMethodcreateExecutionStartedStateWithParent
(we *commonpb.WorkflowExecution, tl string, parentInfo *workflowspb.ParentExecutionInfo, identity string, sche
service/history/history_engine2_test.go:1212
↓ 3 callersMethodcreateFirstWorkflowTask
createFirstWorkflowTask is used by StartChildExecution transfer task to create the first workflow task for child execution.
service/history/transfer_queue_active_task_executor.go:1418
↓ 3 callersMethodcreateLongPollContext
(parent context.Context)
client/frontend/client.go:46
↓ 3 callersFunctioncreateMutableState
(t *testing.T, nsEntry *namespace.Namespace, cfg *configs.Config)
service/history/workflow/workflow_test/mutable_state_impl_test.go:199
↓ 3 callersMethodcreateNewBranch
( ctx context.Context, baseBranchToken []byte, baseBranchLastEventID int64, newVersionHistory *historyspb.
service/history/ndc/branch_manager.go:188
↓ 3 callersMethodcreateNewExecutionWithUpdate
( ctx context.Context, shardContext historyi.ShardContext, executionRef chasm.ComponentRef, archetypeID ch
service/history/chasm_engine.go:832
↓ 3 callersFunctioncreateNexusOperationFailure
createNexusOperationFailure creates a NexusOperationExecutionFailure wrapping the given cause.
chasm/lib/workflow/nexus_methods.go:346
↓ 3 callersMethodcreatePartialNamespace
Partial namespace creation is only relevant for Cassandra, the following tests will only run when the underlying cluster is cassandra
common/persistence/persistence-tests/metadata_persistence_v2.go:82
↓ 3 callersMethodcreateSignalWorkflowExecutionRequest
( targetNamespace namespace.Name, task *tasks.SignalExecutionTask, si *persistencespb.SignalInfo, attribut
service/history/transfer_queue_active_task_executor_test.go:3181
↓ 3 callersFunctioncreateStartToCloseTimeoutFailure
()
chasm/lib/activity/activity.go:756
↓ 3 callersMethodcreateTQAndPTQForBacklogTests
()
service/matching/matching_engine_test.go:3604
↓ 3 callersFunctioncreateTestCQLFileContent
()
tools/cassandra/cqlclient_tests.go:58
↓ 3 callersFunctioncreateVersionSet
(buildId string)
service/matching/task_queue_partition_manager_test.go:1315
↓ 3 callersMethodcreateVisibilityRequestBase
( namespaceName namespace.Name, task tasks.Task, mutableState historyi.MutableState, taskQueueName string,
service/history/visibility_queue_task_executor_test.go:810
↓ 3 callersMethodcreateWorkflow
(env *testcore.TestEnv, workflowFn WorkflowFunction)
tests/activity_api_rules_test.go:123
↓ 3 callersFunctionctxWithClientName
ctxWithClientName creates a context with the given client-name set in incoming gRPC metadata and a deadline (required by PollNexusTaskQueue).
service/matching/handler_test.go:54
↓ 3 callersFunctiondeadlineReached
(deadline time.Time)
common/testing/await/require_ctx.go:283
↓ 3 callersFunctiondeadlineSpread
(deadlines []time.Time)
service/matching/matching_engine_test.go:315
↓ 3 callersFunctiondecodeNode
(node *persistencespb.ChasmNode, registry *chasm.Registry)
tools/tdbg/chasm_decoder.go:112
↓ 3 callersFunctiondecodeValueTyped
decodeValueTyped tries to decode to the given type. If the input is a list and allowList is false, then it will return only the first element. If the
common/searchattribute/sadefs/encode_value.go:98
↓ 3 callersMethoddefaultSchedulerOptions
(enabled bool)
common/tasks/execution_aware_scheduler_test.go:385
↓ 3 callersFunctiondefaultTqId
()
service/matching/physical_task_queue_manager_test.go:173
↓ 3 callersMethoddeleteNewBranchWhenError
( ctx context.Context, namespaceID namespace.ID, workflowID string, runID string, archetypeID chasm.Arche
service/history/ndc/workflow_state_replicator.go:643
↓ 3 callersMethoddeleteRedirectRule
deleteRedirectRule deletes the versioning redirect rule at a given index. It checks the response and returns the conflict token.
tests/versioning_test.go:4607
↓ 3 callersMethoddeliverQueryResult
(taskID string, queryResult *queryResult)
service/matching/matching_engine.go:1199
↓ 3 callersFunctiondeserializeGetHistoryToken
(bytes []byte)
common/archiver/gcloud/util.go:66
↓ 3 callersMethoddeserializeToken
( token []byte, defaultLastEventID int64, lastTransactionId int64, )
common/persistence/history_manager.go:1104
↓ 3 callersMethoddial
(hostName string, tlsClientConfig *tls.Config, dialOptions ...grpc.DialOption)
common/rpc/rpc.go:292
↓ 3 callersMethoddialOpts
()
common/telemetry/config.go:177
↓ 3 callersFunctiondiscardChasmSideEffectTask
discardChasmSideEffectTask handles discard of a CHASM side effect task on standby. It first checks if the execution still exists on the source (active
service/history/chasm_task_util.go:92
↓ 3 callersMethoddispatchChildWorkflow
( env *testcore.TestEnv, newVersioning bool, crossTq bool, )
tests/versioning_test.go:2527
↓ 3 callersMethoddispatchContinueAsNew
( env *testcore.TestEnv, newVersioning bool, crossTq bool, )
tests/versioning_test.go:3023
↓ 3 callersFunctiondoNexusHTTPRequest
(t *testing.T, router *mux.Router, endpointID string)
service/frontend/nexus_operation_http_handler_test.go:67
↓ 3 callersMethoddoPollActivityAndHandle
( env *testcore.TestEnv, tv *testvars.TestVars, versioned bool, async chan<- struct{}, handler func(task
tests/versioning_3_test.go:4834
↓ 3 callersMethoddoReconcileInboundStreams
( streamKeys map[ClusterShardKeyPair]struct{}, )
service/history/replication/stream_receiver_monitor.go:247
↓ 3 callersMethoddrainTasks
()
common/tasks/fifo_scheduler.go:217
↓ 3 callersMethodeffectiveUserMetadata
effectiveUserMetadata returns the activity's user metadata, preferring the framework-level ChasmComponentAttributes.user_metadata and falling back to
chasm/lib/activity/activity.go:364
↓ 3 callersFunctionemitCompletionMetrics
( shardContext historyi.ShardContext, namespace *namespace.Namespace, completionMetrics ...completionMetric
service/history/workflow/transaction_impl.go:783
↓ 3 callersMethodemitFinishMetrics
( now time.Time, )
service/history/replication/executable_task.go:350
↓ 3 callersFunctionemitMutableStateStatus
( metricsHandler metrics.Handler, chasmRegistry *chasm.Registry, archetypeID chasm.ArchetypeID, stats *per
service/history/workflow/metrics.go:37
↓ 3 callersFunctionemitMutationMetrics
( shardContext historyi.ShardContext, namespace *namespace.Namespace, archetypeID chasm.ArchetypeID, stats
service/history/workflow/transaction_impl.go:703
↓ 3 callersMethodemitTimeoutMetricScopeWithNamespaceTag
( namespaceID namespace.ID, operation string, timerType enumspb.TimeoutType, effectiveVersioningBehavior e
service/history/timer_queue_active_task_executor.go:981
↓ 3 callersFunctionemitWorkflowCompletionStats
( metricsHandler metrics.Handler, namespace namespace.Name, completion completionMetric, config *configs.C
service/history/workflow/metrics.go:106
↓ 3 callersMethodemitZeroLogicalBacklogForQueue
emitZeroLogicalBacklogForQueue zeroes out logical backlog gauges for a single physical queue to prevent stale values after unloading. Called from: - S
service/matching/task_queue_partition_manager.go:1642
↓ 3 callersMethodencode
()
client/matching/partition_counts.go:31
↓ 3 callersMethodenqueueActivitiesForEachWorkflow
(sets int, tqName string)
tests/task_queue_stats_test.go:1235
↓ 3 callersFunctionensureConfig
(proto *persistencespb.NamespaceConfig)
common/namespace/testconstructors.go:77
↓ 3 callersMethodensureFields
()
service/worker/scheduler/workflow.go:391
↓ 3 callersMethodensureFrontend
()
tests/testcore/clients.go:80
↓ 3 callersFunctionensureInfo
(proto *persistencespb.NamespaceInfo)
common/namespace/testconstructors.go:70
↓ 3 callersMethodensurePredicateSizeLimit
()
service/history/queues/slice.go:470
↓ 3 callersMethodenterSplitBrainStateAndAcceptUpdatesInBothClusters
(ctx context.Context, cluster1UpdateId, cluster2UpdateId string)
tests/xdc/history_replication_signals_and_updates_test.go:533
↓ 3 callersMethodequalHistoryEventsAttributes
( expectedEventsAttributes []map[string]any, actualHistoryEvents []*historypb.HistoryEvent, )
common/testing/historyrequire/history_require.go:367
↓ 3 callersFunctionequalX509
(a, b []*x509.Certificate)
common/rpc/encryption/local_store_cert_provider.go:563
↓ 3 callersMethodeventuallyDeleted
(env *NexusTestEnv, t *testing.T, operationID, runID string)
tests/nexus_standalone_test.go:2290
↓ 3 callersFunctionexecuteChasmSideEffectTask
executeChasmSideEffectTask completes execution of a CHASM side effect task after physical task validation. TODO - ExecuteSideEffectTask doesn't need
service/history/chasm_task_util.go:48
↓ 3 callersMethodexecuteDoomedWorkflow
executeDoomedWorkflow runs a workflow that is guaranteed to produce a workflow task that will be added to the DLQ. It then returns the sdk workflow ru
tests/dlq_test.go:408
↓ 3 callersMethodexecuteNamespaceReplicationTasksUntil
executeNamespaceReplicationTasksUntil executes buffered namespace event replication tasks until the specified event type is encountered with the speci
tests/xdc/history_replication_signals_and_updates_test.go:637
↓ 3 callersMethodexecuteOperationTimeout
executeOperationTimeout is the entry point for the timeout timer tasks: it records the timeout event (recordOperationTimeout) and emits the timeout me
components/nexusoperations/executors.go:635
↓ 3 callersFunctionextractErrorReason
(resp *elastic.BulkResponseItem)
common/persistence/visibility/store/elasticsearch/processor.go:386
↓ 3 callersFunctionextractTestNames
extractTestNames tries to identify Go test function names from a log block. It looks for fully-qualified names like pkg.TestXxx(...) and Go test failu
tools/testrunner/log.go:151
↓ 3 callersMethodfairnessPartitions
fairnessPartitions is the number of read/write partitions used by FairnessSuite.
tests/priority_fairness_test.go:428
↓ 3 callersFunctionfastForwardStartReq
(env *testcore.TestEnv, tv *testvars.TestVars, runTimeout time.Duration, cfg *commonpb.TimeSkippingConfig)
tests/timeskipping_fast_forward_test.go:64
↓ 3 callersMethodfault
(method, err string)
service/matching/matching_engine_test.go:5383
↓ 3 callersFunctionfetchCACert
(pathOrUrl string)
tools/tdbg/factory.go:187
↓ 3 callersFunctionfieldsOf
fieldsOf iterates across all CHASM-managed fields of a struct. Other fields are not yielded. nolint:revive // cognitive complexity 26 (> max enabled
chasm/fields_iterator.go:43
↓ 3 callersFunctionfile_temporal_server_api_archiver_v1_message_proto_rawDescGZIP
()
api/archiver/v1/message.pb.go:397
← previousnext →6,201–6,300 of 43,335, ranked by callers