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
↓ 13 callers
Function
isSupportedTextOperator
(operator string)
common/persistence/visibility/store/sql/query_converter_legacy.go:671
↓ 13 callers
Method
len
len returns the index of the highest set bit.
service/matching/bits.go:9
↓ 13 callers
Function
makeUpdateWithCallbackHandler
makeUpdateWithCallbackHandler creates a nexus handler that sends a workflow update with completion callbacks to the specified child workflow. onStart
tests/nexus_workflow_update_test.go:59
↓ 13 callers
Function
mkUserData
(numSets int)
service/matching/version_sets_test.go:36
↓ 13 callers
Function
newInternalQueryTask
( taskID string, request *matchingservice.QueryWorkflowRequest, )
service/matching/task.go:179
↓ 13 callers
Function
newInternalTaskForSyncMatch
( info *persistencespb.TaskInfo, forwardInfo *taskqueuespb.TaskForwardInfo, taskDispatchRevisionNumber int6
service/matching/task.go:132
↓ 13 callers
Method
newRandomQueueMessageRow
( queueType persistence.QueueType, messageID int64, )
common/persistence/sql/sqlplugin/tests/queue_message.go:297
↓ 13 callers
Method
newRandomReplicationTaskRow
( shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_replication_task.go:307
↓ 13 callers
Method
newRandomReplicationTasksDLQRow
( sourceClusterName string, shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_replication_task_dlq.go:333
↓ 13 callers
Method
newRandomTimerTaskRow
( shardID int32, timestamp time.Time, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_timer_task.go:335
↓ 13 callers
Method
newRandomTransferTaskRow
( shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_transfer_task.go:309
↓ 13 callers
Method
newRandomVisibilityTaskRow
( shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_visibility_task.go:309
↓ 13 callers
Function
newSUT
()
service/history/historybuilder/history_builder_categorization_test.go:1239
↓ 13 callers
Method
newTestEnv
newTestEnv creates a TestEnv with the dynamic config required to exercise SignalWithStartWorkflowExecution from a workflow. Both settings are namespac
tests/signal_with_start_from_workflow_test.go:68
↓ 13 callers
Method
newTestWorkflowSnapshot
( state enumsspb.WorkflowExecutionState, )
common/persistence/operation_mode_validator_test.go:379
↓ 13 callers
Function
newUpdateNexusTestConfig
newUpdateNexusTestConfig creates a config with randomized names to avoid collisions.
tests/nexus_workflow_update_test.go:46
↓ 13 callers
Function
notZero
(v T, label string, msg proto.Message)
service/history/workflow/update/validation.go:9
↓ 13 callers
Method
output
()
components/nexusoperations/statemachine.go:184
↓ 13 callers
Function
replaceAssignmentRule
(rule *taskqueuepb.BuildIdAssignmentRule, data *persistencespb.VersioningData, clock *hlc.Clock, idx int32,
service/matching/version_rule_test.go:136
↓ 13 callers
Function
respondActivity
()
tests/versioning_3_test.go:4537
↓ 13 callers
Method
run
(sched *schedulepb.Schedule, iterations int)
service/worker/scheduler/workflow_test.go:84
↓ 13 callers
Function
runMigrate
(t *testing.T, factory tdbg.ClientFactory, args ...string)
tools/tdbg/schedule_migrate_test.go:94
↓ 13 callers
Method
runningWorkflows
()
service/worker/scheduler/workflow_test.go:116
↓ 13 callers
Method
setupPartitionManagerWithTaskHookFactories
setupPartitionManagerWithTaskHookFactories creates a partition manager with the given task match hooks.
service/matching/task_queue_partition_manager_test.go:1400
↓ 13 callers
Method
tryDeleteVersion
( env *testcore.TestEnv, tv *testvars.TestVars, expectedError string, skipDrainage bool, )
tests/worker_deployment_version_test.go:1830
↓ 13 callers
Method
updateBacklogStats
updateApproximateBacklogCount updates the in-memory DB state with the given delta value TODO(pri): old matcher cleanup
service/matching/db.go:405
↓ 13 callers
Function
validSWSRequest
()
chasm/lib/workflow/validator_test.go:50
↓ 13 callers
Method
validateTimeSkippingConfig
( tsc *commonpb.TimeSkippingConfig, ns namespace.Name, )
service/frontend/workflow_handler.go:702
↓ 12 callers
Method
AddActivityTaskTimedOutEvent
(int64, int64, *failurepb.Failure, enumspb.RetryState)
service/history/interfaces/mutable_state.go:67
↓ 12 callers
Method
AddCompletedWorkflowEvent
(int64, *commandpb.CompleteWorkflowExecutionCommandAttributes, string)
service/history/interfaces/mutable_state.go:74
↓ 12 callers
Method
AddRandomTasks
( category tasks.Category, numTasks int, newTaskFn func(definition.WorkflowKey, int64, time.Time) tasks.Tas
common/persistence/tests/execution_mutable_state_task.go:540
↓ 12 callers
Method
AddTimerStartedEvent
(int64, *commandpb.StartTimerCommandAttributes)
service/history/interfaces/mutable_state.go:98
↓ 12 callers
Function
AliasFields
AliasFields returns SearchAttributes struct where each custom search attribute name is replaced with alias. If no replacement where made, it returns n
common/searchattribute/mapper.go:139
↓ 12 callers
Function
Attempt
retry Attempt returns tag for Attempt
common/log/tag/tags.go:676
↓ 12 callers
Method
BatchWith
BatchWith task and return a new TrackableExecutableTask
service/history/replication/batchable_task.go:21
↓ 12 callers
Method
Bucket
(URI string)
common/archiver/gcloud/connector/client_delegate.go:17
↓ 12 callers
Method
Clear
Clear the Registry and abort all Updates.
service/history/workflow/update/registry.go:69
↓ 12 callers
Function
Compare
Compare 2 Clocks, returns 0 if a == b, -1 if a > b, 1 if a < b
common/clock/hybrid_logical_clock/hybrid_logical_clock.go:45
↓ 12 callers
Method
CompleteHistoryTask
(ctx context.Context, request *CompleteHistoryTaskRequest)
common/persistence/data_interfaces.go:1138
↓ 12 callers
Method
Connect
()
common/testing/nettest/pipe_benchmark_test.go:18
↓ 12 callers
Function
ContainsVersionHistoryItem
ContainsVersionHistoryItem check whether VersionHistory has given VersionHistoryItem.
common/persistence/versionhistory/version_history.go:93
↓ 12 callers
Function
ContextHasMetadata
ContextHasMetadata returns true if the context has metadata support. This can be used to debug whether a context has been properly initialized with me
common/contextutil/metadata.go:144
↓ 12 callers
Function
ContextMetadataMarkActivityID
ContextMetadataMarkActivityID marks an activity ID on the context for metadata resolution. The handler knows which activity (from the task token) but
common/contextutil/metadata.go:89
↓ 12 callers
Method
Convert
(task tasks.Task, targetClusterID int32, priority enumsspb.TaskPriority)
service/history/replication/raw_task_converter.go:45
↓ 12 callers
Function
CopyVersionedTransitions
( transitions []*persistencespb.VersionedTransition, )
common/persistence/transitionhistory/transition_history.go:12
↓ 12 callers
Method
CountNexusOperationExecutions
(context.Context, *workflowservice.CountNexusOperationExecutionsRequest)
chasm/lib/nexusoperation/frontend.go:28
↓ 12 callers
Method
CreateWorkflow
( ctx context.Context, archetypeID chasm.ArchetypeID, targetWorkflow Workflow, )
service/history/ndc/transaction_manager.go:93
↓ 12 callers
Method
DPanic
(msg string, tags ...tag.Tag)
common/log/interface.go:23
↓ 12 callers
Function
DeploymentFromExternalDeploymentVersion
DeploymentFromExternalDeploymentVersion Temporary helper function to convert WorkerDeploymentVersion to Deployment proto until we update code to use t
common/worker_versioning/worker_versioning.go:510
↓ 12 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
api/adminservicemock/v1/service_grpc.pb.mock.go:42
↓ 12 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
api/adminservicemock/v1/service_grpc.pb.mock.go:986
↓ 12 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/mock/store_mock.go:41
↓ 12 callers
Method
EnqueuePollerAndWait
(ctxs []context.Context, poller *waitingPoller)
service/matching/matcher_data.go:308
↓ 12 callers
Method
EnqueueTaskAndWait
(ctxs []context.Context, task *internalTask)
service/matching/matcher_data.go:267
↓ 12 callers
Function
FailureSourceTag
(value string)
common/metrics/tags.go:267
↓ 12 callers
Function
Fatalf
(format string, v ...any)
cmd/tools/codegen/helpers.go:61
↓ 12 callers
Function
FindFirstVersionHistoryIndexByVersionHistoryItem
FindFirstVersionHistoryIndexByVersionHistoryItem find the first VersionHistory index which contains the given version history item.
common/persistence/versionhistory/version_histories.go:161
↓ 12 callers
Function
Float64
(key string, value float64)
common/log/tag/zap_tag.go:206
↓ 12 callers
Method
Get
Get returns the value for the given key
common/collection/interface.go:31
↓ 12 callers
Method
GetApproximatePersistedSize
()
service/history/interfaces/mutable_state.go:221
↓ 12 callers
Method
GetBufferedIDs
()
service/history/interfaces/query_register.go:14
↓ 12 callers
Method
GetChildWorkflowOnly
()
api/historyservice/v1/request_response.pb.go:330
↓ 12 callers
Method
GetClusters
()
api/persistence/v1/namespaces.pb.go:362
↓ 12 callers
Method
GetCompletion
()
api/persistence/v1/update.pb.go:257
↓ 12 callers
Method
GetDeleteTimestamp
()
api/persistence/v1/task_queues.pb.go:376
↓ 12 callers
Method
GetDeleted
()
api/deployment/v1/message.pb.go:256
↓ 12 callers
Function
GetDurationPropertyFnFilteredByDestination
(value time.Duration)
common/dynamicconfig/setting_gen.go:684
↓ 12 callers
Method
GetExecutionDuration
()
api/archiver/v1/message.pb.go:340
↓ 12 callers
Method
GetHistoryFunc
(namespace string, execution *commonpb.WorkflowExecution)
tests/testcore/functional_test_base.go:629
↓ 12 callers
Method
GetInclusiveEndMessageId
()
api/adminservice/v1/request_response.pb.go:2839
↓ 12 callers
Method
GetLastProcessedTime
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:342
↓ 12 callers
Method
GetMessagesFromDLQ
( ctx context.Context, firstMessageID int64, lastMessageID int64, pageSize int, pageToken []byt
common/persistence/namespace_replication_queue.go:76
↓ 12 callers
Method
GetNamespaceEntry
()
service/history/workflow/mutable_state_impl.go:1354
↓ 12 callers
Method
GetNamespaceWithOptions
(name Name, opts GetNamespaceOptions)
common/namespace/registry.go:23
↓ 12 callers
Method
GetNewExecutionRunId
()
api/persistence/v1/executions.pb.go:859
↓ 12 callers
Method
GetNextFailoverVersion
GetNextFailoverVersion return the next failover version for namespace failover
common/cluster/metadata.go:48
↓ 12 callers
Method
GetOrCreateCurrentExecution
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, workflowID st
service/history/workflow/cache/cache.go:33
↓ 12 callers
Method
GetPendingSignalExternalInfos
()
service/history/interfaces/mutable_state.go:193
↓ 12 callers
Method
GetReplicationTasksIter
( ctx context.Context, pollingCluster string, minInclusiveTaskID int64, maxExclusiveTaskID int64,
service/history/replication/ack_manager.go:48
↓ 12 callers
Method
GetStatus
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:272
↓ 12 callers
Method
GetTaskQueueInfos
()
api/deployment/v1/message.pb.go:1234
↓ 12 callers
Method
GetTimeSkippingStatePropagation
()
api/historyservice/v1/request_response.pb.go:358
↓ 12 callers
Function
HeaderCallsiteTag
(kind string)
common/metrics/tags.go:590
↓ 12 callers
Function
Int32
(key string, value int32)
common/log/tag/zap_tag.go:194
↓ 12 callers
Function
Invoke
( ctx context.Context, req *historyservice.RespondActivityTaskFailedRequest, shard historyi.ShardContext,
service/history/api/respondactivitytaskfailed/api.go:22
↓ 12 callers
Function
IsEmptyVersionHistory
IsEmptyVersionHistory indicate whether version history is empty
common/persistence/versionhistory/version_history.go:250
↓ 12 callers
Method
IsStateDirty
()
service/history/interfaces/chasm_tree.go:25
↓ 12 callers
Function
Load
Load loads and validates the Temporal server configuration. It supports multiple loading strategies based on the provided options: - Embedded template
common/config/loader.go:129
↓ 12 callers
Method
Logger
Logger returns a logger tagged with execution key and other chasm framework internal information.
chasm/context.go:32
↓ 12 callers
Function
MinKey
(this Key, that Key)
service/history/tasks/key.go:111
↓ 12 callers
Method
MustOffer
MustOffer blocks until a consumer is found to handle this task Returns error only when context is canceled or the ratelimit is set to zero (allow noth
service/matching/matcher.go:270
↓ 12 callers
Function
NamespaceIDTag
NamespaceIDTag returns a new namespace ID tag.
common/metrics/tags.go:111
↓ 12 callers
Method
NamespaceId
()
common/tqid/task_queue_id.go:43
↓ 12 callers
Function
NewEmptyTree
NewEmptyTree creates a new empty in-memory CHASM tree.
chasm/tree.go:290
↓ 12 callers
Method
NewExecutionManager
NewExecutionManager returns a new execution manager
common/persistence/client/factory.go:39
↓ 12 callers
Function
NewHostLevelEventsCache
( executionManager persistence.ExecutionManager, config *configs.Config, handler metrics.Handler, logger l
service/history/events/cache.go:56
↓ 12 callers
Function
NewInterceptor
NewInterceptor creates an authorization interceptor.
common/authorization/interceptor.go:99
↓ 12 callers
Method
NewLocalFrontendClientWithTimeout
(timeout time.Duration, longPollTimeout time.Duration)
client/clientfactory.go:33
↓ 12 callers
Function
NewMockFileReader
NewMockFileReader creates a new mock instance.
common/dynamicconfig/file_based_client_mock.go:32
↓ 12 callers
Function
NewMockNamespaceReplicationQueue
NewMockNamespaceReplicationQueue creates a new mock instance.
common/persistence/namespace_replication_queue_mock.go:33
← previous
next →
2,001–2,100 of 43,335, ranked by callers