MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersFunctionNewDefaultTokenKeyProvider
(cfg *config.Authorization, logger log.Logger)
common/authorization/default_token_key_provider.go:37
↓ 1 callersFunctionNewDestinationBoolSetting
(key string, def bool, description string)
common/dynamicconfig/setting_gen.go:130
↓ 1 callersFunctionNewDestinationFloatSetting
(key string, def float64, description string)
common/dynamicconfig/setting_gen.go:402
↓ 1 callersFunctionNewDestinationTypedSetting
NewDestinationTypedSetting creates a setting that uses mapstructure to handle complex structured values. The value from dynamic config will be _merged
common/dynamicconfig/setting_gen.go:1687
↓ 1 callersFunctionNewDurationPtrTag
(key string, value *durationpb.Duration)
common/log/tag/zap_tag.go:138
↓ 1 callersFunctionNewDynamicTLSClientConfig
( getCert func() (*tls.Certificate, error), rootCAs *x509.CertPool, serverName string, enableHostVerificat
common/auth/tls_config_helper.go:39
↓ 1 callersFunctionNewDynamicWorkerPoolScheduler
NewDynamicWorkerPoolScheduler creates a [DynamicWorkerPoolScheduler] with the given limiter.
common/tasks/dynamic_worker_pool_scheduler.go:45
↓ 1 callersFunctionNewEndpointRegistryConfig
(dc *dynamicconfig.Collection)
common/nexus/endpoint_registry.go:76
↓ 1 callersFunctionNewEngine
Asserts that interface is indeed implemented NewEngine creates an instance of matching engine
service/matching/matching_engine.go:263
↓ 1 callersFunctionNewEngineWithShardContext
NewEngineWithShardContext creates an instance of history engine
service/history/history_engine.go:155
↓ 1 callersFunctionNewEventGenerator
NewEventGenerator initials the event generator
common/testing/event_generator.go:64
↓ 1 callersFunctionNewExecutableSyncVersionedTransitionTask
( processToolBox ProcessToolBox, taskID int64, taskCreationTime time.Time, sourceClusterName string, sour
service/history/replication/executable_sync_versioned_transition_task.go:37
↓ 1 callersFunctionNewExecutionManager
NewExecutionManager returns new ExecutionManager
common/persistence/execution_manager.go:43
↓ 1 callersFunctionNewExecutionPersistenceRateLimitedClient
NewExecutionPersistenceRateLimitedClient creates a client to manage executions
common/persistence/persistence_rate_limited_clients.go:125
↓ 1 callersFunctionNewExecutionStore
(session gocql.Session, serializer serialization.Serializer, logger log.Logger)
common/persistence/cassandra/execution_store.go:89
↓ 1 callersMethodNewFactory
( rpcFactory common.RPCFactory, monitor membership.Monitor, metricsHandler metrics.Handler, dc *dy
client/clientfactory.go:40
↓ 1 callersFunctionNewFactoryFromSession
NewFactoryFromSession returns an instance of a factory object from the given session.
common/persistence/cassandra/factory.go:59
↓ 1 callersMethodNewFairTaskManager
NewFairTaskManager returns a new fair task manager
common/persistence/client/factory.go:33
↓ 1 callersFunctionNewFileBasedClient
NewFileBasedClient creates a file based client. use the NewFileBasedClientWithMetrics instead if you want to collect metrics. This method is retained
common/dynamicconfig/file_based_client.go:57
↓ 1 callersFunctionNewFileExporter
(outDir string)
common/testing/testtelemetry/exporter.go:38
↓ 1 callersFunctionNewFixedAddressTranslatorPlugin
()
common/persistence/nosql/nosqlplugin/cassandra/translator/fixed_address_translator.go:24
↓ 1 callersFunctionNewFloat64
(key string, value float64)
common/log/tag/zap_tag.go:114
↓ 1 callersFunctionNewFrontendHandler
( client nexusoperationpb.NexusOperationServiceClient, config *Config, logger log.Logger, namespaceRegistr
chasm/lib/nexusoperation/frontend.go:46
↓ 1 callersFunctionNewGenerator
NewGenerator returns an initialized Generator component, which should be parented under a Scheduler root node.
chasm/lib/scheduler/generator.go:28
↓ 1 callersFunctionNewHTTPAPIServer
NewHTTPAPIServer creates an [HTTPAPIServer]. routes registered with additionalRouteRegistrationFuncs take precedence over the auto generated grpc pro
service/frontend/http_api_server.go:69
↓ 1 callersFunctionNewHealthCheckInterceptor
NewHealthCheckInterceptor creates a new health check interceptor
common/rpc/interceptor/health_check.go:113
↓ 1 callersFunctionNewHealthInterceptor
NewHealthInterceptor returns a new HealthInterceptor. It starts with state not healthy.
common/rpc/interceptor/health.go:25
↓ 1 callersFunctionNewHistoryArchiver
NewHistoryArchiver creates a new gcloud storage HistoryArchiver
common/archiver/gcloud/history_archiver.go:60
↓ 1 callersFunctionNewHistoryArchiver
NewHistoryArchiver creates a new archiver.HistoryArchiver based on filestore
common/archiver/filestore/history_archiver.go:71
↓ 1 callersFunctionNewHistoryArchiver
NewHistoryArchiver creates a new archiver.HistoryArchiver based on s3
common/archiver/s3store/history_archiver.go:72
↓ 1 callersMethodNewHistoryClientWithTimeout
(timeout time.Duration)
client/clientfactory.go:30
↓ 1 callersFunctionNewHistoryEventIDValidator
NewHistoryEventIDValidator returns new instance.
service/worker/scanner/executions/history_event_id_validator.go:29
↓ 1 callersFunctionNewHistoryEventsHandler
( clusterMetadata cluster.Metadata, eventImporter EventImporter, shardController shard.Controller, logger
service/history/replication/eventhandler/history_events_handler.go:56
↓ 1 callersFunctionNewHistoryImporter
( shardContext historyi.ShardContext, workflowCache wcache.Cache, logger log.Logger, )
service/history/ndc/history_importer.go:47
↓ 1 callersFunctionNewHistoryReplicator
( shardContext historyi.ShardContext, workflowCache wcache.Cache, eventsReapplier EventsReapplier, eventSe
service/history/ndc/history_replicator.go:122
↓ 1 callersFunctionNewHistoryStore
( session gocql.Session, serializer serialization.Serializer, )
common/persistence/cassandra/history_store.go:52
↓ 1 callersFunctionNewHistoryTaskRecorder
NewHistoryTaskRecorder creates a recorder that wraps the given ExecutionManager
tests/testcore/history_task_recorder.go:43
↓ 1 callersFunctionNewInternalClaimMapper
()
common/authorization/claim_mapper.go:68
↓ 1 callersFunctionNewInvocationTask
(destination string)
components/callbacks/tasks.go:24
↓ 1 callersFunctionNewInvoker
NewInvoker returns an initialized Invoker component, which should be parented under a Scheduler root component.
chasm/lib/scheduler/invoker.go:35
↓ 1 callersFunctionNewIsConverter
(fnInterceptor FieldNameInterceptor)
common/persistence/visibility/store/query/converter_legacy.go:171
↓ 1 callersFunctionNewLazyDLQHandler
( shard historyi.ShardContext, deleteManager deletemanager.DeleteManager, workflowCache wcache.Cache, clie
service/history/replication/dlq_handler.go:60
↓ 1 callersFunctionNewLimitedReadCloser
(rc io.ReadCloser, l int64)
components/nexusoperations/response_size_limiter.go:20
↓ 1 callersFunctionNewLoadBalancer
NewLoadBalancer returns an instance of matching load balancer that can help distribute api calls across task queue partitions
client/matching/loadbalancer.go:63
↓ 1 callersFunctionNewLocalActivities
( visibilityManager manager.VisibilityManager, metadataManager persistence.MetadataManager, namespaceCacheR
service/worker/deletenamespace/reclaimresources/activities.go:45
↓ 1 callersFunctionNewLocalActivities
( visibilityManager manager.VisibilityManager, metricsHandler metrics.Handler, logger log.Logger, )
service/worker/deletenamespace/deleteexecutions/activities.go:85
↓ 1 callersMethodNewLocalAdminClientWithTimeout
(timeout time.Duration, largeTimeout time.Duration)
client/clientfactory.go:35
↓ 1 callersFunctionNewMapEventCache
NewMapEventCache is a functional event cache mock that wraps a simple Go map
service/history/workflow/test_util.go:39
↓ 1 callersMethodNewMatchingClientWithTimeout
(namespaceIDToName NamespaceIDToNameFunc, timeout time.Duration, longPollTimeout time.Duration)
client/clientfactory.go:31
↓ 1 callersFunctionNewMetadataFromConfig
( config *Config, clusterMetadataStore persistence.ClusterMetadataManager, dynamicCollection *dynamicconfig
common/cluster/metadata.go:187
↓ 1 callersFunctionNewMetadataManagerImpl
NewMetadataManagerImpl returns new MetadataManager
common/persistence/metadata_manager.go:34
↓ 1 callersFunctionNewMetadataPersistenceMetricsClient
NewMetadataPersistenceMetricsClient creates a MetadataManager client to manage metadata
common/persistence/persistence_metric_clients.go:118
↓ 1 callersFunctionNewMetadataPersistenceRateLimitedClient
NewMetadataPersistenceRateLimitedClient creates a MetadataManager client to manage metadata
common/persistence/persistence_rate_limited_clients.go:159
↓ 1 callersFunctionNewMetadataStore
NewMetadataStore is used to create an instance of the Namespace MetadataStore implementation
common/persistence/cassandra/metadata_store.go:82
↓ 1 callersFunctionNewMetricClient
NewMetricClient creates a new instance of workflowservice.WorkflowServiceClient that emits metrics
client/frontend/metric_client.go:24
↓ 1 callersFunctionNewMetricClient
NewMetricClient creates a new instance of matchingservice.MatchingServiceClient that emits metrics
client/matching/metric_client.go:30
↓ 1 callersFunctionNewMetricClient
NewMetricClient creates a new instance of historyservice.HistoryServiceClient that emits metrics
client/history/metric_client.go:26
↓ 1 callersFunctionNewMetricClient
NewMetricClient creates a new instance of adminservice.AdminServiceClient that emits metrics
client/admin/metric_client.go:25
↓ 1 callersFunctionNewMockArchiver
NewMockArchiver creates a new mock instance.
service/history/archival/archiver_mock.go:32
↓ 1 callersFunctionNewMockAuthorizer
NewMockAuthorizer creates a new mock instance.
common/authorization/authorizer_mock.go:32
↓ 1 callersFunctionNewMockBranchMgr
NewMockBranchMgr creates a new mock instance.
service/history/ndc/branch_manager_mock.go:33
↓ 1 callersFunctionNewMockClaimMapper
NewMockClaimMapper creates a new mock instance.
common/authorization/claim_mapper_mock.go:31
↓ 1 callersFunctionNewMockClient
NewMockClient creates a new mock instance.
service/worker/parentclosepolicy/client_mock.go:32
↓ 1 callersFunctionNewMockClusterMetadataStore
NewMockClusterMetadataStore creates a new mock instance.
common/persistence/mock/store_mock.go:720
↓ 1 callersFunctionNewMockComponent
NewMockComponent creates a new mock instance.
chasm/component_mock.go:31
↓ 1 callersFunctionNewMockCustomHistoryArchiverFactory
NewMockCustomHistoryArchiverFactory creates a new mock instance.
common/archiver/provider/provider_mock.go:86
↓ 1 callersFunctionNewMockCustomVisibilityArchiverFactory
NewMockCustomVisibilityArchiverFactory creates a new mock instance.
common/archiver/provider/provider_mock.go:125
↓ 1 callersFunctionNewMockEncodedValue
NewMockEncodedValue creates a new mock instance.
common/testing/mocksdk/value_mock.go:25
↓ 1 callersFunctionNewMockEngineFactory
NewMockEngineFactory creates a new mock instance.
service/history/shard/engine_factory_mock.go:32
↓ 1 callersFunctionNewMockHistoryEventsHandler
NewMockHistoryEventsHandler creates a new mock instance.
service/history/replication/eventhandler/history_events_handler_mock.go:36
↓ 1 callersFunctionNewMockManager
NewMockManager creates a new mock instance.
common/searchattribute/search_attribute_mock.go:72
↓ 1 callersFunctionNewMockMetadataStore
NewMockMetadataStore creates a new mock instance.
common/persistence/mock/store_mock.go:554
↓ 1 callersFunctionNewMockMutableStateRebuilder
NewMockMutableStateRebuilder creates a new mock instance.
service/history/workflow/mutable_state_rebuilder_mock.go:36
↓ 1 callersFunctionNewMockNexusEndpointStore
NewMockNexusEndpointStore creates a new mock instance.
common/persistence/mock/store_mock.go:1506
↓ 1 callersFunctionNewMockPartitionScaler
NewMockPartitionScaler creates a new mock instance.
service/matching/partition_scaler_mock.go:71
↓ 1 callersFunctionNewMockProcessor
NewMockProcessor creates a new mock instance.
common/persistence/visibility/store/elasticsearch/processor_mock.go:33
↓ 1 callersFunctionNewMockProgressCache
NewMockProgressCache creates a new mock instance.
service/history/replication/progress_cache_mock.go:33
↓ 1 callersFunctionNewMockReaderWrapper
NewMockReaderWrapper creates a new mock instance.
common/archiver/gcloud/connector/client_delegate_mock.go:273
↓ 1 callersFunctionNewMockReceiverFlowController
NewMockReceiverFlowController creates a new mock instance.
service/history/replication/stream_receiver_flow_controller_mock.go:32
↓ 1 callersFunctionNewMockResendHandler
NewMockResendHandler creates a new mock instance.
service/history/replication/eventhandler/resend_handler_mock.go:33
↓ 1 callersFunctionNewMockSenderFlowController
NewMockSenderFlowController creates a new mock instance.
service/history/replication/stream_sender_flow_controller_mock.go:34
↓ 1 callersFunctionNewMockShardStore
NewMockShardStore creates a new mock instance.
common/persistence/mock/store_mock.go:205
↓ 1 callersFunctionNewMockSourceTaskConverter
NewMockSourceTaskConverter creates a new mock instance.
service/history/replication/raw_task_converter_mock.go:34
↓ 1 callersFunctionNewMockTaskFetcherFactory
NewMockTaskFetcherFactory creates a new mock instance.
service/history/replication/task_fetcher_mock.go:32
↓ 1 callersFunctionNewMockTaskStore
NewMockTaskStore creates a new mock instance.
common/persistence/mock/store_mock.go:312
↓ 1 callersFunctionNewMockTransaction
NewMockTransaction creates a new mock instance.
service/history/workflow/transaction_mock.go:34
↓ 1 callersFunctionNewMockVisibilityManager
NewMockVisibilityManager creates a new mock instance.
chasm/visibility_manager_mock.go:33
↓ 1 callersFunctionNewMockVisibilityStore
NewMockVisibilityStore creates a new mock instance.
common/persistence/visibility/store/visibility_store_mock.go:34
↓ 1 callersFunctionNewMockWorkflowStateReplicator
NewMockWorkflowStateReplicator creates a new mock instance.
service/history/ndc/workflow_state_replicator_mock.go:35
↓ 1 callersFunctionNewMockmanagerSelector
NewMockmanagerSelector creates a new mock instance.
common/persistence/visibility/manager_selector_mock.go:33
↓ 1 callersFunctionNewMockphysicalTaskQueueManager
NewMockphysicalTaskQueueManager creates a new mock instance.
service/matching/physical_task_queue_manager_mock.go:38
↓ 1 callersFunctionNewMockscaleDB
NewMockscaleDB creates a new mock instance.
service/matching/scale_manager_mock.go:32
↓ 1 callersFunctionNewMocktaskFetcher
NewMocktaskFetcher creates a new mock instance.
service/history/replication/task_fetcher_mock.go:94
↓ 1 callersFunctionNewMocktransactionMgrForExistingWorkflow
NewMocktransactionMgrForExistingWorkflow creates a new mock instance.
service/history/ndc/transaction_manager_existing_workflow_mock.go:33
↓ 1 callersFunctionNewMocktransactionMgrForNewWorkflow
NewMocktransactionMgrForNewWorkflow creates a new mock instance.
service/history/ndc/transaction_manager_new_workflow_mock.go:33
↓ 1 callersFunctionNewMockuserDataManager
NewMockuserDataManager creates a new mock instance.
service/matching/user_data_manager_mock.go:35
↓ 1 callersFunctionNewMutableStateInitializer
( shardContext historyi.ShardContext, workflowCache wcache.Cache, logger log.Logger, )
service/history/ndc/mutable_state_initializer.go:57
↓ 1 callersFunctionNewMutableStateStore
(session gocql.Session, serializer serialization.Serializer, logger log.Logger)
common/persistence/cassandra/mutable_state_store.go:375
↓ 1 callersFunctionNewMutableStateTaskStore
(session gocql.Session, serializer serialization.Serializer)
common/persistence/cassandra/mutable_state_task_store.go:170
↓ 1 callersFunctionNewMutableStateValidator
NewMutableStateValidator returns new instance.
service/worker/scanner/executions/mutable_state_validator.go:40
← previousnext →10,201–10,300 of 43,335, ranked by callers