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 callersMethodvalidate
(rc *RegistrableComponent)
chasm/registry.go:286
↓ 3 callersMethodvalidateAndPopulateStartRequest
( ctx context.Context, req *workflowservice.StartActivityExecutionRequest, namespaceID namespace.ID, )
chasm/lib/activity/frontend.go:356
↓ 3 callersFunctionvalidateBlobSize
( activityID string, blobSizeViolationTagValue string, blobSizeLimitError dynamicconfig.IntPropertyFnWithNa
chasm/lib/activity/validator.go:254
↓ 3 callersMethodvalidateBuildIDAfterReset
assumes given run has a single activity task.
tests/versioning_test.go:3886
↓ 3 callersMethodvalidateCompletionState
( completionState *historyi.QueryCompletionState, )
service/history/workflow/query.go:88
↓ 3 callersMethodvalidateCreateRequest
( request *persistence.CreateWorkflowExecutionRequest, expectedArchetypeID chasm.ArchetypeID, expectedActiv
service/history/chasm_engine_test.go:588
↓ 3 callersFunctionvalidateDirPath
Validation
common/archiver/filestore/util.go:182
↓ 3 callersMethodvalidateKey
(key EventKey)
service/history/events/cache.go:97
↓ 3 callersMethodvalidateName
(n string)
chasm/registry.go:334
↓ 3 callersFunctionvalidateSetupConfig
(config *SetupConfig, db DB)
tools/common/schema/handler.go:57
↓ 3 callersMethodvalidateSlicesOrdered
( reader Reader, )
service/history/queues/reader_test.go:494
↓ 3 callersMethodvalidateStateMachineRef
validateStateMachineRef compares the ref and associated state machine's version and transition count to detect staleness.
service/history/statemachine_environment.go:223
↓ 3 callersMethodvalidateStateMachineRefWithoutTransitionHistory
(ms historyi.MutableState, ref hsm.Ref, potentialStaleState bool)
service/history/statemachine_environment.go:291
↓ 3 callersMethodvalidateTLSInfo
(tlsInfo *credentials.TLSInfo, err error, serialNumber int64)
common/rpc/test/rpc_localstore_tls_test.go:626
↓ 3 callersFunctionvalidateTaskByClock
( shardContext historyi.ShardContext, task tasks.Task, )
service/history/ndc_task_util.go:209
↓ 3 callersFunctionvalidateTaskGeneration
( ctx context.Context, shardContext historyi.ShardContext, workflowContext historyi.WorkflowContext, mutab
service/history/ndc_task_util.go:235
↓ 3 callersFunctionvalidateTaskHighWaterMark
validateTaskHighWaterMark validates a component's lastProcessedTime against a task timestamp. A task is valid if its scheduled time is after the high
chasm/lib/scheduler/util.go:69
↓ 3 callersFunctionvalidateUpdateConfig
(config *UpdateConfig, db DB)
tools/common/schema/handler.go:86
↓ 3 callersMethodvalidateUpdateExecutionRequestWithSignalExternalFailedEvent
( signalInitiatedEventId int64, expectedFailedCause enumspb.SignalExternalWorkflowExecutionFailedCause, req
service/history/transfer_queue_active_task_executor_test.go:2026
↓ 3 callersFunctionvalidateVersionAndGetReactivationEligibility
(ctx context.Context, pinnedVersion *deploymentpb.WorkerDeploymentVersion, matchingClient resource.MatchingC
common/worker_versioning/worker_versioning.go:697
↓ 3 callersMethodvalueFields
()
chasm/tree.go:698
↓ 3 callersMethodverifyNewRunExist
(ctx context.Context)
service/history/replication/executable_verify_versioned_transition_task.go:206
↓ 3 callersMethodverifyTransientTask
(task *workflowservice.PollWorkflowTaskQueueResponse)
tests/versioning_3_test.go:3530
↓ 3 callersMethodverifyWorkerDeploymentInfo
(expected, actual *deploymentpb.WorkerDeploymentInfo)
tests/worker_deployment_test.go:3307
↓ 3 callersFunctionversionStateToSummary
(s *deploymentspb.VersionLocalState)
service/worker/workerdeployment/version_workflow.go:1060
↓ 3 callersMethodversionedNexusTaskPoller
(ctx context.Context, t *testing.T, taskQueue, buildID string, handler nexusTaskHandler)
tests/nexus_test_base.go:116
↓ 3 callersMethodwaitForDeploymentDataPropagationQueryWorkerDeployment
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/versioning_3_test.go:4220
↓ 3 callersFunctionwaitForMutableStateGone
waitForMutableStateGone polls until GetWorkflowExecution returns NotFound for the given runID.
tests/history_node_cleanup_test.go:264
↓ 3 callersMethodwaitForPollers
(n int)
service/matching/matcher_data_test.go:134
↓ 3 callersMethodwaitForPollers
(env *testcore.TestEnv, tv *testvars.TestVars, moreExpectedVersions ...*testvars.TestVars)
tests/worker_deployment_version_test.go:748
↓ 3 callersMethodwaitForTasks
(n int)
service/matching/matcher_data_test.go:142
↓ 3 callersMethodwaitForVisibilityCount
waitForVisibilityCount waits for the visibility store to index the expected number of workflow executions in the given namespace before proceeding. Th
tests/xdc/base.go:467
↓ 3 callersMethodwaitForWorkflowBuildID
Periodically checks a WF and unblocks when it is assigned to the given build ID
tests/versioning_test.go:5034
↓ 3 callersMethodwaitUntilFirstWorkflowTaskCompleted
waitUntilFirstWorkflowTaskCompleted waits until the workflow is RUNNING and has completed its first workflow task (so a workflow without an activity i
tests/pause_workflow_execution_test.go:1805
↓ 3 callersMethodwarnf
(format string, args ...any)
common/dynamicconfig/yaml_loader.go:116
↓ 3 callersFunctionwithFairPrefix
(name string)
service/matching/pri_metrics_handler.go:145
↓ 3 callersFunctionwithPriPrefix
(name string)
service/matching/pri_metrics_handler.go:93
↓ 3 callersFunctionwithWorkerService
(enabled bool)
tests/testcore/functional_test_base.go:167
↓ 3 callersFunctionworkflowExecutionStateFromCurrentExecutionsRow
( serializer serialization.Serializer, row *sqlplugin.CurrentExecutionsRow, )
common/persistence/sql/execution_util.go:1209
↓ 3 callersMethodworkflowFunc
(ctx workflow.Context, activityFunc func() (string, error))
tests/activity_api_rules_test.go:65
↓ 3 callersMethodworkflowIsArchived
workflowIsArchived asserts that both the workflow history and workflow visibility are archived.
tests/archival_test.go:308
↓ 3 callersFunctionworkflowListFilterType
WorkflowListFilterType returns tag for WorkflowListFilterType
common/log/tag/tags.go:77
↓ 3 callersFunctionworkflowTagGetters
nolint:revive // cognitive complexity 37 (> max enabled 25)
cmd/tools/genrpcserverinterceptors/main.go:118
↓ 3 callersFunctionwriteAttemptFailure
(b *strings.Builder, f attemptFailure)
common/testing/await/report.go:82
↓ 3 callersMethodwriteCurrentReport
writeCurrentReport writes the merged report from all completed attempts to the final output path. It is called after each attempt so that partial resu
tools/testrunner/testrunner.go:303
↓ 3 callersMethodwriteLogLocked
writeLogLocked appends a structured record to the output log. Callers must hold s.mu.
tools/tdbg/commands.go:1222
↓ 2 callersMethodActivityInfoToBlob
(info *persistencespb.ActivityInfo)
common/persistence/serialization/serializer.go:44
↓ 2 callersMethodAddActivityTask
AddActivityTask is called by the history service when a workflow task is scheduled, so that it can be dispatched by the MatchingEngine.
api/matchingservice/v1/service_grpc.pb.go:81
↓ 2 callersMethodAddBulkRequestAndWait
( _ context.Context, bulkRequest *client.BulkableRequest, visibilityTaskKey string, )
common/persistence/visibility/store/elasticsearch/visibility_store.go:327
↓ 2 callersFunctionAddCompatibleRedirectRule
(timestamp *hlc.Clock, data *persistencespb.VersioningData, req *workflowservice.UpdateWorkerVersioningRules
service/matching/version_rule_helpers.go:157
↓ 2 callersFunctionAddDeleteExecutionTask
AddDeleteExecutionTask creates a DeleteExecutionTask and adds it to the shard's task queue. This is a package-level function so it can be used by call
service/history/deletemanager/delete_manager.go:90
↓ 2 callersMethodAddMarkerRecordedEvent
( workflowTaskCompletedEventID int64, command *commandpb.RecordMarkerCommandAttributes, )
service/history/historybuilder/history_builder.go:739
↓ 2 callersFunctionAddRoutingKeyToContext
AddRoutingKeyToContext adds the routing Key to the context
common/rpc/interceptor/routing_key_interceptor.go:125
↓ 2 callersMethodAddTasks
(ctx context.Context, in *AddTasksRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:154
↓ 2 callersMethodAddTasks
The AddTasks API is used to add history tasks to a shard. The first use-case for this API is the DLQ. When we are unable to process history tasks, we
api/historyservice/v1/service_grpc.pb.go:311
↓ 2 callersMethodAddWorkflowExecutionStartedEvent
AddWorkflowExecutionStartedEvent firstInChainRunID is the runID of the first run in a workflow chain (continueAsNew, cron & workflow retry) originalRu
service/history/historybuilder/history_builder.go:163
↓ 2 callersMethodAddWorkflowExecutionStartedEventWithOptions
( execution *commonpb.WorkflowExecution, startRequest *historyservice.StartWorkflowExecutionRequest, resetP
service/history/workflow/mutable_state_impl.go:2893
↓ 2 callersMethodAddWorkflowTask
AddWorkflowTask is called by the history service when a workflow task is scheduled, so that it can be dispatched by the MatchingEngine.
api/matchingservice/v1/service_grpc.pb.go:78
↓ 2 callersMethodAddWorkflowTaskScheduleToStartTimeoutEvent
(workflowTask *WorkflowTaskInfo)
service/history/interfaces/mutable_state.go:78
↓ 2 callersFunctionAddresses
Addresses returns tag for Addresses
common/log/tag/tags.go:426
↓ 2 callersMethodAlertCh
()
service/history/queues/monitor.go:41
↓ 2 callersMethodAllocateEventID
()
service/history/historybuilder/event_store.go:58
↓ 2 callersMethodAllocateSubqueue
( ctx context.Context, key *persistencespb.SubqueueKey, )
service/matching/db.go:768
↓ 2 callersMethodAppendSlices
(...Slice)
service/history/queues/reader.go:32
↓ 2 callersMethodApplyActivityTaskCancelRequestedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:241
↓ 2 callersMethodApplyActivityTaskCanceledEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:242
↓ 2 callersMethodApplyActivityTaskCompletedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:243
↓ 2 callersMethodApplyActivityTaskFailedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:244
↓ 2 callersMethodApplyActivityTaskStartedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4431
↓ 2 callersMethodApplyActivityTaskTimedOutEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:247
↓ 2 callersMethodApplyChildWorkflowExecutionCanceledEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:248
↓ 2 callersMethodApplyChildWorkflowExecutionCompletedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:249
↓ 2 callersMethodApplyChildWorkflowExecutionFailedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:250
↓ 2 callersMethodApplyChildWorkflowExecutionStartedEvent
(*historypb.HistoryEvent, *clockspb.VectorClock)
service/history/interfaces/mutable_state.go:251
↓ 2 callersMethodApplyChildWorkflowExecutionTerminatedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:252
↓ 2 callersMethodApplyChildWorkflowExecutionTimedOutEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:253
↓ 2 callersMethodApplyExternalWorkflowExecutionCancelRequested
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:259
↓ 2 callersMethodApplyExternalWorkflowExecutionSignaled
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:260
↓ 2 callersMethodApplyRequestCancelExternalWorkflowExecutionFailedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:261
↓ 2 callersMethodApplyRequestCancelExternalWorkflowExecutionInitiatedEvent
(int64, *historypb.HistoryEvent, string)
service/history/interfaces/mutable_state.go:262
↓ 2 callersMethodApplySignalExternalWorkflowExecutionFailedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:263
↓ 2 callersMethodApplySignalExternalWorkflowExecutionInitiatedEvent
(int64, *historypb.HistoryEvent, string)
service/history/interfaces/mutable_state.go:264
↓ 2 callersMethodApplyStartChildWorkflowExecutionFailedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:265
↓ 2 callersMethodApplyTaskQueueUserDataReplicationEvent
Apply a user data replication event.
api/matchingservice/v1/service_grpc.pb.go:150
↓ 2 callersFunctionApplyTestClusterOptions
(options []TestClusterOption)
tests/testcore/functional_test_base.go:412
↓ 2 callersMethodApplyTimerCanceledEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:267
↓ 2 callersMethodApplyTimerFiredEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:268
↓ 2 callersMethodApplyTimerStartedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:269
↓ 2 callersMethodApplyUpsertWorkflowSearchAttributesEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:272
↓ 2 callersMethodApplyWorkflowExecutionCancelRequestedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:273
↓ 2 callersMethodApplyWorkflowExecutionCanceledEvent
(int64, *historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:274
↓ 2 callersMethodApplyWorkflowExecutionUpdateAcceptedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:283
↓ 2 callersMethodApplyWorkflowExecutionUpdateCompletedEvent
(event *historypb.HistoryEvent, batchID int64)
service/history/interfaces/mutable_state.go:284
↓ 2 callersMethodApplyWorkflowPropertiesModifiedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:271
↓ 2 callersMethodApplyWorkflowTaskTimedOutEvent
(timeoutType enumspb.TimeoutType)
service/history/workflow/workflow_task_state_machine.go:260
↓ 2 callersMethodApproximateMaxPropagationTime
ApproximateMaxPropagationTime returns an approximate upper bound on propagation time for updates to membership information. This is _not_ a guarantee!
common/membership/interfaces.go:64
↓ 2 callersFunctionArchivalRequestBranchToken
ArchivalRequestBranchToken returns tag for RequestBranchToken
common/log/tag/tags.go:871
↓ 2 callersFunctionArchivalRequestCloseFailoverVersion
ArchivalRequestCloseFailoverVersion returns tag for RequestCloseFailoverVersion
common/log/tag/tags.go:881
↓ 2 callersMethodArchivalTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:101
↓ 2 callersMethodAttempt
()
service/history/replication/executable_task.go:284
← previousnext →6,701–6,800 of 43,335, ranked by callers