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 callersMethodhandleSyncShardStatus
( status *replicationspb.SyncShardStatus, )
service/history/replication/task_processor.go:288
↓ 3 callersMethodhandleWriteErrorLocked
( requestRangeID int64, err error, )
service/history/shard/context_impl.go:1388
↓ 3 callersFunctionhasNameConflict
(row map[string]any, column string, value T)
common/persistence/cassandra/metadata_store.go:512
↓ 3 callersMethodhashFn
(key any)
common/persistence/visibility/store/elasticsearch/processor.go:144
↓ 3 callersFunctionhistoryBuilderWithTimerEventsInDbBuffer
(timers ...string)
service/history/historybuilder/history_builder_categorization_test.go:1223
↓ 3 callersMethodhistoryIsDeleted
(env *archivalTestEnv, workflowInfo archivalWorkflowInfo)
tests/archival_test.go:362
↓ 3 callersFunctionidentity
(v T)
service/worker/scheduler/buffer_test.go:30
↓ 3 callersMethodidentity
()
service/worker/scheduler/workflow.go:1547
↓ 3 callersMethodinitLastUpdatesTime
()
service/history/shard/context_impl.go:2149
↓ 3 callersFunctioninitSession
( logger log.Logger, newClusterConfigFunc func() (*gocql.ClusterConfig, error), metricsHandler metrics.Hand
common/persistence/nosql/nosqlplugin/cassandra/gocql/session.go:94
↓ 3 callersMethodinjectHook
(t *testing.T, hook testhooks.Hook, scope any)
tests/testcore/onebox.go:948
↓ 3 callersFunctioninsertQueueMetadataWithMultiplePartitions
( t *testing.T, session gocql.Session, queueType persistence.QueueV2Type, queueName string, )
common/persistence/tests/cassandra_test.go:1213
↓ 3 callersFunctioninvoke
(t *testing.T, modifyMutableState mutableStateModifier)
service/history/api/recordworkflowtaskstarted/api_test.go:66
↓ 3 callersFunctionisActiveRedirectRuleSource
(buildID string, redirectRules []*persistencespb.RedirectRule)
service/matching/version_rule_helpers.go:385
↓ 3 callersFunctionisAlphanumeric
(c byte)
common/persistence/query_util.go:256
↓ 3 callersFunctionisRaceBoundary
(line string)
tools/testrunner/log.go:315
↓ 3 callersMethodisStopped
()
common/tasks/interleaved_weighted_round_robin.go:403
↓ 3 callersFunctionisSupportedOperator
(supportedOperators []string, operator string)
common/persistence/visibility/store/sql/query_converter_legacy.go:659
↓ 3 callersFunctionisSupportedTypeRangeCond
(saType enumspb.IndexedValueType)
common/persistence/visibility/store/sql/query_converter_legacy.go:675
↓ 3 callersFunctionisTestOutputLine
isTestOutputLine reports whether line is a Go test-framework output line, i.e. " file.go:N: …" — exactly 4 spaces then a non-whitespace character.
tools/testrunner/log.go:442
↓ 3 callersMethodisWaitStageReached
(_ chasm.Context, waitStage enumspb.NexusOperationWaitStage)
chasm/lib/nexusoperation/operation.go:506
↓ 3 callersMethodjitterSeed
()
chasm/lib/scheduler/scheduler.go:427
↓ 3 callersFunctionjsonPayload
(data string)
tests/http_api_test.go:35
↓ 3 callersFunctionlistFilesByPrefix
(dirPath string, prefix string)
common/archiver/filestore/util.go:105
↓ 3 callersMethodlistOpenWorkflowExecutions
(env *testcore.TestEnv, start, end time.Time, id string, expectedNumber int)
tests/cron_test.go:577
↓ 3 callersMethodloadDelegate
loadDelegate returns the rate limiter that this rate limiter delegates to.
common/quotas/request_rate_limiter_delegator.go:31
↓ 3 callersMethodloadSearchAttributeString
(saName string)
service/history/workflow/mutable_state_impl.go:3769
↓ 3 callersFunctionlockTaskQueue
( ctx context.Context, tx sqlplugin.Tx, tqHash uint32, tqId []byte, oldRangeID int64, v sqlplugin.Matchi
common/persistence/sql/task_v1.go:187
↓ 3 callersMethodlogNewUserData
(message string, data *persistencespb.VersionedTaskQueueUserData, tags ...tag.Tag)
service/matching/user_data_manager.go:872
↓ 3 callersMethodmakeBuildIdCountRequest
(query string)
service/matching/reachability.go:225
↓ 3 callersFunctionmakeDefaultSet
(data *persistencespb.VersioningData, setIx int, timestamp *hlc.Clock)
service/matching/version_sets.go:298
↓ 3 callersFunctionmakeKey
(i int)
tools/fairsim/sim_test.go:44
↓ 3 callersFunctionmakeResponse
( startResp *historyservice.StartWorkflowExecutionResponse, updateResp *historyservice.UpdateWorkflowExecuti
service/history/api/multioperation/api.go:379
↓ 3 callersFunctionmakeVersionInSetDefault
(data *persistencespb.VersioningData, setIx, versionIx int, timestamp *hlc.Clock)
service/matching/version_sets.go:309
↓ 3 callersMethodmaybeRefresh
()
common/persistence/client/health_request_rate_limiter.go:95
↓ 3 callersMethodmerge
(incomingTracker *executableTracker)
service/history/queues/tracker.go:59
↓ 3 callersMethodmergeIterators
(incomingSlice *SliceImpl)
service/history/queues/slice.go:229
↓ 3 callersFunctionmix
from https://www.pcg-random.org/posts/developing-a-seed_seq-alternative.html
service/matching/counter/cmsketch.go:258
↓ 3 callersFunctionmkCountResponse
(count int64)
service/matching/reachability_test.go:333
↓ 3 callersFunctionmkExistingDefault
(id string)
service/matching/version_sets_test.go:62
↓ 3 callersFunctionmkPromoteInSet
(id string)
service/matching/version_sets_test.go:69
↓ 3 callersMethodmustGenerateTaskID
()
service/history/outbound_queue_standby_task_executor_test.go:409
↓ 3 callersMethodmustInitHSM
()
service/history/workflow/mutable_state_impl.go:651
↓ 3 callersMethodmutableStateIsDeleted
(env *archivalTestEnv, namespaceID namespace.ID, execution *commonpb.WorkflowExecution)
tests/archival_test.go:389
↓ 3 callersMethodmutateCompletionComponentRef
( token *tokenspb.NexusOperationCompletion, mutate func(*persistencespb.ChasmComponentRef), )
tests/nexus_workflow_test.go:3030
↓ 3 callersMethodnamespaceClusterNames
(resp *workflowservice.DescribeNamespaceResponse)
tests/xdc/base.go:436
↓ 3 callersMethodnewAttempt
()
tools/testrunner/testrunner.go:187
↓ 3 callersFunctionnewBacklogAgeTracker
()
service/matching/backlog_age_tracker.go:19
↓ 3 callersFunctionnewBoundActivities
(frontend workflowservice.WorkflowServiceClient)
service/worker/batcher/activities_namespace_test.go:36
↓ 3 callersFunctionnewChasmRegistry
(logger log.Logger)
tools/tdbg/chasm_registry.go:13
↓ 3 callersFunctionnewClient
newClient create a ES client
common/persistence/visibility/store/elasticsearch/client/client_v7.go:30
↓ 3 callersFunctionnewDbBufferWithTimerEvents
(ids ...string)
service/history/historybuilder/history_builder_categorization_test.go:1177
↓ 3 callersFunctionnewDefaultClientDelegate
(ctx context.Context)
common/archiver/gcloud/connector/client_delegate.go:83
↓ 3 callersMethodnewEnv
newEnv builds a logs channel + logRecorder and starts a dedicated single-shard cluster wired to that recorder with the given fault injection config. T
tests/acquire_shard_test.go:81
↓ 3 callersFunctionnewErrorLogger
(logger log.Logger)
common/persistence/visibility/store/elasticsearch/client/logger.go:19
↓ 3 callersFunctionnewEventsCache
( executionManager persistence.ExecutionManager, metricsHandler metrics.Handler, logger log.Logger, maxSiz
service/history/events/cache.go:76
↓ 3 callersFunctionnewExecutorForAdmitterTest
(t *testing.T, admitter NamespaceReplicationAdmitter)
common/namespace/nsreplication/replication_admitter_test.go:71
↓ 3 callersFunctionnewFactory
newFactory builds a ringpop factory
common/membership/ringpop/factory.go:67
↓ 3 callersFunctionnewFairBacklogManager
( tqCtx context.Context, pqMgr physicalTaskQueueManager, config *taskQueueConfig, fairTaskManager persiste
service/matching/fair_backlog_manager.go:56
↓ 3 callersFunctionnewFairLevelTreeMap
()
service/matching/fair_level.go:28
↓ 3 callersFunctionnewFairMetricsHandler
(handler metrics.Handler)
service/matching/pri_metrics_handler.go:97
↓ 3 callersFunctionnewFieldInternalWithNode
(node *Node)
chasm/field_internal.go:24
↓ 3 callersFunctionnewForwarderReqToken
(maxOutstanding int)
service/matching/forwarder.go:351
↓ 3 callersFunctionnewFromName
(testName string)
common/testing/testvars/test_vars.go:43
↓ 3 callersFunctionnewGlobalMetricCapture
(capture *metricstest.Capture)
tests/testcore/metric_capture.go:19
↓ 3 callersFunctionnewHashRing
(replicaPoints int)
common/membership/ringpop/service_resolver.go:120
↓ 3 callersFunctionnewHistoryBuilder
()
service/history/historybuilder/history_builder_categorization_test.go:1219
↓ 3 callersFunctionnewHistoryIterator
( request *ArchiveHistoryRequest, executionManager persistence.ExecutionManager, targetHistoryBlobSize int,
common/archiver/history_iterator.go:77
↓ 3 callersMethodnewIOContext
()
service/history/shard/context_impl.go:2300
↓ 3 callersFunctionnewInfoLogger
(logger log.Logger)
common/persistence/visibility/store/elasticsearch/client/logger.go:27
↓ 3 callersFunctionnewInternalRulesTestWorkflow
(env *testcore.TestEnv)
tests/activity_api_rules_test.go:48
↓ 3 callersMethodnewInternalVisibilityRequestBase
( request *manager.VisibilityRequestBase, )
common/persistence/visibility/visibility_manager_impl.go:368
↓ 3 callersFunctionnewInvalidUpdateWorkflowWithNewMode
( mode UpdateWorkflowMode, currentWorkflowState enumsspb.WorkflowExecutionState, newWorkflowState enumsspb.
common/persistence/operation_mode_validator.go:327
↓ 3 callersFunctionnewLatencyStats
()
tools/fairsim/sim.go:152
↓ 3 callersFunctionnewLiveness
( timeSource clock.TimeSource, ttl func() time.Duration, onIdle func(), )
service/matching/liveness.go:23
↓ 3 callersFunctionnewMatcherData
(config *taskQueueConfig, logger log.Logger, timeSource clock.TimeSource, canForward bool, rateLimitManager *r
service/matching/matcher_data.go:226
↓ 3 callersFunctionnewMatchingEngine
( config *Config, taskMgr persistence.TaskManager, fairTaskMgr persistence.FairTaskManager, mockHistoryClien
service/matching/matching_engine_test.go:237
↓ 3 callersMethodnewMatchingEngine
( config *Config, taskMgr persistence.TaskManager, fairTaskMgr persistence.TaskManager, )
service/matching/matching_engine_test.go:228
↓ 3 callersFunctionnewMockRoutingInfoCache
()
service/history/api/recordactivitytaskstarted/api_test.go:37
↓ 3 callersFunctionnewOutboundQueueStandbyTaskExecutor
( shardCtx historyi.ShardContext, workflowCache wcache.Cache, clusterName string, logger log.Logger, metr
service/history/outbound_queue_standby_task_executor.go:35
↓ 3 callersFunctionnewPriBacklogManager
( tqCtx context.Context, pqMgr physicalTaskQueueManager, config *taskQueueConfig, taskManager persistence.
service/matching/pri_backlog_manager.go:75
↓ 3 callersFunctionnewPriMetricsHandler
TODO(pri): cleanup; delete this
service/matching/pri_metrics_handler.go:45
↓ 3 callersFunctionnewQueueBase
( shard historyi.ShardContext, category tasks.Category, paginationFnProvider PaginationFnProvider, schedul
service/history/queues/queue_base.go:105
↓ 3 callersFunctionnewQuotaLogger
( logger log.Logger, )
common/quotas/calculator/logged_calculator.go:85
↓ 3 callersFunctionnewRPCFactory
(dialOptions ...grpc.DialOption)
common/testing/nettest/rpc_factory_test.go:84
↓ 3 callersFunctionnewReaderRequest
( readerID int64, )
service/history/queues/reader_quotas.go:53
↓ 3 callersFunctionnewReplicationTaskFromBatch
( clusterMetadata cluster.Metadata, logger log.Logger, workflowKey definition.WorkflowKey, baseExecutionIn
service/history/ndc/replication_task.go:124
↓ 3 callersFunctionnewSummaryRow
(kind failureType, name string, details string)
tools/testrunner/summary.go:92
↓ 3 callersMethodnewTaskContext
( parentCtx context.Context, namespaceName namespace.Name, )
service/history/replication/task_executor.go:420
↓ 3 callersFunctionnewTaskForAdmitterTest
()
common/namespace/nsreplication/replication_admitter_test.go:86
↓ 3 callersFunctionnewTaskKeyManager
( taskCategoryRegistry tasks.TaskCategoryRegistry, timeSource clock.TimeSource, config *configs.Config, lo
service/history/shard/task_key_manager.go:24
↓ 3 callersFunctionnewTaskMatcher
newTaskMatcher returns a task matcher instance. The returned instance can be used by task producers and consumers to find a match. Both sync matches a
service/matching/matcher.go:55
↓ 3 callersMethodnewTaskQueueStatsContext
( usePriMatcher bool, behavior testcore.MatchingBehavior, extraOpts ...testcore.TestOption, )
tests/task_queue_stats_test.go:101
↓ 3 callersFunctionnewTaskTracker
( timeSource clock.TimeSource, bucketSize time.Duration, totalInterval time.Duration, )
service/matching/task_tracker.go:51
↓ 3 callersMethodnewTestEnv
(opts ...testcore.TestOption)
tests/priority_fairness_test.go:42
↓ 3 callersMethodnewTestEnv
()
tests/callbacks_migration_test.go:32
↓ 3 callersMethodnewTestEnv
(opts ...testcore.TestOption)
tests/callbacks_test.go:69
↓ 3 callersMethodnewTestEnv
(enableTransitionHistory bool, opts ...testcore.TestOption)
tests/gethistory_test.go:54
↓ 3 callersFunctionnewTestFairTaskManager
(logger log.Logger)
service/matching/matching_engine_test.go:5141
↓ 3 callersFunctionnewTestLibrary
( controller *gomock.Controller, )
chasm/test_library_test.go:19
← previousnext →6,401–6,500 of 43,335, ranked by callers