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 callersFunctionvalidateDescribeActivityExecutionRequest
( req *workflowservice.DescribeActivityExecutionRequest, maxIDLengthLimit int, )
chasm/lib/activity/validator.go:305
↓ 1 callersMethodvalidateDescribeTaskQueueWithDefaultMode
( tqName string, tqType enumspb.TaskQueueType, expectation taskQueueExpectations, singlePartition bool, )
tests/task_queue_stats_test.go:1381
↓ 1 callersMethodvalidateDescribeTaskQueueWithEnhancedMode
( tqName string, tqType enumspb.TaskQueueType, expectation taskQueueExpectations, )
tests/task_queue_stats_test.go:1426
↓ 1 callersMethodvalidateDescribeWorkerDeploymentVersion
( tqName string, tqType enumspb.TaskQueueType, expectation taskQueueExpectations, )
tests/task_queue_stats_test.go:1484
↓ 1 callersFunctionvalidateGetRequest
(request *operatorservice.GetNexusEndpointRequest)
service/frontend/nexus_endpoint_client.go:396
↓ 1 callersFunctionvalidateGetWorkflowExecutionRawHistoryRequest
( request *historyservice.GetWorkflowExecutionRawHistoryRequest, )
service/history/api/getworkflowexecutionrawhistory/api.go:161
↓ 1 callersMethodvalidateGetWorkflowExecutionRawHistoryV2Request
( request *adminservice.GetWorkflowExecutionRawHistoryV2Request, )
service/frontend/admin_handler.go:989
↓ 1 callersMethodvalidateIncomingBatchTask
(incomingTask BatchableTask)
service/history/replication/executable_history_task.go:350
↓ 1 callersMethodvalidateIncomingBatchTask
(incomingTask BatchableTask)
service/history/replication/executable_activity_state_task.go:259
↓ 1 callersFunctionvalidateInterval
(i *schedulepb.IntervalSpec)
service/worker/scheduler/spec.go:232
↓ 1 callersFunctionvalidateIteratorsOrderedDisjoint
( iterators []Iterator, )
service/history/queues/slice.go:496
↓ 1 callersFunctionvalidateMainModule
( ctx context.Context, modFile *modfile.File, mod moduleSpec, )
cmd/tools/check-dependencies/main.go:132
↓ 1 callersFunctionvalidateNamespace
(ctx workflow.Context, nsInfo getNamespaceInfoResult)
service/worker/deletenamespace/workflow.go:83
↓ 1 callersMethodvalidateNamespace
( namespace string, )
service/frontend/workflow_handler.go:6614
↓ 1 callersMethodvalidateNamespaceReplicationTask
(task *replicationspb.NamespaceTaskAttributes)
common/namespace/nsreplication/replication_task_executor.go:338
↓ 1 callersMethodvalidateNoEventsAfterWorkflowFinish
validateNoEventsAfterWorkflowFinish perform check on history event batch NOTE: do not apply this check on every batch, since transient workflow task &
service/history/workflow/mutable_state_impl.go:8632
↓ 1 callersFunctionvalidateNodeChainAndTrim
( tailNodeID int64, tailTransactionID int64, transactionIDToNode map[int64]historyNodeMetadata, )
common/persistence/history_node_util.go:22
↓ 1 callersMethodvalidateOnConflictOptions
(opts *workflowpb.OnConflictOptions)
service/frontend/workflow_handler.go:6291
↓ 1 callersMethodvalidatePageSize
(pageSize int32)
service/frontend/nexus_endpoint_client.go:401
↓ 1 callersFunctionvalidateParams
(params *DeleteNamespaceWorkflowParams)
service/worker/deletenamespace/workflow.go:72
↓ 1 callersFunctionvalidateParams
(params *ReclaimResourcesParams)
service/worker/deletenamespace/reclaimresources/workflow.go:68
↓ 1 callersFunctionvalidateParams
(ctx workflow.Context, params *DeleteExecutionsParams)
service/worker/deletenamespace/deleteexecutions/workflow.go:75
↓ 1 callersFunctionvalidatePauseRequest
(req *workflowservice.PauseWorkflowExecutionRequest, shard historyi.ShardContext)
service/history/api/pauseworkflow/api.go:99
↓ 1 callersFunctionvalidatePollActivityExecutionRequest
( req *workflowservice.PollActivityExecutionRequest, maxIDLengthLimit int, )
chasm/lib/activity/validator.go:331
↓ 1 callersMethodvalidatePollTaskSyncMatch
(buildId string, useVersioning bool)
service/matching/task_queue_partition_manager_test.go:1248
↓ 1 callersFunctionvalidatePostResetOperationInputs
validatePostResetOperationInputs validates the optional post reset operation inputs. Returns parallel slices (one entry per operation) carrying the re
service/history/api/resetworkflow/api.go:246
↓ 1 callersMethodvalidateQuery
()
service/matching/workers/worker_query_engine.go:156
↓ 1 callersFunctionvalidateRejectionMsg
ValidateWorkflowExecutionUpdateRejectionMessage validates the presence of expected fields on updatepb.Rejection messages.
service/history/workflow/update/validation.go:92
↓ 1 callersMethodvalidateRemoteClusterMetadata
(metadata *adminservice.DescribeClusterResponse)
service/frontend/admin_handler.go:1954
↓ 1 callersMethodvalidateRemoteClusterMetadata
(metadata *adminservice.DescribeClusterResponse)
service/frontend/operator_handler.go:753
↓ 1 callersFunctionvalidateReplicateEventsRequest
( historySerializer serialization.Serializer, request *historyservice.ReplicateEventsV2Request, )
service/history/ndc/replication_task.go:413
↓ 1 callersFunctionvalidateReplicationStateUpdate
(existingNamespace *persistence.GetNamespaceResponse, nsUpdateRequest *workflowservice.UpdateNamespaceRequest)
service/frontend/namespace_handler.go:1129
↓ 1 callersFunctionvalidateRequest
(r *VersionCheckRequest)
common/versioninfo/caller.go:78
↓ 1 callersMethodvalidateRequestCancel
( requestCancelInfos map[int64]*persistencespb.RequestCancelInfo, lastEventID int64, )
service/worker/scanner/executions/mutable_state_validator.go:182
↓ 1 callersFunctionvalidateRequestMsg
(updateID string, msg *updatepb.Request)
service/history/workflow/update/validation.go:43
↓ 1 callersFunctionvalidateRequestMsgPrefix
( updateID string, prefix string, msg *updatepb.Request, )
service/history/workflow/update/validation.go:56
↓ 1 callersFunctionvalidateResponse
(r *VersionCheckResponse)
common/versioninfo/caller.go:68
↓ 1 callersFunctionvalidateResponseMsg
(updateID string, msg *updatepb.Response)
service/history/workflow/update/validation.go:80
↓ 1 callersMethodvalidateRetention
( executionInfo *persistencespb.WorkflowExecutionInfo, executionState enumsspb.WorkflowExecutionState, )
service/worker/scanner/executions/mutable_state_validator.go:231
↓ 1 callersMethodvalidateShardId
(shardID int32)
service/history/shard/controller_impl.go:546
↓ 1 callersMethodvalidateSignal
( signalInfos map[int64]*persistencespb.SignalInfo, lastEventID int64, )
service/worker/scanner/executions/mutable_state_validator.go:203
↓ 1 callersMethodvalidateStartResult
( ns *namespace.Namespace, result *nexusrpc.ClientStartOperationResponse[*commonpb.Payload], )
chasm/lib/nexusoperation/operation_tasks.go:287
↓ 1 callersFunctionvalidateStateUpdate
(existingNamespace *persistence.GetNamespaceResponse, nsUpdateRequest *workflowservice.UpdateNamespaceRequest)
service/frontend/namespace_handler.go:1163
↓ 1 callersMethodvalidateStaticConfig
(config *FileBasedClientConfig)
common/dynamicconfig/file_based_client.go:204
↓ 1 callersFunctionvalidateSuiteStruct
(structType reflect.Type)
common/testing/parallelsuite/suite.go:199
↓ 1 callersMethodvalidateSyncState
If routing update time has changed then we want to let the update through.
service/worker/workerdeployment/version_workflow.go:860
↓ 1 callersMethodvalidateTasksOnRoot
(retrier backoff.Retrier)
service/matching/pri_matcher.go:249
↓ 1 callersFunctionvalidateTemporalTls
(temporalTls *TLS)
common/auth/tls_config_helper.go:119
↓ 1 callersMethodvalidateTimer
( timerInfos map[string]*persistencespb.TimerInfo, lastEventID int64, )
service/worker/scanner/executions/mutable_state_validator.go:140
↓ 1 callersMethodvalidateURI
(URI archiver.URI)
common/archiver/gcloud/history_archiver.go:289
↓ 1 callersMethodvalidateURI
(URI archiver.URI)
common/archiver/gcloud/visibility_archiver.go:301
↓ 1 callersFunctionvalidateUnpauseRequest
(req *workflowservice.UnpauseWorkflowExecutionRequest, shard historyi.ShardContext)
service/history/api/unpauseworkflow/api.go:91
↓ 1 callersMethodvalidateValueType
(name string, value any, fieldType enumspb.IndexedValueType)
common/persistence/visibility/store/elasticsearch/query_interceptors.go:169
↓ 1 callersMethodvalidateVersionRuleBuildId
(request *workflowservice.UpdateWorkerVersioningRulesRequest)
service/frontend/workflow_handler.go:6262
↓ 1 callersMethodvalidateVisibilityBusinessIDAlias
(rc *RegistrableComponent)
chasm/registry.go:344
↓ 1 callersFunctionvalidateWorkerTLS
(cfg *config.WorkerTLS)
common/rpc/encryption/tls_factory.go:107
↓ 1 callersFunctionvalidateWorkflowCounts
validateWorkflowCounts ensures the number of deployment and version workflows matches expectations
service/worker/workerdeployment/replaytester/replay_test.go:150
↓ 1 callersMethodvalidateWorkflowExecutionInfo
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, execution *commonpb.W
service/history/workflow/cache/cache.go:398
↓ 1 callersMethodverifyActivityInfos
(expectedMap, actualMap map[int64]*persistencespb.ActivityInfo)
service/history/workflow/mutable_state_impl_test.go:5429
↓ 1 callersMethodverifyChildWorkflow
verifyChildWorkflow describes the childWorkflowID and identifies its parent. It then checks if the current run was derived from that parent by compari
service/history/transfer_queue_active_task_executor.go:1160
↓ 1 callersMethodverifyExecutionInfo
(current, target, origin *persistencespb.WorkflowExecutionInfo)
service/history/workflow/mutable_state_impl_test.go:5474
↓ 1 callersFunctionverifyForwardingMetrics
(t *testing.T, capture *testcore.NamespaceMetricCapture, expectTaskForwarded bool, expectPollForwarded bool)
tests/nexus_matching_test.go:164
↓ 1 callersFunctionverifyMutableStateChecksum
( ms historyi.MutableState, csum *persistencespb.Checksum, )
service/history/workflow/checksum.go:27
↓ 1 callersMethodverifyNamespaceActive
( creationParams *creationParams, currentWorkflowConditionFailed *persistence.CurrentWorkflowConditionFailed
service/history/api/startworkflow/api.go:394
↓ 1 callersMethodverifyNumTasks
verifyNumTasks verifies that the specified file contains the expected number of DLQ tasks, and that each task has the expected metadata and payload.
tests/dlq_test.go:587
↓ 1 callersMethodverifyOwnershipLocked
(ctx context.Context)
service/matching/db.go:316
↓ 1 callersMethodverifyPendingTaskSize
()
service/history/queues/reader.go:530
↓ 1 callersFunctionverifyPersistenceCompatibleVersion
( cfg config.Persistence, persistenceServiceResolver resolver.ServiceResolver, logger log.Logger, )
temporal/fx.go:912
↓ 1 callersMethodverifyRoutingConfig
(expected, actual *deploymentpb.RoutingConfig, deploymentName string)
tests/worker_deployment_test.go:3292
↓ 1 callersMethodverifySpeculativeTask
Verify this is a speculative task - events not yet in persisted history
tests/versioning_3_test.go:3514
↓ 1 callersMethodverifyWorkerDeploymentSummary
( expectedSummary *workflowservice.ListWorkerDeploymentsResponse_WorkerDeploymentSummary, actualSummary *wor
tests/worker_deployment_test.go:3539
↓ 1 callersMethodversionCheckLoop
( ctx context.Context, )
service/frontend/version_checker.go:70
↓ 1 callersMethodversionDataToSync
()
service/worker/workerdeployment/version_workflow.go:855
↓ 1 callersFunctionversionStateToVersionInfo
nolint:staticcheck
service/worker/workerdeployment/client.go:1654
↓ 1 callersMethodversionedNexusTaskPollerDo
(ctx context.Context, t *testing.T, taskQueue, buildID string, handler nexusTaskHandler)
tests/nexus_test_base.go:124
↓ 1 callersFunctionvisibilityChasmTaskFromProto
(task *persistencespb.VisibilityTaskInfo)
common/persistence/serialization/task_serializers.go:1174
↓ 1 callersFunctionvisibilityChasmTaskToProto
(task *tasks.ChasmTask)
common/persistence/serialization/task_serializers.go:1160
↓ 1 callersFunctionvisibilityCloseTaskFromProto
( closeVisibilityTask *persistencespb.VisibilityTaskInfo, )
common/persistence/serialization/task_serializers.go:1104
↓ 1 callersFunctionvisibilityCloseTaskToProto
( closetVisibilityTask *tasks.CloseExecutionVisibilityTask, )
common/persistence/serialization/task_serializers.go:1090
↓ 1 callersFunctionvisibilityDeleteTaskFromProto
( deleteVisibilityTask *persistencespb.VisibilityTaskInfo, )
common/persistence/serialization/task_serializers.go:1141
↓ 1 callersFunctionvisibilityDeleteTaskToProto
( deleteVisibilityTask *tasks.DeleteExecutionVisibilityTask, )
common/persistence/serialization/task_serializers.go:1119
↓ 1 callersFunctionvisibilityStartTaskFromProto
( startVisibilityTask *persistencespb.VisibilityTaskInfo, )
common/persistence/serialization/task_serializers.go:1048
↓ 1 callersFunctionvisibilityStartTaskToProto
( startVisibilityTask *tasks.StartExecutionVisibilityTask, )
common/persistence/serialization/task_serializers.go:1034
↓ 1 callersFunctionvisibilityUpsertTaskFromProto
( upsertVisibilityTask *persistencespb.VisibilityTaskInfo, )
common/persistence/serialization/task_serializers.go:1076
↓ 1 callersFunctionvisibilityUpsertTaskToProto
( upsertVisibilityTask *tasks.UpsertExecutionVisibilityTask, )
common/persistence/serialization/task_serializers.go:1063
↓ 1 callersFunctionvisibilityValueFromPayload
visibilityValueFromPayload decoded payload based on type set in its metadata.
chasm/visibility_value.go:156
↓ 1 callersMethodvisitor
(path ...string)
tools/testrunner/junit.go:355
↓ 1 callersMethodwait
(task T)
common/tasks/rate_limited_scheduler.go:83
↓ 1 callersMethodwaitForChannel
(ctx context.Context, ch chan struct{})
tests/xdc/activity_api_test.go:270
↓ 1 callersMethodwaitForClusterConnected
( sourceCluster *testcore.TestCluster, targetClusterName string, )
tests/xdc/base.go:177
↓ 1 callersFunctionwaitForClusterFormation
waitForClusterFormation waits until the server's reachable members include all membership ports from all provided port sets, confirming the servers di
tests/mixedbrain/server_util.go:132
↓ 1 callersMethodwaitForNSReplication
waitForNSReplication blocks until the namespace has been replicated. We want to do this because replication tasks will get dropped if the namespace do
tests/xdc/history_replication_dlq_test.go:341
↓ 1 callersMethodwaitForNewRunToStart
( client workflowservice.WorkflowServiceClient, namespace string, execution *commonpb.WorkflowExecution, )
tests/xdc/failover_test.go:1753
↓ 1 callersMethodwaitForRateLimiterPermission
(req *schedulespb.StartWorkflowRequest)
service/worker/scheduler/activities.go:89
↓ 1 callersMethodwaitNamespaceHandoverUpdate
( ctx context.Context, namespaceName namespace.Name, methodName string, )
common/rpc/interceptor/namespace_handover.go:117
↓ 1 callersMethodwaitOperationRetry
( ctx context.Context, sdkClient sdkclient.Client, run sdkclient.WorkflowRun, )
tests/xdc/nexus_state_replication_test.go:686
↓ 1 callersMethodwaitSchemaAgreement
waitSchemaAgreement wait for schema change agreements
tools/cassandra/cqlclient.go:296
↓ 1 callersMethodwaitUntilNamespaceReplicated
( ctx context.Context, namespaceName string, )
tests/xdc/stream_based_replication_test.go:262
↓ 1 callersMethodwaitUntilReplicationTasksAreInDLQ
This method blocks until the DLQ has received replication tasks which cover all the provided history events.
tests/xdc/history_replication_dlq_test.go:311
↓ 1 callersMethodwaitUntilWorkflowVerified
waitUntilWorkflowVerified waits until the workflow with the given ID has been replicated to the standby cluster. It does this by waiting for the repli
tests/xdc/history_replication_dlq_test.go:407
← previousnext →13,401–13,500 of 43,335, ranked by callers