MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 1 callersFunctionnewActivityMatchEvaluator
(ai *persistencespb.ActivityInfo)
service/history/workflow/matcher/activity_evaluator.go:30
↓ 1 callersFunctionnewActivityRetryTimePostActionInfo
( mutableState historyi.MutableState, taskQueue string, activityScheduleToStartTimeout time.Duration, acti
service/history/ndc_standby_task_util.go:190
↓ 1 callersFunctionnewActivityStartDuringTransition
(st *status.Status)
common/serviceerror/activity_start_during_transition.go:43
↓ 1 callersFunctionnewActivityTaskPostActionInfo
( mutableState historyi.MutableState, activityInfo *persistencespb.ActivityInfo, )
service/history/ndc_standby_task_util.go:176
↓ 1 callersFunctionnewAdminDLQCommands
( dlqServiceProvider *DLQServiceProvider, taskCategoryRegistry tasks.TaskCategoryRegistry, )
tools/tdbg/tdbg_commands.go:741
↓ 1 callersFunctionnewAdminDLQJobCommands
( dlqServiceProvider *DLQServiceProvider, )
tools/tdbg/tdbg_commands.go:845
↓ 1 callersFunctionnewAdminExecutionCommands
(clientFactory ClientFactory, prompterFactory PrompterFactory)
tools/tdbg/tdbg_commands.go:81
↓ 1 callersFunctionnewAdminHistoryHostCommands
(clientFactory ClientFactory)
tools/tdbg/tdbg_commands.go:516
↓ 1 callersFunctionnewAdminMembershipCommands
(clientFactory ClientFactory)
tools/tdbg/tdbg_commands.go:476
↓ 1 callersFunctionnewAdminScheduleCommands
(clientFactory ClientFactory)
tools/tdbg/tdbg_commands.go:300
↓ 1 callersFunctionnewAdminShardManagementCommands
(clientFactory ClientFactory, taskCategoryRegistry tasks.TaskCategoryRegistry)
tools/tdbg/tdbg_commands.go:349
↓ 1 callersFunctionnewAdminTaskQueueCommands
(clientFactory ClientFactory)
tools/tdbg/tdbg_commands.go:570
↓ 1 callersFunctionnewAny
(testName string, testHash uint32)
common/testing/testvars/any.go:20
↓ 1 callersMethodnewArchivalTaskExecutor
newArchivalTaskExecutor creates a new archival task executor for the given shard.
service/history/archival_queue_factory.go:123
↓ 1 callersFunctionnewArchiverBase
( enabled bool, customHistoryArchiverFactory provider.CustomHistoryArchiverFactory, customVisibilityArchive
tests/testcore/test_cluster.go:491
↓ 1 callersFunctionnewBucket
()
service/matching/workers/registry_impl.go:82
↓ 1 callersFunctionnewBulkProcessor
(esBulkProcessor *elastic.BulkProcessor)
common/persistence/visibility/store/elasticsearch/client/bulk_processor_v7.go:16
↓ 1 callersFunctionnewBulkService
(esBulkService *elastic.BulkService)
common/persistence/visibility/store/elasticsearch/client/bulk_service_v7.go:15
↓ 1 callersFunctionnewCancellationResult
(callErr error)
chasm/lib/nexusoperation/cancellation_tasks.go:43
↓ 1 callersFunctionnewChasmEngine
( executionCache cache.Cache, registry *chasm.Registry, config *configs.Config, notifier *ChasmNotifier,
service/history/chasm_engine.go:80
↓ 1 callersFunctionnewChasmTestEnv
newChasmTestEnv creates a chasmTestEnv backed by a dedicated cluster with EnableChasm and VisibilityEnableUnifiedQueryConverter overridden for the tes
tests/chasm_test.go:58
↓ 1 callersFunctionnewCircularTaskBuffer
(size int)
service/matching/task_tracker.go:16
↓ 1 callersFunctionnewClients
( logger log.Logger, hostsByService map[primitives.ServiceName]static.Hosts, tlsConfigProvider *encryption.
tests/testcore/clients.go:53
↓ 1 callersFunctionnewClusterMetadataPersistence
( db sqlplugin.DB, logger log.Logger, serializer serialization.Serializer, )
common/persistence/sql/cluster_metadata.go:228
↓ 1 callersFunctionnewClusterWithPersistenceTestBaseFactory
( t *testing.T, clusterConfig *TestClusterConfig, logger log.Logger, tbFactory PersistenceTestBaseFactory,
tests/testcore/test_cluster.go:175
↓ 1 callersFunctionnewCompleted
( id string, outcomeFuture *future.ReadyFutureImpl[*updatepb.Outcome], opts ...updateOpt, )
service/history/workflow/update/update.go:119
↓ 1 callersFunctionnewComponentOnlyLibrary
(dc *dynamicconfig.Collection)
chasm/lib/nexusoperation/library.go:38
↓ 1 callersFunctionnewConnPool
()
common/persistence/sql/sqlplugin/sqlite/conn_pool.go:25
↓ 1 callersFunctionnewContext
( shardID int32, factory EngineFactory, historyConfig *configs.Config, persistenceConfig config.Persistenc
service/history/shard/context_impl.go:2036
↓ 1 callersFunctionnewContextWithTimeout
(c *cli.Context, timeout time.Duration)
tools/tdbg/util.go:186
↓ 1 callersFunctionnewCurrentBranchChanged
(st *status.Status, errDetails *errordetailsspb.CurrentBranchChangedFailure)
common/serviceerror/current_branch_changed.go:57
↓ 1 callersFunctionnewCustomServerStatsHandler
( handler stats.Handler, logger log.Logger, )
common/telemetry/grpc.go:77
↓ 1 callersFunctionnewDBMetricReporter
(dbKind DbKind, handle *DatabaseHandle)
common/persistence/sql/sqlplugin/db_metrics.go:25
↓ 1 callersFunctionnewDecodeCommands
( taskBlobEncoder TaskBlobEncoder, )
tools/tdbg/tdbg_commands.go:921
↓ 1 callersFunctionnewDefaultManagerSelector
( visibilityManager manager.VisibilityManager, secondaryVisibilityManager manager.VisibilityManager, enable
common/persistence/visibility/manager_selector.go:29
↓ 1 callersFunctionnewExecutableTracker
(grouper Grouper)
service/history/queues/tracker.go:20
↓ 1 callersFunctionnewExecutionNotifier
()
chasm/chasmtest/test_engine.go:671
↓ 1 callersFunctionnewExecutionTimerPostActionInfo
( mutableState historyi.MutableState, )
service/history/ndc_standby_task_util.go:168
↓ 1 callersFunctionnewFairTaskReader
( backlogMgr *fairBacklogManagerImpl, subqueue subqueueIndex, initialAckLevel fairLevel, )
service/matching/fair_task_reader.go:83
↓ 1 callersFunctionnewFairTaskWriter
( backlogMgr *fairBacklogManagerImpl, counterFactory func(subqueueIndex) counter.Counter, )
service/matching/fair_task_writer.go:39
↓ 1 callersFunctionnewFault
newFault returns an error based on the provided name. If the name is not recognized, then this method will panic.
common/persistence/faultinjection/fault.go:31
↓ 1 callersFunctionnewFaultInjectionClusterMetadataStore
newFaultInjectionClusterMetadataStore returns faultInjectionClusterMetadataStore.
common/persistence/faultinjection/cluster_metadata_store_gen.go:24
↓ 1 callersFunctionnewFaultInjectionExecutionStore
newFaultInjectionExecutionStore returns faultInjectionExecutionStore.
common/persistence/faultinjection/execution_store_gen.go:24
↓ 1 callersFunctionnewFaultInjectionMetadataStore
newFaultInjectionMetadataStore returns faultInjectionMetadataStore.
common/persistence/faultinjection/metadata_store_gen.go:24
↓ 1 callersFunctionnewFaultInjectionNexusEndpointStore
newFaultInjectionNexusEndpointStore returns faultInjectionNexusEndpointStore.
common/persistence/faultinjection/nexus_endpoint_store_gen.go:24
↓ 1 callersFunctionnewFaultInjectionQueue
newFaultInjectionQueue returns faultInjectionQueue.
common/persistence/faultinjection/queue_gen.go:25
↓ 1 callersFunctionnewFaultInjectionQueueV2
newFaultInjectionQueueV2 returns faultInjectionQueueV2.
common/persistence/faultinjection/queue_v2_gen.go:24
↓ 1 callersFunctionnewFaultInjectionShardStore
newFaultInjectionShardStore returns faultInjectionShardStore.
common/persistence/faultinjection/shard_store_gen.go:24
↓ 1 callersFunctionnewGRPCResolver
(monitor Monitor)
common/membership/grpc_resolver.go:72
↓ 1 callersFunctionnewGenerator
()
cmd/tools/protogen/main.go:125
↓ 1 callersFunctionnewGlobal
()
common/testing/testvars/const.go:6
↓ 1 callersFunctionnewHandler
(logger log.Logger, specBuilder *legacyscheduler.SpecBuilder)
chasm/lib/scheduler/handler.go:24
↓ 1 callersFunctionnewHistoryArchiver
( executionManager persistence.ExecutionManager, logger log.Logger, metricsHandler metrics.Handler, s3conf
common/archiver/s3store/history_archiver.go:81
↓ 1 callersFunctionnewHistoryEvent
(eventID int64, eventType enumspb.EventType)
service/matching/matching_engine_test.go:5107
↓ 1 callersFunctionnewHistoryEventCacheItem
( event *historypb.HistoryEvent, )
service/history/events/cache.go:221
↓ 1 callersFunctionnewHostScheduler
newHostScheduler creates a new task scheduler for tasks on the archival queue.
service/history/archival_queue_factory.go:68
↓ 1 callersFunctionnewInlineClientConn
( servers map[string]any, interceptors []grpc.UnaryServerInterceptor, metricsHandler metrics.Handler, name
service/frontend/http_api_server.go:356
↓ 1 callersFunctionnewInternalNexusTask
( taskID string, deadline time.Time, operationDeadline time.Time, request *matchingservice.DispatchNexusTa
service/matching/task.go:203
↓ 1 callersFunctionnewInvalidConflictResolveWorkflowWithCurrentMode
( mode ConflictResolveWorkflowMode, resetWorkflowState enumsspb.WorkflowExecutionState, currentWorkflowStat
common/persistence/operation_mode_validator.go:364
↓ 1 callersFunctionnewInvalidConflictResolveWorkflowWithCurrentWithNewMode
( mode ConflictResolveWorkflowMode, resetWorkflowState enumsspb.WorkflowExecutionState, newWorkflowState en
common/persistence/operation_mode_validator.go:377
↓ 1 callersMethodnewInvocation
( ctx context.Context, ns *namespace.Namespace, endpoint *persistencespb.NexusEndpointEntry, opRef chasm.C
chasm/lib/nexusoperation/operation_tasks.go:244
↓ 1 callersMethodnewInvocationHTTP
( ctx context.Context, ns *namespace.Namespace, endpoint *persistencespb.NexusEndpointEntry, service strin
chasm/lib/nexusoperation/invocation.go:94
↓ 1 callersMethodnewInvocationSystem
( ns *namespace.Namespace, )
chasm/lib/nexusoperation/invocation.go:182
↓ 1 callersMethodnewInvokerTaskHandlerContext
( ctx context.Context, scheduler *Scheduler, )
chasm/lib/scheduler/invoker_tasks.go:782
↓ 1 callersFunctionnewIter
(session *session, gocqlIter *gocql.Iter)
common/persistence/nosql/nosqlplugin/cassandra/gocql/iter.go:12
↓ 1 callersFunctionnewJSONHistoryTokenSerializer
newJSONHistoryTokenSerializer creates a new instance of TaskTokenSerializer
common/persistence/json_history_token_serializer.go:25
↓ 1 callersFunctionnewLocalActivities
( metadataManager persistence.MetadataManager, clusterMetadata cluster.Metadata, nexusEndpointManager persi
service/worker/deletenamespace/activities.go:43
↓ 1 callersFunctionnewLocalStorePerHostCertProviderMap
( overrides map[string]config.ServerTLS, certProviderFactory CertProviderFactory, refreshInterval time.Dura
common/rpc/encryption/local_store_per_host_cert_provider_map.go:19
↓ 1 callersFunctionnewLockedMutableState
newLockedMutableState returns a new lockedMutableState with the given mutable state, last write version and release function
service/history/archival_queue_task_executor.go:274
↓ 1 callersFunctionnewLogRecorder
newLogRecorder creates a new log recorder. It records all the logs to the given channel.
tests/acquire_shard_test.go:41
↓ 1 callersFunctionnewMatcher
(msg string, tags []tag.Tag, e *Expectation)
common/testing/testlogger/testlogger.go:96
↓ 1 callersFunctionnewMatchingTaskStoreV1
( session gocql.Session, )
common/persistence/cassandra/matching_task_store_v1.go:44
↓ 1 callersFunctionnewMatchingTaskStoreV2
( session gocql.Session, )
common/persistence/cassandra/matching_task_store_v2.go:51
↓ 1 callersFunctionnewMetadataPersistenceV2
newMetadataPersistenceV2 creates an instance of sqlMetadataManagerV2
common/persistence/sql/metadata.go:22
↓ 1 callersFunctionnewMockTaskGeneratorProvider
( mockTaskGenerator *MockTaskGenerator, )
service/history/workflow/task_refresher_test.go:1521
↓ 1 callersFunctionnewMoveGroupAction
( maxReaderCount int, grouper Grouper, moveGroupTaskCountBase int, moveGroupTaskCountMultiplier float64,
service/history/queues/action_move_group.go:16
↓ 1 callersFunctionnewMutableState
(t *testing.T)
components/callbacks/executors_test.go:269
↓ 1 callersFunctionnewMutableStateMatchEvaluator
( executionInfo *persistencespb.WorkflowExecutionInfo, executionState *persistencespb.WorkflowExecutionState
service/history/workflow/matcher/mutable_state_evaluator.go:26
↓ 1 callersFunctionnewMutexInfo
()
common/locks/id_mutex.go:57
↓ 1 callersFunctionnewMySQLQueryConverter
( namespaceName namespace.Name, namespaceID namespace.ID, saTypeMap searchattribute.NameTypeMap, saMapper
common/persistence/visibility/store/sql/query_converter_legacy_mysql.go:62
↓ 1 callersMethodnewNamespaceCacheEntry
()
service/history/workflow/mutable_state_impl_test.go:2535
↓ 1 callersFunctionnewNexusHTTPResponseWriter
(writer http.ResponseWriter, nc *nexusContext)
service/frontend/nexus_http_response_writer.go:15
↓ 1 callersFunctionnewNoopMetricsHandler
()
common/metrics/noop_impl.go:17
↓ 1 callersFunctionnewNoopMovingWindowAverage
()
common/aggregate/noop_moving_window_average.go:9
↓ 1 callersFunctionnewNoopSignalAggregator
()
common/persistence/noop_health_signal_aggregator.go:13
↓ 1 callersFunctionnewObjectWalker
(pruneTypes patterns)
common/testing/objectleak/walker.go:24
↓ 1 callersFunctionnewObsoleteDispatchBuildId
(st *status.Status)
common/serviceerror/obsolete_dispatch_build_id.go:46
↓ 1 callersFunctionnewObsoleteMatchingTask
(st *status.Status)
common/serviceerror/obsolete_matching_task.go:56
↓ 1 callersFunctionnewOwnership
( config *configs.Config, historyServiceResolver membership.ServiceResolver, hostInfoProvider membership.Ho
service/history/shard/ownership.go:40
↓ 1 callersFunctionnewPProfInitializerImpl
(logger log.Logger, port int)
tests/testcore/test_cluster.go:482
↓ 1 callersFunctionnewPollerManager
( currentShardId int32, clusterMetadata cluster.Metadata, )
service/history/replication/poller_manager.go:23
↓ 1 callersFunctionnewPostgreSQLQueryConverter
( namespaceName namespace.Name, namespaceID namespace.ID, saTypeMap searchattribute.NameTypeMap, saMapper
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:43
↓ 1 callersFunctionnewPriTaskReader
( backlogMgr *priBacklogManagerImpl, subqueue subqueueIndex, initialAckLevel int64, )
service/matching/pri_task_reader.go:66
↓ 1 callersFunctionnewPriTaskWriter
( backlogMgr *priBacklogManagerImpl, )
service/matching/pri_task_writer.go:50
↓ 1 callersFunctionnewPriorityDynamicRateLimiter
( rateFn quotas.RateFn, requestPriorityFn quotas.RequestPriorityFn, operatorRPSRatio OperatorRPSRatio, bur
common/persistence/client/quotas.go:226
↓ 1 callersFunctionnewPrometheusScope
newPrometheusScope returns a new prometheus scope with a default reporting interval of a second
common/metrics/config.go:433
↓ 1 callersMethodnewQueryTask
(id string)
service/matching/matcher_data_test.go:115
↓ 1 callersFunctionnewQueue
( db sqlplugin.DB, logger log.Logger, queueType persistence.QueueType, serializer serialization.Serializer
common/persistence/sql/queue.go:24
↓ 1 callersFunctionnewQueueFactoryBase
newQueueFactoryBase creates a new QueueFactoryBase for the archival queue, which contains common configurations like the task scheduler, task priority
service/history/archival_queue_factory.go:92
↓ 1 callersFunctionnewQueuePendingTaskAction
( attributes *AlertAttributesQueuePendingTaskCount, monitor Monitor, maxReaderCount int, grouper Grouper,
service/history/queues/action_pending_task_count.go:33
← previousnext →12,301–12,400 of 43,335, ranked by callers