MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 10 callersMethodWaitForHistory
(expectedHistory string, actualHistoryReader HistoryReader, waitFor time.Duration, tick time.Duration)
common/testing/historyrequire/history_require.go:227
↓ 10 callersMethodWithActivityIDNumber
(n int)
common/testing/testvars/test_vars.go:352
↓ 10 callersFunctionWithBusinessIDPolicy
WithBusinessIDPolicy sets the businessID reuse and conflict policy used in the transition when creating a new execution. This option only applies to S
chasm/engine.go:155
↓ 10 callersMethodWithDeploymentSeriesNumber
[cleanup-wv-pre-release]
common/testing/testvars/test_vars.go:236
↓ 10 callersFunctionWithNotificationVersion
WithNotificationVersion assigns a notification version to the Namespace.
common/namespace/mutate.go:53
↓ 10 callersFunctionWorkflowType
WorkflowType returns tag for WorkflowType
common/log/tag/tags.go:115
↓ 10 callersMethodaddCompatibleBuildID
addCompatibleBuildID updates build ID info on a task queue with a new compatible build ID.
tests/versioning_test.go:4866
↓ 10 callersFunctionaddTimerStartedEvent
(ms historyi.MutableState, workflowTaskCompletedEventID int64, timerID string, timeout time.Duration)
service/history/history_engine_test.go:6808
↓ 10 callersFunctionallow
( ctx context.Context, api string, rateLimiter quotas.RequestRateLimiter, )
common/persistence/visibility/visibility_manager_rate_limited.go:170
↓ 10 callersFunctionappendError
(aggregatedErr error, err error)
common/rpc/encryption/local_store_cert_provider.go:489
↓ 10 callersMethodassertDirectoryExists
(path string)
common/archiver/filestore/util_test.go:419
↓ 10 callersFunctionassertResponseIsNil
(t *testing.T, response *schedulespb.WatchWorkflowResponse)
service/worker/scheduler/responsebuilder_test.go:277
↓ 10 callersMethodcheckSequenceFull
(jitterSeed string, spec *schedulepb.ScheduleSpec, start time.Time, seq ...time.Time)
service/worker/scheduler/spec_test.go:41
↓ 10 callersMethodconvertKeysToTasks
( keysByCategory map[tasks.Category][]tasks.Key, )
service/history/shard/task_request_tracker_test.go:160
↓ 10 callersMethodcreateExecutionStartedState
(we *commonpb.WorkflowExecution, tl string, identity string, scheduleWorkflowTask bool, startWorkflowTask bool
service/history/history_engine2_test.go:1208
↓ 10 callersMethodcreateTaskQueue
( rangeID int64, taskQueueKind enumspb.TaskQueueKind, )
common/persistence/tests/task_queue.go:234
↓ 10 callersMethodcreateVersionedMutableStateWithCompletedWFT
creates a mutable state with first WFT completed on Build ID "b1"
service/history/workflow/mutable_state_impl_test.go:653
↓ 10 callersFunctiondefaultConfig
()
chasm/lib/scheduler/helper_test.go:68
↓ 10 callersMethoddelay
()
service/matching/matching_engine_test.go:5369
↓ 10 callersFunctiondurationNear
(t *testing.T, value, target time.Duration)
tests/schedule_test.go:3080
↓ 10 callersMethodfailWorkflowTaskOnInvalidArgument
( wtFailedCause enumspb.WorkflowTaskFailedCause, err error, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1543
↓ 10 callersFunctionfile_temporal_server_api_errordetails_v1_message_proto_rawDescGZIP
()
api/errordetails/v1/message.pb.go:593
↓ 10 callersFunctionfile_temporal_server_api_persistence_v1_hsm_proto_rawDescGZIP
()
api/persistence/v1/hsm.pb.go:849
↓ 10 callersFunctionfile_temporal_server_api_persistence_v1_queues_proto_rawDescGZIP
()
api/persistence/v1/queues.pb.go:573
↓ 10 callersMethodget
(count int)
service/worker/scanner/taskqueue/mocks_test.go:116
↓ 10 callersMethodgetBacklogAge
getBacklogAge is the latest age across all backlogs re-directing to this matcher; may momentarily be 0 cause of race conditions when no reader pushes
service/matching/matcher.go:592
↓ 10 callersFunctiongetOrDefaultLimit
(limit T)
service/frontend/fx_test.go:833
↓ 10 callersMethodhandleOperationFailure
handleOperationFailure handles operation failures, optionally failing silently
tools/elasticsearch/tasks.go:203
↓ 10 callersMethodinterceptRequest
( ctx context.Context, request *matchingservice.DispatchNexusTaskRequest, header nexus.Header, )
service/frontend/nexus_handler.go:159
↓ 10 callersFunctionisJSONArray
(str string)
common/searchattribute/stringify.go:174
↓ 10 callersFunctionmakeCrossNamespaceCommand
Helper to create a cross-namespace command
common/authorization/interceptor_test.go:288
↓ 10 callersMethodmakePinnedOverride
(tv *testvars.TestVars)
tests/worker_deployment_version_test.go:2832
↓ 10 callersFunctionmergeFairnessWeightOverrides
( existing fairnessWeightOverrides, set fairnessWeightOverrides, unset []string, maxFairnessKeyWeightOverr
service/matching/fairness_util.go:43
↓ 10 callersFunctionmkSet
(setID string, buildIDs ...*persistencespb.BuildId)
service/matching/version_sets_merge_test.go:30
↓ 10 callersFunctionmustParent
(tn *tqid.NormalPartition, n int)
service/matching/forwarder_test.go:509
↓ 10 callersFunctionmustToPayload
(t *testing.T, input any)
chasm/lib/nexusoperation/tasks_test_helpers_test.go:33
↓ 10 callersMethodnewActivities
()
service/worker/scanner/scheduleinvariants/invariants_test.go:60
↓ 10 callersFunctionnewHostInfo
newHostInfo creates a new *hostInfo instance
common/membership/ringpop/hostinfo.go:25
↓ 10 callersMethodnewRandomQueueMetadataRow
( queueType persistence.QueueType, )
common/persistence/sql/sqlplugin/tests/queue_metadata.go:179
↓ 10 callersFunctionnewSAColName
( dbColName string, alias string, fieldName string, valueType enumspb.IndexedValueType, )
common/persistence/visibility/store/sql/query_converter_util_legacy.go:74
↓ 10 callersMethodnewSimpleCallerWF
newSimpleCallerWF returns a caller workflow that executes a nexus operation targeting childWfID and returns the string result.
tests/nexus_workflow_update_test.go:194
↓ 10 callersMethodnewTaskExecutable
( task tasks.Task, )
service/history/visibility_queue_task_executor_test.go:938
↓ 10 callersFunctionnewTaskQueuePartitionManager
( e *matchingEngineImpl, ns *namespace.Namespace, partition tqid.Partition, tqConfig *taskQueueConfig, lo
service/matching/task_queue_partition_manager.go:123
↓ 10 callersFunctionnewTestCache
(t *testing.T)
client/matching/partition_counts_test.go:32
↓ 10 callersMethodnow
()
service/worker/scheduler/workflow.go:438
↓ 10 callersMethodnow
()
service/matching/matcher_data_test.go:55
↓ 10 callersMethodnow
()
common/persistence/sql/sqlplugin/tests/history_timer_task.go:331
↓ 10 callersMethodpollActivityTaskQueue
(ctx context.Context, taskQueue string)
tests/activity_standalone_test.go:6151
↓ 10 callersFunctionprocessTask
( ctx context.Context, limiter quotas.RequestRateLimiter, task task, procFn func(*workflowpb.WorkflowExecu
service/worker/batcher/activities.go:764
↓ 10 callersFunctionreapplyEvents
( ctx context.Context, mutableState historyi.MutableState, targetBranchUpdateRegistry update.Registry, sta
service/history/ndc/workflow_resetter.go:841
↓ 10 callersMethodrecord
record marks that a dedicated-cluster-only feature was used, satisfying the guard.
tests/testcore/test_env.go:661
↓ 10 callersFunctionrequireNotStartedButRunning
(t *testing.T, resp *workflowservice.StartWorkflowExecutionResponse)
tests/workflow_test.go:1922
↓ 10 callersFunctionrunTestServerTest
(s *suite.Suite, host string, serverFactory *TestFactory, clientFactory *TestFactory, isValid bool)
common/rpc/test/rpc_common_test.go:101
↓ 10 callersFunctionsampleCompactHistory
sampleCompactHistory is used in almost every test.
common/testing/historyrequire/history_require_test.go:14
↓ 10 callersMethodscheduleAndGetSWSResult
scheduleAndGetSWSResult dispatches a SignalWithStartWorkflowExecution Nexus operation from within a fresh caller workflow via the __temporal_system en
tests/signal_with_start_from_workflow_test.go:83
↓ 10 callersMethodscheduleCompletedWFTForBatchIDTest
scheduleCompletedWFTForBatchIDTest puts the suite's mutable state into a configuration where the next Add*Event call lands in its own size-rolled batc
service/history/workflow/mutable_state_impl_test.go:9094
↓ 10 callersMethodsendCatchUp
(priority enumsspb.TaskPriority)
service/history/replication/stream_sender.go:362
↓ 10 callersMethodsetStateChanged
()
service/worker/workerdeployment/workflow.go:1753
↓ 10 callersFunctionswitchTasksTable
switchTasksTable switches table names from tasks to tasks_v2 and modifies queries for v2 schema
common/persistence/cassandra/matching_task_store_queue.go:29
↓ 10 callersMethodsyncSubComponents
syncSubComponents syncs the entire tree recursively (starting from the root node n) from the underlining component value: - Create: -- if child node i
chasm/tree.go:861
↓ 10 callersMethodtagScope
(operation string)
common/persistence/visibility/visiblity_manager_metrics.go:209
↓ 10 callersFunctiontaskQueueIdAndHash
Returns the persistence task queue id and a uint32 hash for a task queue.
common/persistence/sql/task_util.go:43
↓ 10 callersMethodtransition
(request contextRequest)
service/history/shard/context_impl.go:1551
↓ 10 callersMethodupdateErrorMetric
(handler metrics.Handler, err error)
common/persistence/visibility/visiblity_manager_metrics.go:215
↓ 10 callersMethodupdateVersioningOverride
( env *testcore.TestEnv, execution *commonpb.WorkflowExecution, override *workflowpb.VersioningOverride, )
tests/versioning_3_test.go:2298
↓ 10 callersFunctionupdateWorkflow
update updates an already existing deployment version/deployment workflow.
service/worker/workerdeployment/util.go:202
↓ 10 callersMethodusingTaskqueuePartition
(taskType enumspb.TaskQueueType)
service/matching/forwarder_test.go:493
↓ 10 callersFunctionvalidateFairnessWeightUpdate
( set map[string]float32, unset []string, maxConfigLimit int, )
service/frontend/validators.go:50
↓ 10 callersMethodverifyEventHistorySize
( workflowID string, runID string, historySize int64, )
tests/ndc/ndc_test.go:2298
↓ 9 callersMethodAddChildWorkflowExecutionCompletedEvent
(int64, *commonpb.WorkflowExecution, *historypb.WorkflowExecutionCompletedEventAttributes)
service/history/interfaces/mutable_state.go:69
↓ 9 callersMethodAddSpooledTask
(task *internalTask)
service/matching/physical_task_queue_manager_interface.go:49
↓ 9 callersMethodAddWorkflowTaskTimedOutEvent
(workflowTask *WorkflowTaskInfo)
service/history/interfaces/mutable_state.go:83
↓ 9 callersMethodAfterFunc
AfterFunc return a timer that will fire after the specified duration. It is important to note that the timeSource is locked while the callback is call
common/clock/event_time_source.go:73
↓ 9 callersFunctionAllocListenAddress
()
common/nexus/nexustest/server.go:17
↓ 9 callersMethodAllow
()
common/quotas/clocked_rate_limiter.go:35
↓ 9 callersMethodApplyEvents
( ctx context.Context, request *historyservice.ReplicateEventsV2Request, )
service/history/ndc/history_replicator.go:79
↓ 9 callersFunctionAttachDecorator
AttachDecorator applies decorator to the test-scoped context once for key. Reusing the same key is a no-op. If the test context does not exist yet, At
common/testing/testcontext/context.go:82
↓ 9 callersFunctionCacheTypeTag
(value string)
common/metrics/tags.go:446
↓ 9 callersMethodCheckTaskQueueUserDataPropagation
(ctx context.Context, request *matchingservice.CheckTaskQueueUserDataPropagationRequest)
service/matching/matching_engine_interfaces.go:37
↓ 9 callersMethodCloseSend
()
service/history/replication/bi_direction_stream.go:37
↓ 9 callersMethodComponentByID
ComponentByID returns the registrable component for a given archetype ID. This method should only be used by CHASM framework internal code, NOT CHASM
chasm/registry.go:136
↓ 9 callersFunctionContextMetadataGetMarkedActivityIDs
ContextMetadataGetMarkedActivityIDs returns the marked activity IDs from the context.
common/contextutil/metadata.go:101
↓ 9 callersFunctionContextWithTimeout
( ctx context.Context, timeout time.Duration, timeSource TimeSource, )
common/clock/context.go:68
↓ 9 callersMethodContinueAsNewMinBackoff
ContinueAsNewMinBackoff calculate minimal backoff for next ContinueAsNew run. Input backoffDuration is current backoff for next run. If current backof
service/history/interfaces/mutable_state.go:354
↓ 9 callersMethodData
Data gets the data for a given state machine ID.
service/history/hsm/tree.go:689
↓ 9 callersFunctionDecodeClusterShardMD
( getter headers.HeaderGetter, )
client/history/metadata.go:37
↓ 9 callersFunctionDecodeKeywordList
(value *commonpb.Payload)
common/searchattribute/sadefs/encode_value.go:137
↓ 9 callersMethodDeleteMessageFromDLQ
(ctx context.Context, messageID int64)
common/persistence/persistence_interface.go:181
↓ 9 callersMethodDeleteNamespaceByName
(ctx context.Context, request *DeleteNamespaceByNameRequest)
common/persistence/data_interfaces.go:1224
↓ 9 callersMethodDeleteNexusOperationExecution
(context.Context, *workflowservice.DeleteNexusOperationExecutionRequest)
chasm/lib/nexusoperation/frontend.go:31
↓ 9 callersMethodDeserialize
(taskCategoryID int, blob *commonpb.DataBlob)
tools/tdbg/task_encoder.go:33
↓ 9 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
client/client_bean_mock.go:43
↓ 9 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/interfaces/shard_context_mock.go:869
↓ 9 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/workflow/task_refresher_mock.go:41
↓ 9 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/quotas/rate_limiter_mock.go:40
↓ 9 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/data_interfaces_mock.go:1249
↓ 9 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/namespace_replication_queue_mock.go:40
↓ 9 callersMethodEqualHistoryEventsSuffix
(expectedHistorySuffix string, actualHistoryEvents []*historypb.HistoryEvent)
common/testing/historyrequire/history_require.go:100
↓ 9 callersFunctionEventIDFromToken
EventIDFromToken gets the event ID associated with an event load token.
service/history/hsm/tree.go:173
↓ 9 callersMethodExecutionInfo
ExecutionInfo returns metadata information about the execution.
chasm/context.go:30
← previousnext →2,501–2,600 of 43,335, ranked by callers