MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 11 callersFunctionWithGlobalFlag
WithGlobalFlag sets whether or not this Namespace is global.
common/namespace/mutate.go:45
↓ 11 callersFunctionWorkerDeploymentVersionToStringV32
(v *deploymentspb.WorkerDeploymentVersion)
common/worker_versioning/worker_versioning.go:1155
↓ 11 callersFunctionWorkflowInitiatedID
WorkflowInitiatedID returns tag for WorkflowInitiatedID
common/log/tag/tags.go:226
↓ 11 callersMethodassertChanState
(expectedClosed bool, chans ...<-chan struct{})
service/history/workflow/query_registry_test.go:217
↓ 11 callersMethodassertClosedExecutionEquals
( req *manager.RecordWorkflowExecutionClosedRequest, resp *workflowpb.WorkflowExecutionInfo)
common/persistence/tests/visibility_persistence_suite.go:1138
↓ 11 callersMethodcheckIfPayloadSizeExceedsLimit
( commandTypeTag metrics.Tag, payloadSize int, message string, )
service/history/api/respondworkflowtaskcompleted/workflow_size_checker.go:54
↓ 11 callersFunctionconvertToExecutionInfo
(record *archiverspb.VisibilityRecord, saTypeMap searchattribute.NameTypeMap)
common/archiver/s3store/util.go:252
↓ 11 callersFunctioncreateAssignmentRuleWithoutRamp
(buildId string)
service/matching/version_rule_helper_test.go:87
↓ 11 callersFunctiondeleteMessages
( ctx context.Context, q persistence.QueueV2, queueType persistence.QueueV2Type, queueName string, maxID
common/persistence/tests/cassandra_test.go:1239
↓ 11 callersFunctiondescribeResp
(paused bool, overlap enumspb.ScheduleOverlapPolicy, runningCount int)
service/worker/scanner/scheduleinvariants/invariants_test.go:223
↓ 11 callersMethoddispatchForExistingWorkflow
( ctx context.Context, isWorkflowRebuilt bool, archetypeID chasm.ArchetypeID, targetWorkflow Workf
service/history/ndc/transaction_manager_existing_workflow.go:18
↓ 11 callersFunctionextractWorkflowConflictError
( conflictRecord map[string]any, requestRunID string, requestDBVersion int64, requestNextEventID int64, //
common/persistence/cassandra/errors.go:237
↓ 11 callersFunctionfile_temporal_server_api_persistence_v1_chasm_proto_rawDescGZIP
()
api/persistence/v1/chasm.pb.go:999
↓ 11 callersFunctionfile_temporal_server_api_persistence_v1_task_queues_proto_rawDescGZIP
()
api/persistence/v1/task_queues.pb.go:831
↓ 11 callersFunctionfile_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_rawDescGZIP
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:1016
↓ 11 callersMethodfindNode
( path []string, )
chasm/tree.go:2707
↓ 11 callersFunctionformatComparisonExprStringForError
formatComparisonExprStringForError formats comparison expression after custom search attribute was mapped to field name to show alias name for better
common/persistence/visibility/store/sql/query_converter_util_legacy.go:115
↓ 11 callersMethodfqType
fqType returns the fully qualified name of the task, which is a combination of the library name and the task type. This is used to uniquely identify t
chasm/registrable_task.go:180
↓ 11 callersFunctiongenerateEventHistory
Pattern contains either c or f representing completed or failed task. Schedule events for each task has id of NumTotalEvents*i + 1 where i is the inde
service/worker/batcher/activities_test.go:100
↓ 11 callersMethodgetActivityHeartbeatTimeout
( activityInfo *persistencespb.ActivityInfo, )
service/history/workflow/timer_sequence.go:323
↓ 11 callersMethodgetActivityScheduleToStartTimeout
( activityInfo *persistencespb.ActivityInfo, )
service/history/workflow/timer_sequence.go:231
↓ 11 callersMethodgetDLQTypeFromQueueType
()
common/persistence/sql/queue.go:311
↓ 11 callersFunctioninfo
(format string, args ...any)
cmd/tools/protogen/main.go:20
↓ 11 callersMethodinitMockExecutionManager
(batchInfo []int, returnErrorOnPage int, addNotExistCall bool, pages ...page)
common/archiver/history_iterator_test.go:592
↓ 11 callersMethodisStarted
isStarted is true when this task is already marked as started
service/matching/task.go:246
↓ 11 callersFunctionisSupportedComparisonOperator
(operator string)
common/persistence/visibility/store/sql/query_converter_legacy.go:663
↓ 11 callersFunctionmakeStartRequest
( requestID, workflowID, identity, workflowType string, namespaceEntry *namespace.Namespace, memo *commonpb
service/worker/workerdeployment/util.go:417
↓ 11 callersFunctionmergeActivityOptions
( mergeInto *activitypb.ActivityOptions, mergeFrom *activitypb.ActivityOptions, updateFields map[string]str
service/history/api/updateactivityoptions/api.go:210
↓ 11 callersMethodnewBacklogTask
(id int64, age time.Duration, f func(*internalTask, taskResponse))
service/matching/matcher_data_test.go:119
↓ 11 callersFunctionnewFinalizer
(mh metrics.Handler)
common/finalizer/finalizer_test.go:154
↓ 11 callersMethodnewImpl
(pollWaitForToken bool)
common/rpc/interceptor/namespace_rate_limit_test.go:45
↓ 11 callersFunctionnewInvokerExecuteTestEnv
(t *testing.T)
chasm/lib/scheduler/invoker_execute_task_test.go:32
↓ 11 callersMethodnewRandomShardRow
( shardID int32, rangeID int64, )
common/persistence/sql/sqlplugin/tests/history_shard.go:206
↓ 11 callersFunctionnewRegistry
(t *testing.T)
components/nexusoperations/helpers_test.go:38
↓ 11 callersMethodnewRespondActivityTaskFailedRequest
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:417
↓ 11 callersFunctionnewTestDeps
(t *testing.T)
service/worker/scanner/scheduleinvariants/invariants_test.go:42
↓ 11 callersFunctionnewUseCase
(uconfig UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:384
↓ 11 callersFunctionnewVisibilityArchiver
(logger log.Logger, metricsHandler metrics.Handler, storage connector.Client)
common/archiver/gcloud/visibility_archiver.go:53
↓ 11 callersFunctionnewWorkerQueryEngine
* FilterWorkers filters the list of per-namespace worker heartbeats against the provided query. The query should be a valid SQL query without WHERE cl
service/matching/workers/worker_query_engine.go:84
↓ 11 callersFunctionnextBackoffInterval
( now time.Time, currentAttempt int32, maxAttempts int32, initInterval *durationpb.Duration, maxInterval
service/history/workflow/retry.go:70
↓ 11 callersFunctionoverrideWorkflowTaskTimeout
overrideWorkflowTaskTimeout override the workflow task timeout according to default timeout or max timeout
service/history/api/create_workflow_util.go:376
↓ 11 callersMethodpollWithIdentity
UpdatePollerData is a no-op if the poller context has no identity, so we need a context with identity for any tests that check poller info
service/matching/task_queue_partition_manager_test.go:1288
↓ 11 callersMethodprocessTimer
( ctx context.Context, timerTask tasks.Task, actionFn standbyActionFn, postActionFn standbyPostActionFn, )
service/history/timer_queue_standby_task_executor.go:720
↓ 11 callersMethodread
persistence helper
common/persistence/persistence-tests/history_v2_persistence.go:735
↓ 11 callersMethodrelease
()
service/matching/forwarder.go:359
↓ 11 callersFunctionreplaceRedirectRule
(rule *taskqueuepb.CompatibleBuildIdRedirectRule, data *persistencespb.VersioningData, clock *hlc.Clock, ma
service/matching/version_rule_test.go:145
↓ 11 callersFunctionrespondSuccess
(t *testing.T, store mockEventStore, upd *update.Update)
service/history/workflow/update/update_test.go:1115
↓ 11 callersMethodserializeEvents
(events []*historypb.HistoryEvent)
tests/ndc/replication_migration_back_test.go:374
↓ 11 callersMethodsetFailureSource
(source string)
service/frontend/nexus_handler.go:829
↓ 11 callersFunctionsetupSentinelForTest
(t *testing.T)
chasm/lib/scheduler/helper_test.go:419
↓ 11 callersMethodsetupStubs
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:404
↓ 11 callersMethodsignalIfFatal
signalIfFatal calls UnloadFromPartitionManager of the physicalTaskQueueManager if and only if the supplied error represents a fatal condition, e.g. th
service/matching/backlog_manager.go:114
↓ 11 callersMethodstartWorkflow
( env *testcore.TestEnv, tv *testvars.TestVars, override *workflowpb.VersioningOverride, )
tests/worker_deployment_version_test.go:1810
↓ 11 callersFunctiontestComponentSerializedNodes
returns serialized version of TestComponent from above. Generated by generateMapInit function below.
chasm/test_component_test.go:211
↓ 11 callersFunctiontestWorkerCommandsTask
()
service/history/worker_commands_task_dispatcher_test.go:25
↓ 11 callersMethodtrack
( taskMaps ...map[tasks.Category][]tasks.Task, )
service/history/shard/task_request_tracker.go:36
↓ 11 callersMethodverifyOverrides
( expectedBehavior, expectedBehaviorOverride enumspb.VersioningBehavior, expectedDeployment, expectedDeploym
service/history/workflow/mutable_state_impl_test.go:1184
↓ 10 callersMethodAddActivityTaskCancelRequestedEvent
(int64, int64, string)
service/history/interfaces/mutable_state.go:50
↓ 10 callersMethodAddChildWorkflowExecutionStartedEvent
(*commonpb.WorkflowExecution, *commonpb.WorkflowType, int64, *commonpb.Header, *clockspb.VectorClock)
service/history/interfaces/mutable_state.go:71
↓ 10 callersMethodAddTasks
(...tasks.Task)
chasm/tree.go:215
↓ 10 callersMethodAddTimeoutWorkflowEvent
(enumspb.RetryState, string)
service/history/interfaces/mutable_state.go:95
↓ 10 callersMethodAddTimerFiredEvent
(string)
service/history/interfaces/mutable_state.go:97
↓ 10 callersMethodAssertHEPrefixWithDB
(branchToken []byte, events ...[]*p.WorkflowEvents)
common/persistence/tests/execution_mutable_state.go:2700
↓ 10 callersMethodAssign
(Executable)
service/history/queues/priority_assigner.go:12
↓ 10 callersMethodBeginTx
(ctx context.Context)
common/persistence/sql/sqlplugin/interfaces.go:104
↓ 10 callersMethodCanMergeByRange
( incomingScope Scope, )
service/history/queues/scope.go:63
↓ 10 callersMethodCanMergeWithSlice
(Slice)
service/history/queues/slice.go:30
↓ 10 callersMethodCanSplit
(tasks.Key)
service/history/queues/iterator.go:15
↓ 10 callersMethodCanSplitByRange
(tasks.Key)
service/history/queues/slice.go:27
↓ 10 callersMethodCancel
Cancel invokes the buffered rollback functions in the reverse of the order that they were added to this Buffer. It returns true if any effects were ca
common/effect/buffer.go:43
↓ 10 callersMethodCancelOutstandingWorkerPolls
(ctx context.Context, request *matchingservice.CancelOutstandingWorkerPollsRequest)
service/matching/matching_engine_interfaces.go:22
↓ 10 callersFunctionChasmRunID
ChasmRunID returns tag for an entity run ID
common/log/tag/tags.go:926
↓ 10 callersMethodClearStickyTaskQueue
()
service/history/workflow/mutable_state_impl.go:1444
↓ 10 callersMethodClose
()
common/archiver/gcloud/connector/client_delegate.go:54
↓ 10 callersMethodContainsHistoryEvents
ContainsHistoryEvents checks if expectedHistorySegment is contained in actualHistoryEvents. actualHistoryEvents are sanitized based on the first event
common/testing/historyrequire/history_require.go:130
↓ 10 callersFunctionConvertGradualChange
ConvertGradualChange is a conversion function that can handle a plain T (which represents a static value) as well as a GradualChange[T]. It can be use
common/dynamicconfig/gradual_change.go:58
↓ 10 callersFunctionCopyVersionHistoryItem
CopyVersionHistoryItem create a new instance of VersionHistoryItem.
common/persistence/versionhistory/version_history_item.go:19
↓ 10 callersMethodCountChasmExecutions
(ctx context.Context, request *visibilityservice.CountChasmExecutionsRequest)
common/persistence/visibility/store/visibility_store.go:41
↓ 10 callersMethodCreateQueue
( ctx context.Context, request *persistence.CreateQueueRequest, )
service/history/queues/dlq_writer.go:30
↓ 10 callersFunctionDecode
Decode decodes search attributes to the map of search attribute values using (in order): 1. type from typeMap, 2. if typeMap is nil, type from Metadat
common/searchattribute/encode.go:55
↓ 10 callersMethodDeepHealthCheck
(ctx context.Context, in *DeepHealthCheckRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:156
↓ 10 callersMethodDeleteMessagesBefore
(ctx context.Context, messageID int64)
common/persistence/persistence_interface.go:175
↓ 10 callersFunctionDeployment
(d string)
common/log/tag/tags.go:1000
↓ 10 callersFunctionDeploymentFromDeploymentVersion
DeploymentFromDeploymentVersion Temporary helper function to convert WorkerDeploymentVersion to Deployment proto until we update code to use the new p
common/worker_versioning/worker_versioning.go:522
↓ 10 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/membership/interfaces_mock.go:41
↓ 10 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/s3store/query_parser_mock.go:38
↓ 10 callersFunctionExternalWorkerDeploymentVersionFromVersion
ExternalWorkerDeploymentVersionFromVersion Temporary helper function to convert internal Worker Deployment to WorkerDeploymentVersion proto until we u
common/worker_versioning/worker_versioning.go:498
↓ 10 callersFunctionFindBuildId
FindBuildId finds a build ID in the version data's sets, returning (set index, index within that set). Returns -1, -1 if not found.
common/worker_versioning/worker_versioning.go:138
↓ 10 callersMethodForwardTask
(background context.Context, task *internalTask)
service/matching/forwarder_test.go:37
↓ 10 callersMethodFromPayload
(payload *commonpb.Payload, valuePtr any)
tests/testcore/test_data_converter.go:69
↓ 10 callersMethodGet
(k string)
common/metrics/baggage_bench_test.go:28
↓ 10 callersMethodGetActivityOptions
()
api/historyservice/v1/request_response.pb.go:9512
↓ 10 callersFunctionGetActivityState
(ai *persistencespb.ActivityInfo)
service/history/workflow/activity.go:53
↓ 10 callersMethodGetAttempt
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/tasks.pb.go:170
↓ 10 callersMethodGetCategories
()
service/history/tasks/task_category_registry.go:12
↓ 10 callersMethodGetCompletionState
()
service/history/workflow/query.go:30
↓ 10 callersMethodGetCreateRequestId
()
api/persistence/v1/executions.pb.go:3439
↓ 10 callersMethodGetDefaultClient
GetDefaultClient returns the default Temporal client configured for making requests to the server. It is configured to use a pre-registered test name
temporaltest/server.go:68
↓ 10 callersMethodGetError
GetError returns a gRPC INVALID_ARGUMENT error representing the issues in the set or nil if there are no issues.
common/rpc/request_issues.go:27
↓ 10 callersMethodGetExecutionState
TODO: Add methods needed from MutateState here.
chasm/tree.go:207
← previousnext →2,301–2,400 of 43,335, ranked by callers