MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 28 callersFunctionWithWorkerService
WithWorkerService enables the system worker service. The service is off by default to avoid the worker overhead. This implies a dedicated cluster.
tests/testcore/test_env.go:156
↓ 28 callersMethodbuildWorkflowMutableState
()
service/history/workflow/mutable_state_impl_test.go:2545
↓ 28 callersMethodcreatePersistenceMutableState
( ms historyi.MutableState, lastEventID int64, lastEventVersion int64, )
service/history/timer_queue_active_task_executor_test.go:2316
↓ 28 callersMethoddefaultQueue
()
service/matching/task_queue_partition_manager.go:283
↓ 28 callersMethodfailover
( ns string, inClusterIndex int, targetCluster string, targetFailoverVersion int64, )
tests/xdc/base.go:382
↓ 28 callersMethodgetLogger
()
service/history/ndc/replication_task.go:42
↓ 28 callersMethodgetTaskCount
getTaskCount returns number of tasks in a task queue
service/matching/matching_engine_test.go:5498
↓ 28 callersMethodupdateWithStartReq
(env testcore.Env, tv *testvars.TestVars)
tests/update_workflow_test.go:5067
↓ 28 callersMethodverifyDescribeWorkerDeployment
( actualResp *workflowservice.DescribeWorkerDeploymentResponse, expectedResp *workflowservice.DescribeWorker
tests/worker_deployment_test.go:3331
↓ 27 callersMethodAddListener
AddListener adds a listener which will get notified on the given channel whenever membership changes.
common/membership/interfaces.go:78
↓ 27 callersFunctionCheckTaskVersion
CheckTaskVersion will return an error if task version check fails
service/history/ndc_task_util.go:32
↓ 27 callersMethodEnqueueTaskNoWait
(task *internalTask)
service/matching/matcher_data.go:244
↓ 27 callersMethodGetBufferedStarts
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:321
↓ 27 callersMethodGetHistoryArchiver
(scheme string)
common/archiver/provider/provider.go:30
↓ 27 callersMethodGetNextVertices
GetNextVertices generates next vertex batch
common/testing/generator_interface.go:30
↓ 27 callersMethodGetOrCreateShard
(ctx context.Context, request *GetOrCreateShardRequest)
common/persistence/data_interfaces.go:1110
↓ 27 callersMethodGetReason
()
api/schedule/v1/message.pb.go:895
↓ 27 callersMethodGetSession
()
common/persistence/cassandra/test.go:184
↓ 27 callersMethodHandlerName
()
common/testing/testvars/test_vars.go:385
↓ 27 callersMethodHeader
()
service/frontend/nexus_http_response_writer.go:22
↓ 27 callersMethodHistogram
Histogram obtains a histogram for the given name.
common/metrics/metrics.go:35
↓ 27 callersMethodIsRoot
IsRoot always returns false for Sticky partitions
common/tqid/task_queue_id.go:47
↓ 27 callersMethodLess
(i, j int)
common/tasks/weighted_channel.go:82
↓ 27 callersFunctionNew
( t Helper, client workflowservice.WorkflowServiceClient, namespace string, )
common/testing/taskpoller/taskpoller.go:94
↓ 27 callersFunctionNewHook
(key Key[T, S], value T)
common/testing/testhooks/test_impl.go:69
↓ 27 callersFunctionNewInt
(key string, value int)
common/log/tag/zap_tag.go:90
↓ 27 callersFunctionNewIterator
( paginationFnProvider PaginationFnProvider, r Range, )
service/history/queues/iterator.go:32
↓ 27 callersFunctionNewMockExecutable
NewMockExecutable creates a new mock instance.
service/history/queues/executable_mock.go:37
↓ 27 callersMethodPauseActivity
(ctx context.Context, request *historyservice.PauseActivityRequest)
service/history/interfaces/engine.go:96
↓ 27 callersMethodRemoveListener
RemoveListener removes a listener for this service.
common/membership/interfaces.go:80
↓ 27 callersMethodRequestCancelActivityExecution
(context.Context, *workflowservice.RequestCancelActivityExecutionRequest)
chasm/lib/activity/frontend.go:32
↓ 27 callersMethodRespondActivityTaskCanceled
(ctx context.Context, request *historyservice.RespondActivityTaskCanceledRequest)
service/history/interfaces/engine.go:40
↓ 27 callersMethodSaveClusterMetadata
(ctx context.Context, request *SaveClusterMetadataRequest)
common/persistence/data_interfaces.go:1241
↓ 27 callersMethodSuppressBy
(incomingWorkflow Workflow)
service/history/ndc/workflow.go:32
↓ 27 callersFunctionUpdateComponent
TODO: - consider merge with ReadComponent - consider remove ComponentRef from the return value and allow components to get the ref in the transition f
chasm/engine.go:296
↓ 27 callersMethodUpdateWorkflowExecutionOptions
(ctx context.Context, request *historyservice.UpdateWorkflowExecutionOptionsRequest)
service/history/interfaces/engine.go:50
↓ 27 callersMethodensureCreateVersionInDeployment
( env *VersioningTestEnv, tv *testvars.TestVars, )
tests/worker_deployment_test.go:126
↓ 27 callersMethodgetCount
()
common/namespace/nsregistry/registry_watch_test.go:63
↓ 27 callersFunctionmustEncodeValue
(val any, valueType enumspb.IndexedValueType)
common/persistence/visibility/store/elasticsearch/visibility_store_read_test.go:89
↓ 27 callersMethodtestComponentTree
Helper method to create a test tree for TestComponent.
chasm/tree_test.go:3191
↓ 26 callersMethodAcquire
(ctx context.Context, priority Priority, n int)
common/locks/priority_semaphore.go:7
↓ 26 callersFunctionAddress
Address return tag for Address
common/log/tag/tags.go:436
↓ 26 callersMethodAfterFunc
(d time.Duration, f func())
common/clock/time_source.go:13
↓ 26 callersFunctionCounter
Counter returns tag for Counter
common/log/tag/tags.go:511
↓ 26 callersMethodDedicatedWorkerOptions
DedicatedWorkerOptions returns a PerNSDedicatedWorkerOptions for this worker component.
service/worker/common/interface.go:44
↓ 26 callersMethodDeepEqual
(a any, b any)
common/testing/protoassert/assert.go:108
↓ 26 callersMethodDescribeNamespace
DescribeNamespace returns the information and configuration for a registered namespace.
service/frontend/workflow_handler.go:472
↓ 26 callersMethodDescribeWorkerDeploymentVersion
( ctx context.Context, request *workflowservice.DescribeWorkerDeploymentVersionRequest, opts ...grpc.CallOp
client/frontend/client_gen.go:272
↓ 26 callersFunctionEncode
(value ...any)
common/payloads/payloads.go:33
↓ 26 callersMethodGenerateWorkflowCloseTasks
( closedTime time.Time, deleteAfterClose bool, skipCloseTransferTask bool, )
service/history/workflow/task_generator.go:38
↓ 26 callersFunctionGetAndUpdateWorkflowWithNew
( ctx context.Context, reqClock *clockspb.VectorClock, workflowKey definition.WorkflowKey, action UpdateWo
service/history/api/update_workflow_util.go:14
↓ 26 callersMethodGetHistoryBranchUtil
()
common/persistence/data_interfaces.go:1119
↓ 26 callersMethodGetNextEventID
GetNextEventID returns next event ID
service/history/workflow/mutable_state_impl.go:2465
↓ 26 callersMethodGetQueueExclusiveHighReadWatermark
(category tasks.Category)
service/history/interfaces/shard_context.go:68
↓ 26 callersFunctionGetTypedPropertyFn
(value T)
common/dynamicconfig/setting_gen.go:971
↓ 26 callersMethodHasNextVertex
HasNextVertex determines if there is more vertex to generate
common/testing/generator_interface.go:28
↓ 26 callersMethodHostInfo
()
common/membership/interfaces.go:94
↓ 26 callersMethodIter
()
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:32
↓ 26 callersMethodMarkPoisonPill
()
service/history/replication/executable_task.go:91
↓ 26 callersFunctionNewConfigError
NewConfigError creates and returns an instance of ConfigError
tools/common/schema/types.go:173
↓ 26 callersFunctionNewFakeTask
( workflowKey definition.WorkflowKey, category Category, visibilityTimestamp time.Time, )
service/history/tasks/fake_task.go:21
↓ 26 callersFunctionNewMockClient
NewMockClient creates a new mock instance.
common/testing/mocksdk/client_mock.go:37
↓ 26 callersMethodStartBatchOperation
( ctx context.Context, request *workflowservice.StartBatchOperationRequest, opts ...grpc.CallOption, )
client/frontend/client_gen.go:992
↓ 26 callersFunctionThrottleRetry
ThrottleRetry is a resource aware version of Retry. Resource exhausted error will be retried using a different throttle retry policy, instead of the s
common/backoff/retry.go:41
↓ 26 callersFunctionTimeNowPtrUtcAddSeconds
(seconds int)
common/primitives/timestamp/time.go:44
↓ 26 callersMethodValidate
Validate checks if the task is still valid for processing for the current node state. Implementors may return [ErrStaleReference] or [consts.ErrWorkfl
service/history/hsm/tasks.go:40
↓ 26 callersFunctionWithExpectedAttemptCount
(c int)
tests/testcore/taskpoller.go:92
↓ 26 callersMethodacquireShards
(ctx context.Context)
service/history/shard/controller_impl.go:383
↓ 26 callersMethodappendNewNode
(branch []byte, events []*historypb.HistoryEvent, txnID int64)
common/persistence/persistence-tests/history_v2_persistence.go:782
↓ 26 callersMethodcreatePersistenceMutableState
( ms historyi.MutableState, lastEventID int64, lastEventVersion int64, )
service/history/timer_queue_standby_task_executor_test.go:2567
↓ 26 callersFunctionisRetryable
(failure *failurepb.Failure, nonRetryableTypes []string)
service/history/workflow/retry.go:115
↓ 26 callersFunctionnewTestTask
( controller *gomock.Controller, channelKey int, )
common/tasks/interleaved_weighted_round_robin_test.go:588
↓ 26 callersMethodpickReadPartition
(partitionCount int)
client/matching/loadbalancer.go:153
↓ 26 callersMethodpollActivityTaskAndValidate
( ctx context.Context, t *testing.T, activityID string, taskQueue string, runID string, )
tests/activity_standalone_test.go:6199
↓ 25 callersMethodAdvanceNext
AdvanceNext advances to the next timer.
common/clock/event_time_source.go:127
↓ 25 callersMethodConvertError
(err error)
common/persistence/sql/sqlplugin/db_handle.go:157
↓ 25 callersMethodCreateNamespace
CreateNamespace helper method
common/persistence/persistence-tests/metadata_persistence_v2.go:1440
↓ 25 callersMethodCreateWorkerDeployment
( ctx context.Context, namespaceEntry *namespace.Namespace, deploymentName string, identity string,
service/worker/workerdeployment/client.go:67
↓ 25 callersMethodDeleteNamespace
(ctx context.Context, request *DeleteNamespaceRequest)
common/persistence/data_interfaces.go:1223
↓ 25 callersMethodEnabled
Enabled reports whether the handler handles records at the given level.
common/log/slog.go:39
↓ 25 callersMethodFailureToError
FailureToError converts a [Failure] to an [error].
common/nexus/nexusrpc/failure_converter.go:22
↓ 25 callersMethodGetCategory
()
service/history/tasks/task.go:21
↓ 25 callersMethodGetCloseVersion
()
service/history/interfaces/mutable_state.go:178
↓ 25 callersMethodGetDatabaseMutableState
()
api/adminservice/v1/request_response.pb.go:455
↓ 25 callersMethodGetModTime
()
common/dynamicconfig/file_based_client.go:25
↓ 25 callersMethodGetPhysicalTaskQueueInfo
()
api/taskqueue/v1/message.pb.go:401
↓ 25 callersMethodGetPollers
()
api/taskqueue/v1/message.pb.go:452
↓ 25 callersMethodGetVisibilityArchiver
(scheme string)
common/archiver/provider/provider.go:31
↓ 25 callersMethodImportWorkflowExecution
(ctx context.Context, request *historyservice.ImportWorkflowExecutionRequest)
service/history/interfaces/engine.go:82
↓ 25 callersMethodIsMasterCluster
IsMasterCluster whether current cluster is master cluster
common/cluster/metadata.go:44
↓ 25 callersFunctionMergeVersioningData
MergeVersioningData merges two VersioningData structs. If a build ID appears in both data structures, the merged structure will include that latest st
service/matching/version_sets_merge.go:136
↓ 25 callersFunctionNamespaceUnknownTag
NamespaceUnknownTag returns a new namespace:unknown tag-value
common/metrics/tags.go:121
↓ 25 callersFunctionNewDataBlob
NewDataBlob returns a new DataBlob. TODO: return an UnknowEncodingType error with the actual type string when encodingTypeStr is invalid
common/persistence/data_blob.go:10
↓ 25 callersFunctionNewMockClient
NewMockClient creates a new mock instance.
common/archiver/gcloud/connector/client_mock.go:33
↓ 25 callersFunctionNewMockServiceResolver
NewMockServiceResolver creates a new mock instance.
common/membership/interfaces_mock.go:171
↓ 25 callersMethodRootPartition
()
common/tqid/task_queue_id.go:276
↓ 25 callersMethodSend
(Req)
service/history/replication/bi_direction_stream.go:40
↓ 25 callersFunctionStalenessCheck
StalenessCheck verifies that refVersionedTransition is contained in the given transition history. When a task or API request is being processed, the
common/persistence/transitionhistory/transition_history.go:81
↓ 25 callersFunctionUnixOrZeroTimePtr
(nanos int64)
common/primitives/timestamp/time.go:36
↓ 25 callersMethodUnpauseWorkflowExecution
(ctx context.Context, request *historyservice.UnpauseWorkflowExecutionRequest)
service/history/interfaces/engine.go:100
← previousnext →1,001–1,100 of 43,335, ranked by callers