MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 2 callersFunctionloseUpdateRegistryAndAbandonPendingUpdates
(s *testcore.TestEnv, tv *testvars.TestVars)
tests/update_workflow_test.go:52
↓ 2 callersFunctionmakeBufferedEvent
(signalNameSize int)
service/history/historybuilder/history_builder_test.go:2712
↓ 2 callersFunctionmakeCacheKey
( runID string, targetClusterID int32, )
service/history/replication/progress_cache.go:215
↓ 2 callersMethodmakeInternalChasmNodeMap
( nodes map[string]*persistencespb.ChasmNode, )
common/persistence/execution_manager.go:1358
↓ 2 callersFunctionmakeNewVersionState
( deploymentName, buildID string, createTime time.Time, identity string, initialStatus enumspb.WorkerDeplo
service/worker/workerdeployment/util.go:447
↓ 2 callersFunctionmakeSeeds
(rows int, src rand.Source)
service/matching/counter/cmsketch.go:249
↓ 2 callersMethodmakeVersionWorkflowArgs
( deploymentName, buildID string, namespaceEntry *namespace.Namespace, identity string, initialStatus enum
service/worker/workerdeployment/client.go:2090
↓ 2 callersFunctionmakeYearMatcher
(ranges []*schedulepb.Range)
service/worker/scheduler/calendar.go:351
↓ 2 callersFunctionmarshalIndent
(v any)
tools/ci-notify/app.go:237
↓ 2 callersMethodmaskUnknownOrInternalErrors
( req any, fullMethodName string, err error, )
common/rpc/interceptor/mask_internal_error.go:67
↓ 2 callersFunctionmatchAndConvertCvs
( c *Collection, key Key, def T, convert func(value any) (T, error), precedence []Constraints, cvs []Con
common/dynamicconfig/collection.go:287
↓ 2 callersMethodmatchAny
(values ...string)
common/testing/objectleak/pattern.go:46
↓ 2 callersFunctionmatchQuery
(record *archiverspb.VisibilityRecord, query *parsedQuery)
common/archiver/filestore/visibility_archiver.go:305
↓ 2 callersFunctionmatchRemoteClusterKey
matchRemoteClusterKey checks exact matches, then finds the match with the most non-wildcard characters
common/rpc/encryption/local_store_tls_provider.go:482
↓ 2 callersMethodmatches
(value string)
common/testing/objectleak/pattern.go:24
↓ 2 callersMethodmatchingRequest
(req *nexuspb.Request)
service/frontend/nexus_handler.go:122
↓ 2 callersFunctionmaxShardTime
(smap map[string]float64, shards int, salt string)
tools/optimize-test-sharding/main.go:282
↓ 2 callersFunctionmaybeKickoffTaskQueueUserDataReplication
(ctx workflow.Context, params ForceReplicationParams, onDone func(failureReason string))
service/worker/migration/force_replication_workflow.go:280
↓ 2 callersMethodmergeByPredicate
(incomingSlice *SliceImpl)
service/history/queues/slice.go:215
↓ 2 callersMethodmergeEphemeralDataLocked
()
service/matching/user_data_manager.go:837
↓ 2 callersMethodmergeMessagesWithoutBlocking
mergeMessages from the DLQ up to and including the specified message ID, returns immediately after running tdbg command.
tests/dlq_test.go:483
↓ 2 callersFunctionmergeStatsByPriority
(into, from map[int32]*taskqueuepb.TaskQueueStats)
service/matching/task_queue_partition_manager.go:1825
↓ 2 callersMethodmergeTasks
(tasks []*persistencespb.AllocatedTaskInfo, mode mergeMode)
service/matching/fair_task_reader.go:376
↓ 2 callersMethodmergeTasksLocked
nolint:revive,cognitive-complexity // will be simplified in the future
service/matching/fair_task_reader.go:410
↓ 2 callersMethodmethod
(storeName DataStoreName, methodName string)
common/config/config.go:841
↓ 2 callersFunctionmigrateOne
migrateOne migrates a single schedule (or prints the planned action in dry-run), updating summary. It is safe to call concurrently from multiple worke
tools/tdbg/commands.go:1142
↓ 2 callersFunctionmigrateScheduleRPC
( ctx context.Context, adminClient adminservice.AdminServiceClient, ns string, scheduleID string, target
tools/tdbg/commands.go:1163
↓ 2 callersFunctionmkNewAssignmentPercentageRamp
(percent float32)
service/matching/version_rule_test.go:110
↓ 2 callersFunctionmkRedirectRulesMap
(redirectRules []*taskqueuepb.TimestampedCompatibleBuildIdRedirectRule)
tests/versioning_test.go:350
↓ 2 callersMethodmockHistoryWhilePolling
(workflowType *commonpb.WorkflowType)
service/matching/matching_engine_test.go:3589
↓ 2 callersMethodmockWorkflowWithErrorActivity
(activityInfo chan<- activity.Info, sdkClient sdkclient.Client, taskQueue string)
tests/activity_test.go:1488
↓ 2 callersMethodmustGenerateTaskID
()
service/history/outbound_queue_active_task_executor_test.go:267
↓ 2 callersFunctionmustParent
(p Partition, n int)
common/tqid/task_queue_id_test.go:332
↓ 2 callersFunctionmustParseMAC
(s string)
common/config/localip.go:73
↓ 2 callersFunctionmustParseNormalPartition
(t *testing.T, rpcName string, taskType enumspb.TaskQueueType)
common/tqid/task_queue_id_test.go:324
↓ 2 callersFunctionmutableStateFromRow
( result map[string]any, )
common/persistence/cassandra/mutable_state_store.go:1110
↓ 2 callersFunctionmutationToCompletionMetric
( namespaceState string, workflowMutation *persistence.WorkflowMutation, isWorkflow bool, )
service/history/workflow/transaction_impl.go:762
↓ 2 callersFunctionmutualGroupTLSFromChain
(chain testutils.CertChain)
common/rpc/test/rpc_localstore_tls_test.go:241
↓ 2 callersMethodnamespaceEntry
(activeCluster string)
service/history/replication/executable_delete_execution_task_test.go:143
↓ 2 callersMethodnamespaceRowToGetNamespaceResponse
(row *sqlplugin.NamespaceRow)
common/persistence/sql/metadata.go:118
↓ 2 callersMethodnamespaceStateChanged
(oldNS *namespace.Namespace, newNS *namespace.Namespace)
common/namespace/nsregistry/registry.go:896
↓ 2 callersMethodneedRefreshCache
(saCache cache, forceRefreshCache bool, now time.Time)
common/searchattribute/manager.go:91
↓ 2 callersMethodneedToSend
needToSend returns true if outgoing message can be generated for the current Update state. If includeAlreadySent is set to true, then it will return t
service/history/workflow/update/update.go:551
↓ 2 callersFunctionnewAckManager
(db *taskQueueDB, logger log.Logger)
service/matching/ack_manager.go:24
↓ 2 callersMethodnewActivitiesWithParams
(params dynamicconfig.ScheduleInvariantsScannerParams)
service/worker/scanner/scheduleinvariants/invariants_test.go:64
↓ 2 callersMethodnewAdminClient
( client adminservice.AdminServiceClient, timeout time.Duration, longPollTimeout time.Duration, )
client/clientfactory.go:193
↓ 2 callersFunctionnewAdmitted
(id string, request *anypb.Any, opts ...updateOpt)
service/history/workflow/update/update.go:85
↓ 2 callersFunctionnewBackfillerWithState
(ctx chasm.MutableContext, state *schedulerpb.BackfillerState)
chasm/lib/scheduler/backfiller.go:54
↓ 2 callersFunctionnewBacklogManager
( tqCtx context.Context, pqMgr physicalTaskQueueManager, config *taskQueueConfig, taskManager persistence.
service/matching/backlog_manager.go:80
↓ 2 callersFunctionnewBatch
( session *session, gocqlBatch *gocql.Batch, )
common/persistence/nosql/nosqlplugin/cassandra/gocql/batch.go:25
↓ 2 callersFunctionnewCVChannel
()
common/locks/condition_variable_impl.go:84
↓ 2 callersFunctionnewCancellationTaskTestEnv
( t *testing.T, op *Operation, cancellation *Cancellation, invocationData InvocationData, endpointReg nex
chasm/lib/nexusoperation/cancellation_tasks_test.go:48
↓ 2 callersFunctionnewClientDelegateWithCredentials
(ctx context.Context, credentialsPath string)
common/archiver/gcloud/connector/client_delegate.go:88
↓ 2 callersFunctionnewClientRetryPolicy
(initialInterval time.Duration, maxAttempts int, retryUnboundedOnSystemResourceExhausted func() bool)
common/util.go:190
↓ 2 callersMethodnewClientTrace
nolint:revive // cognitive complexity (> 25 max) but is just adding a logging function for each method in the list.
common/nexus/trace.go:105
↓ 2 callersFunctionnewComponentOnlyLibrary
( config *Config, namespaceRegistry namespace.Registry, )
chasm/lib/activity/library.go:43
↓ 2 callersFunctionnewConfig
()
common/testing/await/config.go:19
↓ 2 callersMethodnewConn
(serviceName primitives.ServiceName)
tests/testcore/clients.go:134
↓ 2 callersFunctionnewConnectionSuite
( t *testing.T, factory *sql.Factory, )
common/persistence/tests/persistence_connection_suite.go:26
↓ 2 callersFunctionnewContext
newContext creates a new immutableCtx from an existing Context and root Node. This is similar to NewContext, but returns *immutableCtx instead of Cont
chasm/context.go:141
↓ 2 callersFunctionnewDB
newDB returns an instance of DB, which is a logical connection to the underlying postgresql database
common/persistence/sql/sqlplugin/postgresql/db.go:46
↓ 2 callersFunctionnewDB
newDB returns an instance of DB, which is a logical connection to the underlying mysql database
common/persistence/sql/sqlplugin/mysql/db.go:60
↓ 2 callersFunctionnewDLQHandler
( shard historyi.ShardContext, deleteManager deletemanager.DeleteManager, workflowCache wcache.Cache, clie
service/history/replication/dlq_handler.go:77
↓ 2 callersMethodnewDefaultRateLimiter
()
service/matching/matcher_test.go:60
↓ 2 callersFunctionnewEndpointClient
( endpointsRefreshInterval dynamicconfig.DurationPropertyFn, persistence p.NexusEndpointManager, )
service/matching/nexus_endpoint_client.go:73
↓ 2 callersFunctionnewErrorLogDetector
newErrorLogDetector returns a logger that fails the test if it logs any errors or warnings, except for the ones that are expected. Ideally, there are
temporal/server_test.go:304
↓ 2 callersMethodnewExecution
(key chasm.ExecutionKey)
chasm/chasmtest/test_engine.go:505
↓ 2 callersFunctionnewFaultInjectionTaskStore
newFaultInjectionTaskStore returns faultInjectionTaskStore.
common/persistence/faultinjection/task_store_gen.go:24
↓ 2 callersFunctionnewFieldNameAggInterceptor
( namespaceName namespace.Name, saNameType searchattribute.NameTypeMap, saMapperProvider searchattribute.Ma
service/worker/scheduler/query.go:32
↓ 2 callersMethodnewFrontendClient
( client workflowservice.WorkflowServiceClient, timeout time.Duration, longPollTimeout time.Duration, )
client/clientfactory.go:205
↓ 2 callersFunctionnewGeneratorWithState
(ctx chasm.MutableContext, state *schedulerpb.GeneratorState)
chasm/lib/scheduler/generator.go:37
↓ 2 callersFunctionnewHeaderCaptureCaller
()
tests/nexus_api_test.go:38
↓ 2 callersFunctionnewHistoryArchiver
( executionManager persistence.ExecutionManager, logger log.Logger, metricsHandler metrics.Handler, config
common/archiver/filestore/history_archiver.go:80
↓ 2 callersMethodnewHrsuTestCluster
(ns string, cluster *testcore.TestCluster)
tests/xdc/history_replication_signals_and_updates_test.go:113
↓ 2 callersFunctionnewInvalidConflictResolveWorkflowMode
( mode ConflictResolveWorkflowMode, resetWorkflowState enumsspb.WorkflowExecutionState, )
common/persistence/operation_mode_validator.go:340
↓ 2 callersFunctionnewInvalidConflictResolveWorkflowWithNewMode
( mode ConflictResolveWorkflowMode, resetWorkflowState enumsspb.WorkflowExecutionState, newWorkflowState en
common/persistence/operation_mode_validator.go:351
↓ 2 callersFunctionnewInvalidCreateWorkflowMode
( mode CreateWorkflowMode, workflowState enumsspb.WorkflowExecutionState, )
common/persistence/operation_mode_validator.go:305
↓ 2 callersFunctionnewInvalidUpdateWorkflowMode
( mode UpdateWorkflowMode, currentWorkflowState enumsspb.WorkflowExecutionState, )
common/persistence/operation_mode_validator.go:316
↓ 2 callersMethodnewInvocation
newInvocation creates an invocation for the given endpoint, selecting the appropriate implementation based on the call timeout and endpoint type.
chasm/lib/nexusoperation/task_handler_base.go:122
↓ 2 callersFunctionnewInvocationResult
( response *nexusrpc.ClientStartOperationResponse[*commonpb.Payload], callErr error, )
chasm/lib/nexusoperation/task_handler_helpers.go:227
↓ 2 callersFunctionnewInvocationTaskTestEnv
( t *testing.T, op *Operation, invocationData InvocationData, endpointReg nexustest.FakeEndpointRegistry,
chasm/lib/nexusoperation/operation_tasks_test.go:56
↓ 2 callersFunctionnewInvokerWithState
(ctx chasm.MutableContext, state *schedulerpb.InvokerState)
chasm/lib/scheduler/invoker.go:41
↓ 2 callersFunctionnewJSONContainsExpr
( jsonExpr sqlparser.Expr, valueExpr sqlparser.Expr, )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:237
↓ 2 callersMethodnewJsonContainsExpr
( jsonExpr sqlparser.Expr, valueExpr sqlparser.Expr, )
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:190
↓ 2 callersFunctionnewMapper
( getAlias func(fieldName, ns string) (string, error), getFieldName func(alias, ns string) (string, error),
common/persistence/visibility/store/sql/query_converter_legacy_test.go:1085
↓ 2 callersFunctionnewMemoryScheduledQueue
( scheduler ctasks.Scheduler[ctasks.Task], timeSource clock.TimeSource, logger log.Logger, metricsHandler
service/history/queues/memory_scheduled_queue.go:39
↓ 2 callersFunctionnewMethodFaultGenerator
(faults []fault, seed int64)
common/persistence/faultinjection/method_fault_generator.go:24
↓ 2 callersFunctionnewMitigator
( readerGroup *ReaderGroup, monitor Monitor, logger log.Logger, metricsHandler metrics.Handler, maxReader
service/history/queues/mitigator.go:38
↓ 2 callersFunctionnewMonitor
newMonitor returns a ringpop-based membership monitor
common/membership/ringpop/monitor.go:75
↓ 2 callersFunctionnewMutableStateChecksumPayload
(ms historyi.MutableState)
service/history/workflow/checksum.go:38
↓ 2 callersFunctionnewNDCTransactionMgrForExistingWorkflow
( shardContext historyi.ShardContext, transactionMgr TransactionManager, bypassVersionSemanticsCheck bool,
service/history/ndc/transaction_manager_existing_workflow.go:37
↓ 2 callersFunctionnewNamespaceHandler
newNamespaceHandler create a new namespace handler
service/frontend/namespace_handler.go:69
↓ 2 callersFunctionnewNexusEndpointClient
( config *nexusEndpointClientConfig, namespaceRegistry namespace.Registry, matchingClient matchingservice.M
service/frontend/nexus_endpoint_client.go:70
↓ 2 callersFunctionnewNexusEndpointClientConfig
(dc *dynamicconfig.Collection)
service/frontend/nexus_endpoint_client.go:55
↓ 2 callersFunctionnewNexusEndpointStore
(session gocql.Session, opts ...func(params *testQueueParams))
common/persistence/tests/cassandra_test.go:1557
↓ 2 callersFunctionnewNexusLibrary
(config *nexusoperation.Config, nexusProcessor *chasm.NexusEndpointProcessor)
chasm/lib/workflow/nexus_library.go:14
↓ 2 callersFunctionnewOpNode
newOpNode creates a new operation tree node with the given key.
service/history/hsm/tree.go:775
↓ 2 callersFunctionnewOpenTelemetryProvider
( logger log.Logger, reader sdkmetrics.Reader, statsdConfig *StatsdConfig, statsdExporter *statsdExporter,
common/metrics/opentelemetry_provider.go:86
↓ 2 callersFunctionnewOutboundQueueActiveTaskExecutor
( shardCtx historyi.ShardContext, workflowCache wcache.Cache, logger log.Logger, metricsHandler metrics.Ha
service/history/outbound_queue_active_task_executor.go:34
↓ 2 callersFunctionnewParentWithChildContinueAsNew
( s *ContinueAsNewTestSuite, env *testcore.TestEnv, parentID, parentType, childID, childType string, close
tests/continue_as_new_test.go:614
← previousnext →8,501–8,600 of 43,335, ranked by callers