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 callersMethodwaitUpdateAdmitted
(tv *testvars.TestVars, updateID string)
tests/xdc/history_replication_signals_and_updates_test.go:710
↓ 1 callersMethodwalk
()
tools/testrunner/junit.go:367
↓ 1 callersMethodwalk
(v reflect.Value, path path)
common/testing/objectleak/walker.go:35
↓ 1 callersMethodwarn
(err error)
common/dynamicconfig/yaml_loader.go:112
↓ 1 callersMethodwarnUnmanagedFields
(fqn string, rc *RegistrableComponent)
chasm/registry.go:355
↓ 1 callersMethodwatchLoop
watchLoop processes namespace watch events and handles restarts on failure. It returns when the context is cancelled or the watch channel is closed.
common/namespace/nsregistry/registry.go:407
↓ 1 callersMethodwatchMembership
()
service/matching/matching_engine.go:378
↓ 1 callersFunctionwatchMembershipForEviction
( ctx context.Context, resolver membership.ServiceResolver, clients common.ClientCache, connectionCloseDel
client/matching/client.go:85
↓ 1 callersMethodwatchRunningStart
watchRunningStart will attach a Nexus completion callback to a running BufferedStart. If the start's workflow has already closed, the start is updated
chasm/lib/scheduler/scheduler_tasks.go:240
↓ 1 callersFunctionwatchStartRetryPolicy
watchStartRetryPolicy returns a retry policy for watch startup attempts. On initial startup (initialWatch=true), retries are limited to avoid blocking
common/namespace/nsregistry/registry.go:435
↓ 1 callersFunctionwciSpecToComputeConfig
(spec *wciiface.WorkerControllerInstanceSpec)
service/worker/workerdeployment/compute_util.go:57
↓ 1 callersMethodwireEventIDs
nolint:revive
service/history/historybuilder/event_store.go:377
↓ 1 callersFunctionwithIncreasedSkip
withIncreasedSkip increases the skip level for the given logger if it embeds a zapLogger.
common/log/slog.go:109
↓ 1 callersFunctionwithLimitChecker
(cb func(req *updatepb.Request) error)
service/history/workflow/update/update.go:144
↓ 1 callersFunctionwithMTLS
()
tests/testcore/functional_test_base.go:161
↓ 1 callersFunctionwithMockEngine
withMockEngine configures testEnv to include a mock CHASM engine for side-effect tasks.
chasm/lib/scheduler/helper_test.go:161
↓ 1 callersMethodwithNewWorkflowTask
( ctx context.Context, namespaceName namespace.Name, request *historyservice.RespondWorkflowTaskCompletedRe
service/history/api/respondworkflowtaskcompleted/api.go:905
↓ 1 callersFunctionwithSpecProcessor
withSpecProcessor configures testEnv with a custom SpecProcessor. By default, testEnv uses a real SpecProcessor. Use this option only when you need to
chasm/lib/scheduler/helper_test.go:154
↓ 1 callersMethodwithValue
Intent() OperationIntent ComponentOptions(Component) []ComponentOption withValue should only be used by ContextWithValue() function, do NOT call it di
chasm/context.go:66
↓ 1 callersFunctionwithinLimit
(value int, limit int)
service/history/api/respondworkflowtaskcompleted/workflow_size_checker.go:107
↓ 1 callersFunctionworker
worker processes jobs from the job channel
tools/flakereport/parallel.go:89
↓ 1 callersMethodworker
()
service/worker/scanner/executor/executor.go:112
↓ 1 callersFunctionworkerCommandTypeName
(cmd *workerpb.WorkerCommand)
service/history/worker_commands_task_dispatcher.go:225
↓ 1 callersMethodworkerDeploymentExists
( ctx context.Context, namespaceEntry *namespace.Namespace, deploymentName string, )
service/worker/workerdeployment/client.go:685
↓ 1 callersFunctionworkflowContextFromChasm
(ctx chasm.Context)
chasm/lib/workflow/library.go:57
↓ 1 callersMethodworkflowLeaseCallback
( ctx context.Context, )
service/history/api/multioperation/api.go:235
↓ 1 callersFunctionworkflowServiceRequestRoutingKey
workflowServiceRequestRoutingKey extracts the routing key from a WorkflowService request using field paths declared in the temporal.api.protometa.v1.r
common/rpc/interceptor/routing_key_extractor_gen.go:13
↓ 1 callersMethodworkflowStaysInBuildID
(env *testcore.TestEnv)
tests/versioning_test.go:582
↓ 1 callersFunctionworkflowVerifierProvider
()
service/worker/migration/fx.go:95
↓ 1 callersMethodwriteBatch
(reqs []*writeTaskRequest)
service/matching/fair_task_writer.go:214
↓ 1 callersFunctionwriteBisectTable
writeBisectTable writes all suspect (test, commit) pairs into a single flat table.
tools/flakereport/writer.go:122
↓ 1 callersFunctionwriteFailuresJSON
writeFailuresJSON writes failures.json containing every individual test failure (for analytics).
tools/flakereport/writer.go:15
↓ 1 callersFunctionwriteFile
Helper function to write to file
tests/testcore/history_task_recorder.go:388
↓ 1 callersFunctionwriteGitHubSummary
writeGitHubSummary writes markdown summary to GITHUB_STEP_SUMMARY (if set) and always writes to outputDir/github-report.md.
tools/flakereport/writer.go:203
↓ 1 callersMethodwriteResult
(writer http.ResponseWriter, request *http.Request, result any)
common/nexus/nexusrpc/server.go:55
↓ 1 callersMethodwriteSchedulerCHASMSentinel
writeSchedulerCHASMSentinel creates a CHASM sentinel to reserve the CHASM key space for the given schedule ID. The sentinel auto-closes after a fixed
service/frontend/workflow_handler.go:3694
↓ 1 callersMethodwriteSchedulerWorkflowSentinel
writeSchedulerWorkflowSentinel starts a dummy workflow to reserve the V1 workflow ID space for the given schedule ID. The dummy workflow sleeps for a
service/frontend/workflow_handler.go:3661
↓ 1 callersMethodwriteSummary
(out *strings.Builder)
common/testing/objectleak/report.go:181
↓ 1 callersFunctionwriteTemplatedMethod
(w io.Writer, service service, impl string, m reflect.Method, tmpl string)
cmd/tools/genrpcwrappers/main.go:405
↓ 1 callersMethodwriteToDLQ
(ctx context.Context)
service/history/queues/executable.go:376
↓ 1 callersMethodwriteVisibilityRecordForQueryTest
(record *archiverspb.VisibilityRecord)
common/archiver/filestore/visibility_archiver_test.go:634
↓ 1 callersMethodwriteVisibilityRecordForQueryTest
(visibilityArchiver *visibilityArchiver, record *archiverspb.VisibilityRecord)
common/archiver/s3store/visibility_archiver_test.go:676
↓ 1 callersMethodwroteNewTasks
(tasks []*persistencespb.AllocatedTaskInfo)
service/matching/fair_task_reader.go:372
MethodA
()
common/testing/temporalapi/public_methods_test.go:12
MethodA
()
common/testing/temporalapi/public_methods_test.go:25
MethodAbort
()
service/history/queues/speculative_workflow_task_timeout_executable.go:37
MethodAbort
Abort mocks base method.
service/history/queues/executable_mock.go:49
MethodAbort
Abort indicates an expected call of Abort.
service/history/queues/executable_mock.go:55
MethodAbort
()
service/history/queues/executable.go:638
MethodAbort
Abort mocks base method.
service/history/replication/batchable_task_mock.go:47
MethodAbort
Abort indicates an expected call of Abort.
service/history/replication/batchable_task_mock.go:53
MethodAbort
Abort mocks base method.
service/history/replication/executable_task_tracker_mock.go:47
MethodAbort
Abort indicates an expected call of Abort.
service/history/replication/executable_task_tracker_mock.go:53
MethodAbort
()
service/history/replication/executable_task.go:215
MethodAbort
Abort mocks base method.
service/history/replication/executable_task_mock.go:51
MethodAbort
Abort indicates an expected call of Abort.
service/history/replication/executable_task_mock.go:57
MethodAbort
(reason AbortReason, effects effect.Controller)
service/history/workflow/update/export_test.go:28
MethodAbort
Abort mocks base method.
common/tasks/task_mock.go:45
MethodAbort
Abort indicates an expected call of Abort.
common/tasks/task_mock.go:51
MethodAbort
Abort mocks base method.
common/tasks/task_mock.go:93
MethodAbort
Abort indicates an expected call of Abort.
common/tasks/task_mock.go:99
MethodAbort
Abort marks the task as aborted, usually means task scheduler shutdown.
common/tasks/task.go:15
MethodAbort
()
common/tasks/benchmark_test.go:96
MethodAbortAccepted
(reason AbortReason, effects effect.Controller)
service/history/workflow/update/registry.go:289
MethodAccept
()
common/testing/nettest/listener.go:22
MethodAccept
()
common/testing/nettest/pipe_benchmark_test.go:188
MethodAcceptedEventID
()
service/history/workflow/update/update.go:849
MethodAccess
(ctx context.Context, ref hsm.Ref, accessType hsm.AccessType, accessor func(*hsm.Node) error)
components/nexusoperations/helpers_test.go:28
MethodAccess
(ctx context.Context, ref hsm.Ref, accessType hsm.AccessType, accessor func(*hsm.Node) error)
components/callbacks/executors_test.go:46
MethodAck
()
service/history/queues/speculative_workflow_task_timeout_executable.go:44
MethodAck
Ack mocks base method.
service/history/queues/executable_mock.go:61
MethodAck
Ack indicates an expected call of Ack.
service/history/queues/executable_mock.go:67
MethodAck
()
service/history/queues/executable.go:656
MethodAck
Ack mocks base method.
service/history/replication/batchable_task_mock.go:59
MethodAck
Ack indicates an expected call of Ack.
service/history/replication/batchable_task_mock.go:65
MethodAck
Ack mocks base method.
service/history/replication/executable_task_tracker_mock.go:59
MethodAck
Ack indicates an expected call of Ack.
service/history/replication/executable_task_tracker_mock.go:65
MethodAck
()
service/history/replication/executable_task.go:176
MethodAck
Ack mocks base method.
service/history/replication/executable_task_mock.go:63
MethodAck
Ack indicates an expected call of Ack.
service/history/replication/executable_task_mock.go:69
MethodAck
Ack mocks base method.
common/tasks/task_mock.go:105
MethodAck
Ack indicates an expected call of Ack.
common/tasks/task_mock.go:111
MethodAck
()
common/tasks/benchmark_test.go:98
MethodAcquire
Acquire acquires the semaphore with a weight of n and a priority, blocking until resources are available or ctx is done. On success, returns nil. On f
common/locks/priority_semaphore_impl.go:83
MethodActiveClusterName
(_ RoutingKey)
common/namespace/replication_resolver.go:65
MethodActiveClusterName
ActiveClusterName observes the name of the cluster that is currently active for this namespace.
common/namespace/namespace.go:193
MethodActiveInCluster
(clusterName string)
common/namespace/replication_resolver.go:72
MethodActiveInCluster
ActiveInCluster returns whether the namespace is active in the given cluster. A namespace is considered active if it is either a local namespace or a
common/namespace/namespace.go:258
FunctionActivityExecutionStatusFromString
ActivityExecutionStatusFromString parses a ActivityExecutionStatus value from either the protojson canonical SCREAMING_CASE enum or the traditional t
chasm/lib/activity/gen/activitypb/v1/activity_state.go-helpers.pb.go:285
MethodActivityFunc
()
tests/activity_api_batch_unpause_test.go:74
MethodActivityFuncForPrePause
()
tests/activity_api_rules_test.go:111
MethodActivityFuncForRetryActivity
()
tests/activity_api_rules_test.go:88
MethodActivityFuncForRetryTask
()
tests/activity_api_rules_test.go:100
FunctionActivityInfo
ActivityInfo returns tag for activity info
common/log/tag/tags.go:911
MethodActivityInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:478
MethodActivityInfoToBlob
(info *persistencespb.ActivityInfo)
common/persistence/serialization/serializer.go:474
FunctionAdaptAuthorizeError
(permissionDeniedError *serviceerror.PermissionDenied)
common/nexus/failure.go:436
MethodAdd
Add registers a poller for a worker instance. Thread-safe.
service/matching/matching_engine.go:210
MethodAdd
(poller *waitingPoller)
service/matching/matcher_data.go:88
MethodAdd
(task *internalTask)
service/matching/matcher_data.go:163
← previousnext →13,501–13,600 of 43,335, ranked by callers