Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/temporalio/temporal
/ functions
Functions
43,335 in github.com/temporalio/temporal
⨍
Functions
43,335
◇
Types & classes
5,614
↓ 1 callers
Method
getVisibilityTasks
( ctx context.Context, request *p.GetHistoryTasksRequest, )
common/persistence/cassandra/mutable_state_task_store.go:620
↓ 1 callers
Method
getWFTFailure
(admin adminservice.AdminServiceClient, ns, wfid, runid string)
tests/xdc/workflow_task_reported_problems_test.go:98
↓ 1 callers
Method
getWorkerAllocation
(args refreshArgs)
service/worker/pernamespaceworker.go:268
↓ 1 callers
Method
getWorkerByNamespace
(ns *namespace.Namespace)
service/worker/pernamespaceworker.go:234
↓ 1 callers
Method
getWorkerHeartbeat
(nsID namespace.ID, workerInstanceKey string)
service/matching/workers/registry_impl.go:169
↓ 1 callers
Method
getWorkerTaskReachabilityValidated
Implementation of the GetWorkerTaskReachability API. Expects an already validated request.
service/frontend/task_reachability.go:65
↓ 1 callers
Function
getWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, request *persistence.GetWorkflowExecutionRequest
service/history/workflow/transaction_impl.go:468
↓ 1 callers
Function
getWorkflowID
getWorkflowID extracts the workflow ID from the schedule's action. This is the workflow ID specified in the schedule spec. During workflow start gener
chasm/lib/scheduler/migration/migration.go:386
↓ 1 callers
Method
getWorkflowLease
(ctx context.Context)
service/history/api/multioperation/api.go:286
↓ 1 callers
Function
getWorkflowMemo
( memoFields map[string]*commonpb.Payload, )
service/history/visibility_queue_task_executor.go:666
↓ 1 callers
Method
getWriteBatch
(reqs []*writeTaskRequest)
service/matching/pri_task_writer.go:182
↓ 1 callers
Method
getWriteBatch
(reqs []*writeTaskRequest)
service/matching/task_writer.go:182
↓ 1 callers
Method
getWriteBatch
(reqs []*writeTaskRequest)
service/matching/fair_task_writer.go:202
↓ 1 callers
Function
goTestNameToRunFlagRegexp
(test string)
tools/testrunner/testrunner.go:468
↓ 1 callers
Method
gotIncomingEphemeralData
(eph *taskqueuespb.VersionedEphemeralData)
service/matching/user_data_manager.go:783
↓ 1 callers
Method
grpcAddress
(serviceName primitives.ServiceName)
tests/testcore/clients.go:147
↓ 1 callers
Method
handleActivityTask
( ctx context.Context, task *replicationspb.ReplicationTask, forceApply bool, )
service/history/replication/task_executor.go:105
↓ 1 callers
Method
handleCommandCancelTimer
( _ context.Context, attr *commandpb.CancelTimerCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:908
↓ 1 callers
Method
handleCommandCancelWorkflow
( ctx context.Context, attr *commandpb.CancelWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:934
↓ 1 callers
Method
handleCommandCompleteWorkflow
( ctx context.Context, attr *commandpb.CompleteWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:783
↓ 1 callers
Method
handleCommandContinueAsNewWorkflow
( ctx context.Context, attr *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1029
↓ 1 callers
Method
handleCommandFailWorkflow
( ctx context.Context, attr *commandpb.FailWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:838
↓ 1 callers
Method
handleCommandModifyWorkflowProperties
( _ context.Context, attr *commandpb.ModifyWorkflowPropertiesCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1364
↓ 1 callers
Method
handleCommandProtocolMessage
( ctx context.Context, attr *commandpb.ProtocolMessageCommandAttributes, msgs *collection.IndexedTakeList[s
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:434
↓ 1 callers
Method
handleCommandRecordMarker
( _ context.Context, attr *commandpb.RecordMarkerCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1004
↓ 1 callers
Method
handleCommandRequestCancelExternalWorkflow
( _ context.Context, attr *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:964
↓ 1 callers
Method
handleCommandScheduleActivity
( _ context.Context, attr *commandpb.ScheduleActivityTaskCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:463
↓ 1 callers
Method
handleCommandSignalExternalWorkflow
( _ context.Context, attr *commandpb.SignalExternalWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1248
↓ 1 callers
Method
handleCommandStartChildWorkflow
( _ context.Context, attr *commandpb.StartChildWorkflowExecutionCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1138
↓ 1 callers
Method
handleCommandStartTimer
( _ context.Context, attr *commandpb.StartTimerCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:764
↓ 1 callers
Method
handleCommandUpsertWorkflowSearchAttributes
( _ context.Context, attr *commandpb.UpsertWorkflowSearchAttributesCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1296
↓ 1 callers
Method
handleCommands
( ctx context.Context, commands []*commandpb.Command, msgs *collection.IndexedTakeList[string, *protocolpb.
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:168
↓ 1 callers
Method
handleConflict
handleConflict handles CurrentWorkflowConditionFailedError where there's a workflow with the same workflowID. This may happen either when the currentl
service/history/api/startworkflow/api.go:321
↓ 1 callers
Method
handleConflictPolicy
( _ context.Context, _ historyi.ShardContext, newExecutionParams newExecutionParams, currentRunInfo curren
service/history/chasm_engine.go:1016
↓ 1 callers
Method
handleConflictPolicy
handleConflictPolicy is called when a StartExecution arrives for a business ID whose current run is still running.
chasm/chasmtest/test_engine.go:345
↓ 1 callers
Method
handleErr
( err error, )
service/worker/scanner/history/scavenger.go:291
↓ 1 callers
Method
handleFailures
( mutableState *MutableState, results []MutableStateValidationResult, )
service/worker/scanner/executions/task.go:206
↓ 1 callers
Method
handleFirstReplicationTaskWithNewRun
( ctx context.Context, archetypeID chasm.ArchetypeID, wfCtx historyi.WorkflowContext, executionInfo *persi
service/history/ndc/workflow_state_replicator.go:490
↓ 1 callers
Method
handleFirstReplicationTaskWithoutNewRun
( ctx context.Context, archetypeID chasm.ArchetypeID, wfCtx historyi.WorkflowContext, executionInfo *persi
service/history/ndc/workflow_state_replicator.go:407
↓ 1 callers
Method
handleHistoryReplicationTask
( ctx context.Context, task *replicationspb.ReplicationTask, forceApply bool, )
service/history/replication/task_executor.go:207
↓ 1 callers
Method
handleNamespaceUpdateReplicationTask
handleNamespaceUpdateReplicationTask handles the namespace update replication task
common/namespace/nsreplication/replication_task_executor.go:249
↓ 1 callers
Method
handlePostCommandEagerExecuteActivity
( _ context.Context, attr *commandpb.ScheduleActivityTaskCommandAttributes, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:570
↓ 1 callers
Function
handlePredefinedCronStrings
(c string)
service/worker/scheduler/calendar.go:327
↓ 1 callers
Method
handleQuery
( ctx context.Context, task *workflowservice.PollWorkflowTaskQueueResponse, handler func(task *workflowserv
common/testing/taskpoller/taskpoller.go:420
↓ 1 callers
Method
handleRemoteGeneratedHistoryEvents
( ctx context.Context, workflowKey definition.WorkflowKey, baseExecutionInfo *workflowspb.BaseExecutionInfo
service/history/replication/eventhandler/history_events_handler.go:199
↓ 1 callers
Method
handleReplicationTask
( ctx context.Context, task *replicationspb.ReplicationTask, )
service/worker/replicator/replication_message_processor.go:237
↓ 1 callers
Method
handleReplicationTasks
()
service/worker/replicator/replication_message_processor.go:142
↓ 1 callers
Method
handleRetry
( ctx context.Context, backoffInterval time.Duration, failure *failurepb.Failure, newRunID string, )
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:1421
↓ 1 callers
Method
handleReusePolicy
( ctx context.Context, shardContext historyi.ShardContext, newExecutionParams newExecutionParams, currentR
service/history/chasm_engine.go:1065
↓ 1 callers
Method
handleReusePolicy
handleReusePolicy is called when a StartExecution arrives for a business ID whose current run is closed or completed.
chasm/chasmtest/test_engine.go:387
↓ 1 callers
Method
handleSolError
(opEntry cacheEntry[C], solErr *serviceerrors.ShardOwnershipLost)
client/history/caching_redirector.go:200
↓ 1 callers
Method
handleStartOperationError
handleStartOperationError resolves a failed StartOperation attempt by transitioning the operation to its resulting state: terminally failed/canceled/t
components/nexusoperations/executors.go:533
↓ 1 callers
Method
handleSyncWorkflowStateTask
( ctx context.Context, task *replicationspb.ReplicationTask, forceApply bool, )
service/history/replication/task_executor.go:301
↓ 1 callers
Method
handleTask
( ctx context.Context, task taskDetail, )
service/worker/scanner/history/scavenger.go:251
↓ 1 callers
Method
handleTask
( ctx context.Context, opts *options, task *workflowservice.PollNexusTaskQueueResponse, handler func(task
common/testing/taskpoller/taskpoller.go:190
↓ 1 callers
Method
handleTaskQueueUserDataReplicationTask
( ctx context.Context, attrs *replicationspb.TaskQueueUserDataAttributes, )
service/worker/replicator/replication_message_processor.go:275
↓ 1 callers
Method
handleUseExistingWorkflowOnConflictOptions
( ctx context.Context, workflowKey definition.WorkflowKey, currentWorkflowConditionFailed *persistence.Curr
service/history/api/startworkflow/api.go:652
↓ 1 callers
Method
hasBusinessIDAlias
hasBusinessIDAlias returns true if the component has a businessID alias configured via WithBusinessIDAlias option.
chasm/registrable_component.go:208
↓ 1 callers
Function
hasCallerSegment
(req quotas.Request)
common/persistence/client/quotas.go:298
↓ 1 callers
Method
hasEnoughTimeForRetry
hasEnoughTimeForRetry checks if there is enough time left in the schedule-to-close timeout. If sufficient time remains, it will also return a valid re
chasm/lib/activity/activity.go:724
↓ 1 callers
Method
hasFinishedDraining
hasFinishedDraining returns true if this is a draining backlog manager and all tasks have been fully drained (read and acked).
service/matching/pri_backlog_manager.go:409
↓ 1 callers
Method
hasFinishedDraining
hasFinishedDraining returns true if this is a draining backlog manager and all tasks have been fully drained (read and acked).
service/matching/fair_backlog_manager.go:416
↓ 1 callers
Method
hasMinVersionOld
hasMinVersionOld is only kept for replay consistency. Should not be used in any new place. TODO: remove with cleanup for AsyncSetCurrentAndRamping and
service/worker/workerdeployment/version_workflow.go:1483
↓ 1 callers
Method
hasMoreBackfills
()
chasm/lib/scheduler/scheduler.go:531
↓ 1 callers
Function
hasNoLintComment
hasNoLintComment checks for //parallelize:ignore in the function's doc comment.
tools/parallelize/parallelize.go:161
↓ 1 callers
Function
hasParallelCall
hasParallelCall checks if the function body already contains <param>.Parallel().
tools/parallelize/parallelize.go:174
↓ 1 callers
Method
hasRemainingTasks
()
common/tasks/interleaved_weighted_round_robin.go:378
↓ 1 callers
Method
hasSuiteScoped
(t *testing.T)
tests/testcore/test_cluster_pool.go:220
↓ 1 callers
Method
hasUnprocessedStarts
hasUnprocessedStarts reports whether any BufferedStart is still awaiting its initial ProcessBuffer pass (Attempt == 0).
chasm/lib/scheduler/invoker.go:324
↓ 1 callers
Function
hash
(s string)
common/testing/testvars/hash.go:7
↓ 1 callers
Method
heartbeatLoop
(ctx context.Context)
service/worker/scanner/scheduleinvariants/invariants.go:165
↓ 1 callers
Function
historyMutated
(request *archiver.ArchiveHistoryRequest, historyBatches []*historypb.History, isLast bool)
common/archiver/gcloud/history_archiver.go:301
↓ 1 callers
Function
historyMutated
(request *archiver.ArchiveHistoryRequest, historyBatches []*historypb.History, isLast bool)
common/archiver/s3store/util.go:237
↓ 1 callers
Function
historyRoutingOptions
(reqType reflect.Type)
cmd/tools/genrpcwrappers/main.go:210
↓ 1 callers
Function
httpStatusCodeToHandlerErrorType
(response *http.Response)
common/nexus/nexusrpc/client.go:425
↓ 1 callers
Function
idConflictPolicyFromProto
(p enumspb.NexusOperationIdConflictPolicy)
chasm/lib/nexusoperation/handler.go:288
↓ 1 callers
Function
idReusePolicyFromProto
(p enumspb.NexusOperationIdReusePolicy)
chasm/lib/nexusoperation/handler.go:277
↓ 1 callers
Function
identifyCIBreakers
identifyCIBreakers finds tests that failed their final retry in a CI job. A test breaks CI if it has a failure with the "(final)" suffix in an artifac
tools/flakereport/parser.go:385
↓ 1 callers
Method
identity
()
chasm/lib/scheduler/scheduler.go:431
↓ 1 callers
Function
immutableFieldsChanged
immutableFieldsChanged returns true if any of immutable fields changed.
common/persistence/cluster_metadata_store.go:204
↓ 1 callers
Method
importEvents
( workflowID string, runID string, versionHistory *historyspb.VersionHistory, eventBatches []*historypb.Hi
tests/xdc/stream_based_replication_test.go:332
↓ 1 callers
Method
importTestEvents
( historyClient historyservice.HistoryServiceClient, namespaceName namespace.Name, namespaceId namespace.ID
tests/xdc/stream_based_replication_test.go:191
↓ 1 callers
Method
incrementShardRequestCount
(shardID int32)
common/persistence/health_signal_aggregator.go:113
↓ 1 callers
Method
init
()
service/history/queues/action_pending_task_count.go:82
↓ 1 callers
Method
init
()
common/dynamicconfig/file_based_client.go:124
↓ 1 callers
Method
initDependencies
()
common/persistence/client/factory.go:289
↓ 1 callers
Function
initPrometheusListener
( config *PrometheusConfig, reg *prometheus.Registry, logger log.Logger, fatalOnListenerError bool, )
common/metrics/opentelemetry_provider.go:124
↓ 1 callers
Method
initScanner
(serializer serialization.Serializer)
service/worker/service.go:330
↓ 1 callers
Function
initSeeds
()
cmd/tools/getproto/main.go:147
↓ 1 callers
Method
initSerializedCollectionNode
()
chasm/tree.go:758
↓ 1 callers
Method
initState
()
service/matching/pri_task_writer.go:140
↓ 1 callers
Method
initState
()
service/matching/fair_task_writer.go:143
↓ 1 callers
Function
initSystemNamespaces
( ctx context.Context, cfg *config.Persistence, currentClusterName string, persistenceServiceResolver reso
temporal/server_impl.go:148
↓ 1 callers
Method
initVersionedTransitionInDB
()
service/history/workflow/mutable_state_impl.go:9630
↓ 1 callers
Method
initialize
()
service/matching/task_queue_partition_manager.go:230
↓ 1 callers
Method
initialize
()
common/authorization/default_token_key_provider.go:43
↓ 1 callers
Method
initialize
()
common/rpc/encryption/local_store_cert_provider.go:55
↓ 1 callers
Method
initialize
()
common/rpc/encryption/local_store_tls_provider.go:90
↓ 1 callers
Method
initializeDLQMetadata
( ctx context.Context, blob *commonpb.DataBlob, )
common/persistence/sql/queue.go:347
↓ 1 callers
Method
initializeDLQMetadata
( ctx context.Context, blob *commonpb.DataBlob, )
common/persistence/cassandra/queue_store.go:359
← previous
next →
12,001–12,100 of 43,335, ranked by callers