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 callersFunctionserializeEvents
(serializer serialization.Serializer, events [][]*historypb.HistoryEvent)
service/history/replication/eventhandler/event_importer_test.go:218
↓ 1 callersMethodserializeEvents
(events []*historypb.HistoryEvent)
service/history/replication/eventhandler/remote_history_paginated_fetcher_test.go:256
↓ 1 callersFunctionserializeOutboundTask
( encoder Encoder, task tasks.Task, )
common/persistence/serialization/task_serializers.go:1454
↓ 1 callersMethodserializePointerNode
serializePointerNode doesn't serialize anything but named this way for consistency.
chasm/tree.go:1199
↓ 1 callersFunctionserializeQueryVisibilityToken
(token string)
common/archiver/s3store/util.go:63
↓ 1 callersFunctionserializeReplicationTask
( encoder Encoder, task tasks.Task, )
common/persistence/serialization/task_serializers.go:315
↓ 1 callersMethodserializeTaskWithCache
( registrableTask *RegistrableTask, taskValue reflect.Value, )
chasm/tree.go:3115
↓ 1 callersFunctionserializeTimerTask
( encoder Encoder, task tasks.Task, )
common/persistence/serialization/task_serializers.go:109
↓ 1 callersFunctionserializeTransferTask
( encoder Encoder, task tasks.Task, )
common/persistence/serialization/task_serializers.go:17
↓ 1 callersFunctionserializeVisibilityTask
( encoder Encoder, task tasks.Task, )
common/persistence/serialization/task_serializers.go:267
↓ 1 callersMethodserializeWorkflowEvents
( shardID int32, workflowEvents *WorkflowEvents, )
common/persistence/execution_manager.go:606
↓ 1 callersMethodserve
()
tests/mixedbrain/proxy_util.go:47
↓ 1 callersFunctionserviceNameToServiceTypeEnum
(name primitives.ServiceName)
common/membership/ringpop/monitor.go:478
↓ 1 callersFunctionserviceResolverFromGRPCURL
serviceResolverFromGRPCURL returns a ServiceResolver if ustr corresponds to a membership url, otherwise nil.
common/rpc/rpc.go:403
↓ 1 callersMethodsetCallerInfoForServerAPI
( ctx context.Context, namespaceID namespace.ID, )
service/worker/migration/activities.go:706
↓ 1 callersMethodsetComponentRequestLinks
setComponentRequestLinks records the links contributed by the given request on the component, replacing any prior entry for the same request ID. Passi
chasm/tree.go:1441
↓ 1 callersMethodsetComponentUserMetadata
setComponentUserMetadata stages a user-metadata write for the given component. Applied during CloseTransaction.
chasm/tree.go:1488
↓ 1 callersFunctionsetContainsSetIDs
Check if a set contains any of the given set IDs.
service/matching/version_sets_merge.go:29
↓ 1 callersFunctionsetDefaultParams
(params *batchspb.BatchOperationInput)
service/worker/batcher/workflow.go:281
↓ 1 callersFunctionsetDefaultStartAndEndEvent
( req *adminservice.GetWorkflowExecutionRawHistoryRequest, firstItem *historyspb.VersionHistoryItem, lastIt
service/history/api/getworkflowexecutionrawhistory/api.go:261
↓ 1 callersMethodsetDefaults
(input *BuildIdScavangerInput)
service/worker/scanner/build_ids/scavenger.go:110
↓ 1 callersMethodsetDisablingTransitionHistory
(ms *MutableStateImpl)
service/history/workflow/mutable_state_impl_test.go:4874
↓ 1 callersMethodsetEvicted
setEvicted marks the task as evicted. If it was added to a matcher it will be removed.
service/matching/task.go:353
↓ 1 callersMethodsetHasAnyBufferedEvent
(value bool)
chasm/lib/workflow/nexus_commands_test.go:50
↓ 1 callersFunctionsetHistoryForRecordWfTaskStartedResp
( ctx context.Context, shardContext historyi.ShardContext, workflowKey definition.WorkflowKey, namespaceNa
service/history/api/recordworkflowtaskstarted/api.go:261
↓ 1 callersMethodsetHistoryHandler
(handler historyservice.HistoryServiceServer)
chasm/lib/workflow/nexus_service.go:71
↓ 1 callersMethodsetKnownFairBacklogCount
Use this to reset ApproximateBacklogCount when the backlog count is known, e.g. when you're read to the end of the backlog.
service/matching/db.go:390
↓ 1 callersMethodsetNamespaceIfNotPresent
( req any, )
common/rpc/interceptor/namespace_validator.go:139
↓ 1 callersMethodsetNexusCallbackURL
()
tests/testcore/onebox.go:925
↓ 1 callersMethodsetRamp
nolint:staticcheck // SA1019
service/worker/workerdeployment/workflow.go:974
↓ 1 callersMethodsetReadLevelAfterGap
(newReadLevel int64)
service/matching/pri_task_reader.go:472
↓ 1 callersMethodsetReceiverMode
(priority enumsspb.TaskPriority)
service/history/replication/stream_receiver.go:485
↓ 1 callersFunctionsetSQLiteDatabaseName
(cfg *config.Config, databaseName string)
temporal/server_test.go:181
↓ 1 callersFunctionsetStateStatus
setStateStatus sets state and status in WorkflowExecutionState.
service/history/workflow/mutable_state_state_status.go:16
↓ 1 callersMethodsetTaskMinScheduledTime
( taskMinScheduledTime time.Time, )
service/history/shard/task_key_generator.go:161
↓ 1 callersFunctionsetTestPorts
setTestPorts sets the ports of all services to something different from the default ports.
temporal/server_test.go:190
↓ 1 callersMethodsetUserDataForNonOwningPartition
(userData *persistencespb.VersionedTaskQueueUserData)
service/matching/user_data_manager.go:861
↓ 1 callersFunctionsetWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, request *persistence.SetWorkflowExecutionRequest
service/history/workflow/transaction_impl.go:567
↓ 1 callersMethodsetWorkflowExecutionTx
( ctx context.Context, tx sqlplugin.Tx, request *p.InternalSetWorkflowExecutionRequest, )
common/persistence/sql/execution.go:721
↓ 1 callersMethodsetupActivityInfo
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:635
↓ 1 callersMethodsetupCallContext
setupCallContext creates a context with a timeout and attaches the failure source tracking value.
chasm/lib/nexusoperation/task_handler_base.go:163
↓ 1 callersMethodsetupClusterSettings
setupClusterSettings handles cluster settings configuration
tools/elasticsearch/tasks.go:31
↓ 1 callersMethodsetupDelayedCallbacks
(start time.Time, cbs []delayedCallback, state *runAcrossContinueState)
service/worker/scheduler/workflow_test.go:238
↓ 1 callersMethodsetupDryRunDatabase
sets up a temporary dryrun database for executing the cassandra schema update
tools/common/schema/updatetask.go:420
↓ 1 callersMethodsetupFrontend
()
common/rpc/test/rpc_localstore_tls_test.go:266
↓ 1 callersMethodsetupGlobalNamespaceWithOneCluster
(isRecordActive bool)
common/rpc/interceptor/dc_redirection_policy_test.go:480
↓ 1 callersMethodsetupGlobalNamespaceWithOneReplicationCluster
()
common/rpc/interceptor/dc_redirection_policy_test.go:439
↓ 1 callersMethodsetupHistoryDirectory
()
common/archiver/filestore/history_archiver_test.go:567
↓ 1 callersMethodsetupHistoryDirectory
()
common/archiver/s3store/history_archiver_test.go:683
↓ 1 callersFunctionsetupIndex
(esConfig *esclient.Config, logger log.Logger)
tests/testcore/test_cluster.go:379
↓ 1 callersMethodsetupIndex
setupIndex handles index creation. It checks if the index exists and skips creation if it does.
tools/elasticsearch/tasks.go:69
↓ 1 callersMethodsetupInternode
()
common/rpc/test/rpc_localstore_tls_test.go:382
↓ 1 callersMethodsetupInternodeRingpop
()
common/membership/ringpop/factory_test.go:205
↓ 1 callersFunctionsetupLocalKnownModules
setupLocalKnownModules replaces knownModules with specs pointing at the local bare repo, restoring the original on cleanup.
cmd/tools/check-dependencies/main_test.go:205
↓ 1 callersMethodsetupLocalNamespace
()
common/rpc/interceptor/dc_redirection_policy_test.go:428
↓ 1 callersMethodsetupMocksForWorkflows
(runs []workflowRun, state *runAcrossContinueState)
service/worker/scheduler/workflow_test.go:181
↓ 1 callersMethodsetupMutableState
(uc UsecaseConfig, ai *persistencespb.ActivityInfo)
service/history/api/respondactivitytaskfailed/api_test.go:603
↓ 1 callersMethodsetupSdk
()
tests/testcore/functional_test_base.go:423
↓ 1 callersMethodsetupShardContext
(registry namespace.Registry)
service/history/api/respondactivitytaskfailed/api_test.go:460
↓ 1 callersMethodsetupTaskMgrMocksWithErrors
()
service/worker/scanner/taskqueue/scavenger_test.go:184
↓ 1 callersMethodsetupVisibilityDirectory
()
common/archiver/filestore/visibility_archiver_test.go:566
↓ 1 callersMethodsetupVisibilityDirectory
()
common/archiver/s3store/visibility_archiver_test.go:634
↓ 1 callersMethodsetupWorkflowContext
(mutableState *historyi.MockMutableState)
service/history/api/respondactivitytaskfailed/api_test.go:446
↓ 1 callersMethodshardLingerThenClose
shardLingerThenClose delays closing the shard for a small amount of time, while watching for the shard to become invalid due to receiving a shard owne
service/history/shard/controller_impl.go:308
↓ 1 callersMethodshardRemoveAndStop
(shard historyi.ControllableContext)
service/history/shard/controller_impl.go:214
↓ 1 callersFunctionsharedClusterPersistence
(defaults persistencetests.TestBaseOptions)
tests/testcore/functional_test_base.go:370
↓ 1 callersMethodshiftWorkflowTimes
(initialSkippedDuration *durationpb.Duration)
service/history/workflow/mutable_state_impl.go:9967
↓ 1 callersMethodshouldBacklogSyncMatchTaskOnError
(err error)
service/matching/task_queue_partition_manager.go:702
↓ 1 callersMethodshouldEmitMetrics
shouldEmitMetrics determines if DLQMetricsEmitter should emit metrics. It returns true only if this instance of history service is hosting shard 1.
common/persistence/dlq_metrics_emitter.go:147
↓ 1 callersMethodshouldExcludeAllReapplyEvents
shouldExcludeAllReapplyEvents returns true if the excludeTypes map contains all the elegible re-apply event types.
service/history/ndc/workflow_resetter.go:1171
↓ 1 callersMethodshouldForceDisableEagerDispatch
(sdkName, sdkVersion string)
service/frontend/overrides.go:23
↓ 1 callersMethodshouldForwardRequest
Combines logic from RedirectionInterceptor.redirectionAllowed and some from SelectedAPIsForwardingRedirectionPolicy.getTargetClusterAndIsNamespaceNotA
service/frontend/nexus_handler.go:276
↓ 1 callersMethodshouldForwardRequest
TODO: copied from nexus_handler.go; should be combined with other intercept logic. Combines logic from RedirectionInterceptor.redirectionAllowed and s
service/frontend/nexus_completion_http_handler.go:609
↓ 1 callersMethodshouldGCLocked
()
service/matching/fair_task_reader.go:677
↓ 1 callersMethodshouldGCLocked
()
service/matching/pri_task_reader.go:505
↓ 1 callersMethodshouldProcessTask
(item tasks.Task)
service/history/replication/stream_sender.go:673
↓ 1 callersMethodshouldResubmitOnNack
(err error)
service/history/queues/executable.go:769
↓ 1 callersMethodshouldRetry
(ctx chasm.Context, overridingRetryInterval time.Duration)
chasm/lib/activity/activity.go:710
↓ 1 callersMethodshouldSyncNode
( currentNode, incomingNode *hsm.Node, )
service/history/ndc/hsm_state_replicator.go:200
↓ 1 callersFunctionshowNextPage
(wr io.Writer)
tools/tdbg/util.go:288
↓ 1 callersMethodshrink
()
service/history/queues/tracker.go:85
↓ 1 callersMethodshrinkPredicate
()
service/history/queues/slice.go:339
↓ 1 callersMethodshrinkRange
()
service/history/queues/slice.go:318
↓ 1 callersMethodshrinkSliceLowTaskCount
( readers map[int64]Reader, )
service/history/queues/action_pending_task_count.go:73
↓ 1 callersFunctionshutdownAll
(exporters []otelsdktrace.SpanExporter)
temporal/fx.go:1088
↓ 1 callersMethodsignalExternalExecution
( ctx context.Context, task *tasks.SignalExecutionTask, targetNamespace namespace.Name, targetNamespaceID
service/history/transfer_queue_active_task_executor.go:1623
↓ 1 callersMethodsignalExternalExecutionCompleted
( ctx context.Context, task *tasks.SignalExecutionTask, wfContext historyi.WorkflowContext, targetNamespac
service/history/transfer_queue_active_task_executor.go:1466
↓ 1 callersMethodsignalNewTasks
(resp subqueueCreateTasksResponse)
service/matching/pri_task_reader.go:370
↓ 1 callersMethodsignalReaders
(resp createTasksResponse)
service/matching/pri_backlog_manager.go:256
↓ 1 callersFunctionsignalRemoteCluster
( ctx context.Context, currentCluster string, clientBean client.Bean, parentExecution *commonpb.WorkflowEx
service/worker/parentclosepolicy/workflow.go:167
↓ 1 callersMethodsize
()
client/matching/partition_cache.go:138
↓ 1 callersFunctionsizeOfBlobSlice
( blobSlice []*commonpb.DataBlob, )
common/persistence/size_util.go:74
↓ 1 callersFunctionsizeOfStringSlice
( stringSlice []string, )
common/persistence/size_util.go:64
↓ 1 callersMethodskipBeforeVersion
(version workerdeployment.DeploymentWorkflowVersion)
tests/worker_deployment_test.go:3887
↓ 1 callersMethodskipBeforeVersion
(version workerdeployment.DeploymentWorkflowVersion)
tests/worker_deployment_version_test.go:919
↓ 1 callersMethodskipBeforeVersion
(version workerdeployment.DeploymentWorkflowVersion)
tests/versioning_3_test.go:7991
↓ 1 callersMethodskipFromVersion
(version DeploymentWorkflowVersion)
service/worker/workerdeployment/version_workflow_test.go:2430
↓ 1 callersMethodskipWorkflowTaskCompletedEvent
(workflowTaskType enumsspb.WorkflowTaskType, request *workflowservice.RespondWorkflowTaskCompletedRequest)
service/history/workflow/workflow_task_state_machine.go:687
↓ 1 callersMethodsleep
(nextWakeup time.Time)
service/worker/scheduler/workflow.go:755
↓ 1 callersFunctionsnakeCaseBatchType
(batchType enumspb.BatchOperationType)
service/frontend/workflow_handler.go:5806
← previousnext →12,901–13,000 of 43,335, ranked by callers