MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 13 callersFunctionisSupportedTextOperator
(operator string)
common/persistence/visibility/store/sql/query_converter_legacy.go:671
↓ 13 callersMethodlen
len returns the index of the highest set bit.
service/matching/bits.go:9
↓ 13 callersFunctionmakeUpdateWithCallbackHandler
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 callersFunctionmkUserData
(numSets int)
service/matching/version_sets_test.go:36
↓ 13 callersFunctionnewInternalQueryTask
( taskID string, request *matchingservice.QueryWorkflowRequest, )
service/matching/task.go:179
↓ 13 callersFunctionnewInternalTaskForSyncMatch
( info *persistencespb.TaskInfo, forwardInfo *taskqueuespb.TaskForwardInfo, taskDispatchRevisionNumber int6
service/matching/task.go:132
↓ 13 callersMethodnewRandomQueueMessageRow
( queueType persistence.QueueType, messageID int64, )
common/persistence/sql/sqlplugin/tests/queue_message.go:297
↓ 13 callersMethodnewRandomReplicationTaskRow
( shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_replication_task.go:307
↓ 13 callersMethodnewRandomReplicationTasksDLQRow
( sourceClusterName string, shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_replication_task_dlq.go:333
↓ 13 callersMethodnewRandomTimerTaskRow
( shardID int32, timestamp time.Time, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_timer_task.go:335
↓ 13 callersMethodnewRandomTransferTaskRow
( shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_transfer_task.go:309
↓ 13 callersMethodnewRandomVisibilityTaskRow
( shardID int32, taskID int64, )
common/persistence/sql/sqlplugin/tests/history_visibility_task.go:309
↓ 13 callersFunctionnewSUT
()
service/history/historybuilder/history_builder_categorization_test.go:1239
↓ 13 callersMethodnewTestEnv
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 callersMethodnewTestWorkflowSnapshot
( state enumsspb.WorkflowExecutionState, )
common/persistence/operation_mode_validator_test.go:379
↓ 13 callersFunctionnewUpdateNexusTestConfig
newUpdateNexusTestConfig creates a config with randomized names to avoid collisions.
tests/nexus_workflow_update_test.go:46
↓ 13 callersFunctionnotZero
(v T, label string, msg proto.Message)
service/history/workflow/update/validation.go:9
↓ 13 callersMethodoutput
()
components/nexusoperations/statemachine.go:184
↓ 13 callersFunctionreplaceAssignmentRule
(rule *taskqueuepb.BuildIdAssignmentRule, data *persistencespb.VersioningData, clock *hlc.Clock, idx int32,
service/matching/version_rule_test.go:136
↓ 13 callersFunctionrespondActivity
()
tests/versioning_3_test.go:4537
↓ 13 callersMethodrun
(sched *schedulepb.Schedule, iterations int)
service/worker/scheduler/workflow_test.go:84
↓ 13 callersFunctionrunMigrate
(t *testing.T, factory tdbg.ClientFactory, args ...string)
tools/tdbg/schedule_migrate_test.go:94
↓ 13 callersMethodrunningWorkflows
()
service/worker/scheduler/workflow_test.go:116
↓ 13 callersMethodsetupPartitionManagerWithTaskHookFactories
setupPartitionManagerWithTaskHookFactories creates a partition manager with the given task match hooks.
service/matching/task_queue_partition_manager_test.go:1400
↓ 13 callersMethodtryDeleteVersion
( env *testcore.TestEnv, tv *testvars.TestVars, expectedError string, skipDrainage bool, )
tests/worker_deployment_version_test.go:1830
↓ 13 callersMethodupdateBacklogStats
updateApproximateBacklogCount updates the in-memory DB state with the given delta value TODO(pri): old matcher cleanup
service/matching/db.go:405
↓ 13 callersFunctionvalidSWSRequest
()
chasm/lib/workflow/validator_test.go:50
↓ 13 callersMethodvalidateTimeSkippingConfig
( tsc *commonpb.TimeSkippingConfig, ns namespace.Name, )
service/frontend/workflow_handler.go:702
↓ 12 callersMethodAddActivityTaskTimedOutEvent
(int64, int64, *failurepb.Failure, enumspb.RetryState)
service/history/interfaces/mutable_state.go:67
↓ 12 callersMethodAddCompletedWorkflowEvent
(int64, *commandpb.CompleteWorkflowExecutionCommandAttributes, string)
service/history/interfaces/mutable_state.go:74
↓ 12 callersMethodAddRandomTasks
( category tasks.Category, numTasks int, newTaskFn func(definition.WorkflowKey, int64, time.Time) tasks.Tas
common/persistence/tests/execution_mutable_state_task.go:540
↓ 12 callersMethodAddTimerStartedEvent
(int64, *commandpb.StartTimerCommandAttributes)
service/history/interfaces/mutable_state.go:98
↓ 12 callersFunctionAliasFields
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 callersFunctionAttempt
retry Attempt returns tag for Attempt
common/log/tag/tags.go:676
↓ 12 callersMethodBatchWith
BatchWith task and return a new TrackableExecutableTask
service/history/replication/batchable_task.go:21
↓ 12 callersMethodBucket
(URI string)
common/archiver/gcloud/connector/client_delegate.go:17
↓ 12 callersMethodClear
Clear the Registry and abort all Updates.
service/history/workflow/update/registry.go:69
↓ 12 callersFunctionCompare
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 callersMethodCompleteHistoryTask
(ctx context.Context, request *CompleteHistoryTaskRequest)
common/persistence/data_interfaces.go:1138
↓ 12 callersMethodConnect
()
common/testing/nettest/pipe_benchmark_test.go:18
↓ 12 callersFunctionContainsVersionHistoryItem
ContainsVersionHistoryItem check whether VersionHistory has given VersionHistoryItem.
common/persistence/versionhistory/version_history.go:93
↓ 12 callersFunctionContextHasMetadata
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 callersFunctionContextMetadataMarkActivityID
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 callersMethodConvert
(task tasks.Task, targetClusterID int32, priority enumsspb.TaskPriority)
service/history/replication/raw_task_converter.go:45
↓ 12 callersFunctionCopyVersionedTransitions
( transitions []*persistencespb.VersionedTransition, )
common/persistence/transitionhistory/transition_history.go:12
↓ 12 callersMethodCountNexusOperationExecutions
(context.Context, *workflowservice.CountNexusOperationExecutionsRequest)
chasm/lib/nexusoperation/frontend.go:28
↓ 12 callersMethodCreateWorkflow
( ctx context.Context, archetypeID chasm.ArchetypeID, targetWorkflow Workflow, )
service/history/ndc/transaction_manager.go:93
↓ 12 callersMethodDPanic
(msg string, tags ...tag.Tag)
common/log/interface.go:23
↓ 12 callersFunctionDeploymentFromExternalDeploymentVersion
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 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
api/adminservicemock/v1/service_grpc.pb.mock.go:42
↓ 12 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
api/adminservicemock/v1/service_grpc.pb.mock.go:986
↓ 12 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/mock/store_mock.go:41
↓ 12 callersMethodEnqueuePollerAndWait
(ctxs []context.Context, poller *waitingPoller)
service/matching/matcher_data.go:308
↓ 12 callersMethodEnqueueTaskAndWait
(ctxs []context.Context, task *internalTask)
service/matching/matcher_data.go:267
↓ 12 callersFunctionFailureSourceTag
(value string)
common/metrics/tags.go:267
↓ 12 callersFunctionFatalf
(format string, v ...any)
cmd/tools/codegen/helpers.go:61
↓ 12 callersFunctionFindFirstVersionHistoryIndexByVersionHistoryItem
FindFirstVersionHistoryIndexByVersionHistoryItem find the first VersionHistory index which contains the given version history item.
common/persistence/versionhistory/version_histories.go:161
↓ 12 callersFunctionFloat64
(key string, value float64)
common/log/tag/zap_tag.go:206
↓ 12 callersMethodGet
Get returns the value for the given key
common/collection/interface.go:31
↓ 12 callersMethodGetApproximatePersistedSize
()
service/history/interfaces/mutable_state.go:221
↓ 12 callersMethodGetBufferedIDs
()
service/history/interfaces/query_register.go:14
↓ 12 callersMethodGetChildWorkflowOnly
()
api/historyservice/v1/request_response.pb.go:330
↓ 12 callersMethodGetClusters
()
api/persistence/v1/namespaces.pb.go:362
↓ 12 callersMethodGetCompletion
()
api/persistence/v1/update.pb.go:257
↓ 12 callersMethodGetDeleteTimestamp
()
api/persistence/v1/task_queues.pb.go:376
↓ 12 callersMethodGetDeleted
()
api/deployment/v1/message.pb.go:256
↓ 12 callersFunctionGetDurationPropertyFnFilteredByDestination
(value time.Duration)
common/dynamicconfig/setting_gen.go:684
↓ 12 callersMethodGetExecutionDuration
()
api/archiver/v1/message.pb.go:340
↓ 12 callersMethodGetHistoryFunc
(namespace string, execution *commonpb.WorkflowExecution)
tests/testcore/functional_test_base.go:629
↓ 12 callersMethodGetInclusiveEndMessageId
()
api/adminservice/v1/request_response.pb.go:2839
↓ 12 callersMethodGetLastProcessedTime
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:342
↓ 12 callersMethodGetMessagesFromDLQ
( ctx context.Context, firstMessageID int64, lastMessageID int64, pageSize int, pageToken []byt
common/persistence/namespace_replication_queue.go:76
↓ 12 callersMethodGetNamespaceEntry
()
service/history/workflow/mutable_state_impl.go:1354
↓ 12 callersMethodGetNamespaceWithOptions
(name Name, opts GetNamespaceOptions)
common/namespace/registry.go:23
↓ 12 callersMethodGetNewExecutionRunId
()
api/persistence/v1/executions.pb.go:859
↓ 12 callersMethodGetNextFailoverVersion
GetNextFailoverVersion return the next failover version for namespace failover
common/cluster/metadata.go:48
↓ 12 callersMethodGetOrCreateCurrentExecution
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, workflowID st
service/history/workflow/cache/cache.go:33
↓ 12 callersMethodGetPendingSignalExternalInfos
()
service/history/interfaces/mutable_state.go:193
↓ 12 callersMethodGetReplicationTasksIter
( ctx context.Context, pollingCluster string, minInclusiveTaskID int64, maxExclusiveTaskID int64,
service/history/replication/ack_manager.go:48
↓ 12 callersMethodGetStatus
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:272
↓ 12 callersMethodGetTaskQueueInfos
()
api/deployment/v1/message.pb.go:1234
↓ 12 callersMethodGetTimeSkippingStatePropagation
()
api/historyservice/v1/request_response.pb.go:358
↓ 12 callersFunctionHeaderCallsiteTag
(kind string)
common/metrics/tags.go:590
↓ 12 callersFunctionInt32
(key string, value int32)
common/log/tag/zap_tag.go:194
↓ 12 callersFunctionInvoke
( ctx context.Context, req *historyservice.RespondActivityTaskFailedRequest, shard historyi.ShardContext,
service/history/api/respondactivitytaskfailed/api.go:22
↓ 12 callersFunctionIsEmptyVersionHistory
IsEmptyVersionHistory indicate whether version history is empty
common/persistence/versionhistory/version_history.go:250
↓ 12 callersMethodIsStateDirty
()
service/history/interfaces/chasm_tree.go:25
↓ 12 callersFunctionLoad
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 callersMethodLogger
Logger returns a logger tagged with execution key and other chasm framework internal information.
chasm/context.go:32
↓ 12 callersFunctionMinKey
(this Key, that Key)
service/history/tasks/key.go:111
↓ 12 callersMethodMustOffer
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 callersFunctionNamespaceIDTag
NamespaceIDTag returns a new namespace ID tag.
common/metrics/tags.go:111
↓ 12 callersMethodNamespaceId
()
common/tqid/task_queue_id.go:43
↓ 12 callersFunctionNewEmptyTree
NewEmptyTree creates a new empty in-memory CHASM tree.
chasm/tree.go:290
↓ 12 callersMethodNewExecutionManager
NewExecutionManager returns a new execution manager
common/persistence/client/factory.go:39
↓ 12 callersFunctionNewHostLevelEventsCache
( executionManager persistence.ExecutionManager, config *configs.Config, handler metrics.Handler, logger l
service/history/events/cache.go:56
↓ 12 callersFunctionNewInterceptor
NewInterceptor creates an authorization interceptor.
common/authorization/interceptor.go:99
↓ 12 callersMethodNewLocalFrontendClientWithTimeout
(timeout time.Duration, longPollTimeout time.Duration)
client/clientfactory.go:33
↓ 12 callersFunctionNewMockFileReader
NewMockFileReader creates a new mock instance.
common/dynamicconfig/file_based_client_mock.go:32
↓ 12 callersFunctionNewMockNamespaceReplicationQueue
NewMockNamespaceReplicationQueue creates a new mock instance.
common/persistence/namespace_replication_queue_mock.go:33
← previousnext →2,001–2,100 of 43,335, ranked by callers