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
CloseShardByID
(shardID int32)
service/history/shard/controller_impl.go:189
↓ 1 callers
Method
CloseWithError
(err error)
common/archiver/gcloud/connector/client_delegate.go:56
↓ 1 callers
Method
ClusterConfiguredForArchival
ClusterConfiguredForArchival returns true if cluster is configured to handle archival, false otherwise
common/archiver/archival_metadata.go:151
↓ 1 callers
Method
ClusterName
()
common/testing/testvars/const.go:10
↓ 1 callers
Method
ClusterPutSettings
(ctx context.Context, bodyString string)
common/persistence/visibility/store/elasticsearch/client/client.go:42
↓ 1 callers
Method
CommandHandlers
()
chasm/lib/workflow/registry.go:18
↓ 1 callers
Method
CompactSlices
(SlicePredicate)
service/history/queues/reader.go:34
↓ 1 callers
Function
CompareVersionHistory
CompareVersionHistory compares 2 version history items
common/persistence/versionhistory/version_history.go:255
↓ 1 callers
Method
CompleteActivityByID
CompleteActivityByID mocks base method.
common/testing/mocksdk/client_mock.go:118
↓ 1 callers
Method
CompleteFairTasksLessThan
CompleteFairTasksLessThan deletes of tasks less than the given taskID. Limit is the upper bound of number of tasks that can be deleted by this method.
service/matching/db.go:741
↓ 1 callers
Method
CompleteOperation
(context.Context, *CompletionRequest)
common/nexus/nexusrpc/completion.go:207
↓ 1 callers
Function
CompletedCount
(r Registry)
service/history/workflow/update/export_test.go:26
↓ 1 callers
Method
ComponentIDByFqn
ComponentIDByFqn converts fully qualified component type name to component type ID. This method should only be used by CHASM framework internal code,
chasm/registry.go:125
↓ 1 callers
Method
ComponentOf
(componentGoType reflect.Type)
chasm/export_test.go:20
↓ 1 callers
Method
Concurrency
Dynamic concurrency limiter. Evaluated at submit time.
common/tasks/dynamic_worker_pool_scheduler.go:15
↓ 1 callers
Method
Config
Config returns the underlying NamespaceConfig proto. The returned value is the registry's own copy and must not be mutated.
common/namespace/namespace.go:238
↓ 1 callers
Function
ConfigProvider
(dc *dynamicconfig.Collection)
chasm/lib/activity/config.go:59
↓ 1 callers
Function
ConfigureCassandraCluster
Modifies the input cluster config in place. nolint:revive // cognitive complexity 61 (> max enabled 25)
common/persistence/nosql/nosqlplugin/cassandra/gocql/client.go:41
↓ 1 callers
Method
Consistency
(Consistency)
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:37
↓ 1 callers
Method
ContainsHistory
(expectedHistorySegment string, actualHistory *historypb.History)
common/testing/historyrequire/history_require.go:219
↓ 1 callers
Method
ContentType
(_ any)
service/frontend/protojson_marshaler.go:100
↓ 1 callers
Method
Context
Context returns the test-scoped context (created from [testcontext]). Inside an [Await] callback, it returns the await-scoped context.
common/testing/parallelsuite/suite.go:88
↓ 1 callers
Function
ContextFactoryProvider
(params ContextFactoryParams)
service/history/shard/context_factory.go:72
↓ 1 callers
Function
ContextWithDeadline
( ctx context.Context, deadline time.Time, timeSource TimeSource, )
common/clock/context.go:53
↓ 1 callers
Function
ContinueAsNewVersioningBehaviorTag
(canBehavior enumspb.ContinueAsNewVersioningBehavior)
common/metrics/tags.go:483
↓ 1 callers
Method
ConvertComparisonExpr
( operator string, col *SAColumn, value any, )
common/persistence/visibility/store/query/nil_converter.go:36
↓ 1 callers
Function
ConvertDynamicConfigValueToWeights
( weightsFromDC map[string]any, logger log.Logger, )
service/history/configs/task.go:36
↓ 1 callers
Method
ConvertIsExpr
( operator string, col *query.SAColumn, )
common/persistence/visibility/store/sql/query_converter.go:65
↓ 1 callers
Method
ConvertIsExpr
(operator string, col *SAColumn)
common/persistence/visibility/store/query/nil_converter.go:76
↓ 1 callers
Method
ConvertIsExpr
( operator string, col *query.SAColumn, )
common/persistence/visibility/store/elasticsearch/query_converter.go:201
↓ 1 callers
Method
ConvertKeywordComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/visibility/store/sql/query_converter.go:49
↓ 1 callers
Method
ConvertKeywordComparisonExpr
( operator string, col *SAColumn, value any, )
common/persistence/visibility/store/query/nil_converter.go:44
↓ 1 callers
Method
ConvertKeywordListComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:54
↓ 1 callers
Method
ConvertKeywordListComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/mysql/query_converter.go:77
↓ 1 callers
Method
ConvertKeywordListComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/sqlite/query_converter.go:37
↓ 1 callers
Method
ConvertKeywordListComparisonExpr
( operator string, col *SAColumn, value any, )
common/persistence/visibility/store/query/nil_converter.go:52
↓ 1 callers
Method
ConvertKeywordListComparisonExpr
( operator string, col *query.SAColumn, value any, )
common/persistence/visibility/store/elasticsearch/query_converter.go:155
↓ 1 callers
Function
ConvertNexusLinkToLinkActivity
ConvertNexusLinkToLinkActivity converts a Nexus Link to Link_Activity. NOTE: Experimental
common/nexus/link_converter.go:121
↓ 1 callers
Function
ConvertNexusLinkToLinkWorkflowEvent
ConvertNexusLinkToLinkWorkflowEvent converts a Nexus Link to Link_WorkflowEvent. NOTE: Experimental
common/nexus/link_converter.go:191
↓ 1 callers
Method
ConvertRangeExpr
( operator string, col *query.SAColumn, from, to sqlparser.Expr, )
common/persistence/visibility/store/sql/query_converter.go:57
↓ 1 callers
Method
ConvertRangeExpr
( operator string, col *SAColumn, from, to any, )
common/persistence/visibility/store/query/nil_converter.go:68
↓ 1 callers
Method
ConvertRangeExpr
( operator string, col *query.SAColumn, from, to any, )
common/persistence/visibility/store/elasticsearch/query_converter.go:179
↓ 1 callers
Method
ConvertTaskByCluster
( ctx context.Context, task tasks.Task, targetClusterID int32, )
service/history/replication/ack_manager.go:43
↓ 1 callers
Method
ConvertTextComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:92
↓ 1 callers
Method
ConvertTextComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/mysql/query_converter.go:113
↓ 1 callers
Method
ConvertTextComparisonExpr
( operator string, col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/sqlite/query_converter.go:104
↓ 1 callers
Method
ConvertTextComparisonExpr
( operator string, col *SAColumn, value any, )
common/persistence/visibility/store/query/nil_converter.go:60
↓ 1 callers
Method
ConvertTextComparisonExpr
( operator string, col *query.SAColumn, value any, )
common/persistence/visibility/store/elasticsearch/query_converter.go:163
↓ 1 callers
Function
ConvertToStartRequest
( namespaceID namespace.ID, request *workflowservice.SignalWithStartWorkflowExecutionRequest, now time.Time
service/history/api/signalwithstartworkflow/convert.go:12
↓ 1 callers
Function
ConvertWildcardStringListToRegexp
(in any)
common/dynamicconfig/util.go:17
↓ 1 callers
Function
CountDeploymentVersions
(deployments *persistencespb.DeploymentData)
common/worker_versioning/worker_versioning.go:456
↓ 1 callers
Method
CountGroupByFromVisibility
(ctx context.Context, filter VisibilitySelectFilter)
common/persistence/sql/sqlplugin/visibility.go:109
↓ 1 callers
Method
CountWorkflow
(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest)
service/worker/migration/activities.go:637
↓ 1 callers
Method
CountWorkflowExecutions
CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
service/frontend/workflow_handler.go:2851
↓ 1 callers
Method
Counts
()
common/circuitbreaker/circuitbreaker.go:15
↓ 1 callers
Method
Create
Create returns a TaskHook instance that will be leveraged as part of the specific task queue partition (as specified in the details). This might also
service/matching/hooks/task_lifecycle_hooks.go:51
↓ 1 callers
Method
CreateActivityTaskCancelRequestedEvent
( workflowTaskCompletedEventID int64, scheduledEventID int64, )
service/history/historybuilder/event_factory.go:534
↓ 1 callers
Method
CreateActivityTaskCanceledEvent
( scheduledEventID int64, startedEventID int64, latestCancelRequestedEventID int64, details *commonpb.Payl
service/history/historybuilder/event_factory.go:548
↓ 1 callers
Method
CreateActivityTaskCompletedEvent
( scheduledEventID int64, startedEventID int64, identity string, result *commonpb.Payloads, )
service/history/historybuilder/event_factory.go:279
↓ 1 callers
Method
CreateActivityTaskFailedEvent
( scheduledEventID int64, startedEventID int64, failure *failurepb.Failure, retryState enumspb.RetryState,
service/history/historybuilder/event_factory.go:297
↓ 1 callers
Method
CreateActivityTaskScheduledEvent
( workflowTaskCompletedEventID int64, command *commandpb.ScheduleActivityTaskCommandAttributes, )
service/history/historybuilder/event_factory.go:230
↓ 1 callers
Method
CreateActivityTaskStartedEvent
( scheduledEventID int64, attempt int32, requestID string, identity string, lastFailure *failurepb.Failur
service/history/historybuilder/event_factory.go:255
↓ 1 callers
Method
CreateActivityTaskTimedOutEvent
( scheduledEventID int64, startedEventID int64, timeoutFailure *failurepb.Failure, retryState enumspb.Retr
service/history/historybuilder/event_factory.go:317
↓ 1 callers
Method
CreateChildWorkflowExecutionCanceledEvent
( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID,
service/history/historybuilder/event_factory.go:982
↓ 1 callers
Method
CreateChildWorkflowExecutionCompletedEvent
( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID,
service/history/historybuilder/event_factory.go:932
↓ 1 callers
Method
CreateChildWorkflowExecutionFailedEvent
( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID,
service/history/historybuilder/event_factory.go:956
↓ 1 callers
Method
CreateChildWorkflowExecutionStartedEvent
( initiatedID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, execution *commonpb.W
service/history/historybuilder/event_factory.go:884
↓ 1 callers
Method
CreateChildWorkflowExecutionTerminatedEvent
( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID,
service/history/historybuilder/event_factory.go:1006
↓ 1 callers
Method
CreateChildWorkflowExecutionTimedOutEvent
( initiatedID int64, startedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID,
service/history/historybuilder/event_factory.go:1028
↓ 1 callers
Method
CreateCompletedWorkflowEvent
( workflowTaskCompletedEventID int64, command *commandpb.CompleteWorkflowExecutionCommandAttributes, newExe
service/history/historybuilder/event_factory.go:335
↓ 1 callers
Method
CreateConnection
(dsn string)
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:20
↓ 1 callers
Method
CreateContinuedAsNewEvent
( workflowTaskCompletedEventID int64, newRunID string, command *commandpb.ContinueAsNewWorkflowExecutionCom
service/history/historybuilder/event_factory.go:476
↓ 1 callers
Method
CreateDB
(dbKind DbKind, cfg *config.SQL, r resolver.ServiceResolver, l log.Logger, mh metrics.Handler)
common/persistence/sql/sqlplugin/interfaces.go:33
↓ 1 callers
Method
CreateDatabase
CreateDatabase creates a database if it doesn't exist
tools/sql/conn.go:88
↓ 1 callers
Method
CreateDatabase
CreateDatabase from PersistenceTestCluster interface
common/persistence/sql/test_sql_persistence.go:107
↓ 1 callers
Method
CreateDatabase
CreateDatabase from PersistenceTestCluster interface
common/persistence/cassandra/test.go:153
↓ 1 callers
Function
CreateDependencyTaskNotCompletedReschedulePolicy
CreateDependencyTaskNotCompletedReschedulePolicy creates a retry policy for rescheduling task with ErrDependencyTaskNotCompleted
common/util.go:258
↓ 1 callers
Method
CreateExternalWorkflowExecutionCancelRequested
( initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID strin
service/history/historybuilder/event_factory.go:670
↓ 1 callers
Method
CreateExternalWorkflowExecutionSignaled
( initiatedEventID int64, targetNamespace namespace.Name, targetNamespaceID namespace.ID, workflowID strin
service/history/historybuilder/event_factory.go:779
↓ 1 callers
Method
CreateFailWorkflowEvent
( workflowTaskCompletedEventID int64, retryState enumspb.RetryState, command *commandpb.FailWorkflowExecuti
service/history/historybuilder/event_factory.go:351
↓ 1 callers
Method
CreateFairTasks
CreateFairTasks creates a batch of given tasks for this task queue
service/matching/db.go:594
↓ 1 callers
Method
CreateFromMigrationState
CreateFromMigrationState creates a CHASM schedule from migrated V1 state. Used during migration from workflow-backed schedules to CHASM schedules.
chasm/lib/scheduler/handler.go:82
↓ 1 callers
Function
CreateFrontendHandlerRetryPolicy
CreateFrontendHandlerRetryPolicy creates a retry policy for calls to frontend service
common/util.go:216
↓ 1 callers
Method
CreateHistoryBranch
( ctx context.Context, wfContext historyi.WorkflowContext, mutableState historyi.MutableState, task replic
service/history/ndc/mutable_state_mapper.go:129
↓ 1 callers
Function
CreateHistoryHandlerRetryPolicy
CreateHistoryHandlerRetryPolicy creates a retry policy for calls to history service
common/util.go:223
↓ 1 callers
Method
CreateMarkerRecordedEvent
( workflowTaskCompletedEventID int64, command *commandpb.RecordMarkerCommandAttributes, )
service/history/historybuilder/event_factory.go:803
↓ 1 callers
Function
CreateMatchingClientLongPollRetryPolicy
CreateMatchingClientLongPollRetryPolicy creates a retry policy for poll calls to matching service
common/util.go:210
↓ 1 callers
Function
CreateMatchingHandlerRetryPolicy
CreateMatchingHandlerRetryPolicy creates a retry policy for calls to matching service
common/util.go:229
↓ 1 callers
Function
CreateMutableState
( shard historyi.ShardContext, namespaceEntry *namespace.Namespace, executionTimeout *durationpb.Duration,
service/history/api/create_workflow_util.go:156
↓ 1 callers
Method
CreateNamespace
( ctx context.Context, request *CreateNamespaceRequest, )
common/persistence/metadata_manager.go:52
↓ 1 callers
Method
CreateNamespaceInV2Table
CreateNamespaceInV2Table is the temporary function used by namespace v1 -> v2 migration
common/persistence/cassandra/metadata_store.go:128
↓ 1 callers
Function
CreateNamespaces
CreateNamespaces creates namespaces in the target database without the need to have a running Temporal server. This exists primarily as a workaround
schema/sqlite/setup.go:93
↓ 1 callers
Function
CreatePersistenceClientRetryPolicy
CreatePersistenceClientRetryPolicy creates a retry policy for calls to persistence
common/util.go:161
↓ 1 callers
Function
CreateRecordWorkflowTaskStartedResponse
( ctx context.Context, ms historyi.MutableState, updateRegistry update.Registry, workflowTask *historyi.Wo
service/history/api/recordworkflowtaskstarted/api.go:367
↓ 1 callers
Method
CreateRefreshableConnection
CreateRefreshableConnection creates a connection pool that calls buildDSN before opening each new physical connection, enabling per-connection credent
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:24
↓ 1 callers
Method
CreateRequestCancelExternalWorkflowExecutionFailedEvent
( workflowTaskCompletedEventID int64, initiatedEventID int64, targetNamespace namespace.Name, targetNamesp
service/history/historybuilder/event_factory.go:640
↓ 1 callers
Method
CreateRequestCancelExternalWorkflowExecutionInitiatedEvent
( workflowTaskCompletedEventID int64, command *commandpb.RequestCancelExternalWorkflowExecutionCommandAttrib
service/history/historybuilder/event_factory.go:614
↓ 1 callers
Function
CreateSdkClientFactoryRetryPolicy
CreateSdkClientFactoryRetryPolicy creates a retry policy to handle SdkClientFactory NewClient when frontend service is not ready
common/util.go:282
↓ 1 callers
Method
CreateSignalExternalWorkflowExecutionFailedEvent
( workflowTaskCompletedEventID int64, initiatedEventID int64, targetNamespace namespace.Name, targetNamesp
service/history/historybuilder/event_factory.go:751
↓ 1 callers
Method
CreateSignalExternalWorkflowExecutionInitiatedEvent
( workflowTaskCompletedEventID int64, command *commandpb.SignalExternalWorkflowExecutionCommandAttributes,
service/history/historybuilder/event_factory.go:695
← previous
next →
9,401–9,500 of 43,335, ranked by callers