MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 6 callersFunctionCompare
( clock1 *clockspb.VectorClock, clock2 *clockspb.VectorClock, )
service/history/vclock/vclock.go:31
↓ 6 callersMethodCompleteNexusOperation
Complete an async Nexus Operation using a completion token. The completion state could be successful, failed, or canceled. Deprecated. Will be rename
api/historyservice/v1/service_grpc.pb.go:317
↓ 6 callersMethodComponentByPath
(chasm.Context, []string)
service/history/interfaces/chasm_tree.go:52
↓ 6 callersFunctionComponentPointerTo
ComponentPointerTo returns a CHASM field populated with a pointer to the given component. The target component must be a proper ancestor of the referr
chasm/field.go:58
↓ 6 callersFunctionConvertElasticsearchClientError
(message string, err error)
common/persistence/visibility/store/elasticsearch/visibility_store.go:1288
↓ 6 callersMethodConvertTask
TODO split the ack manager into 2 components
service/history/replication/ack_manager.go:408
↓ 6 callersFunctionCopyContextValues
CopyContextValues copies values in source Context to destination Context.
common/rpc/context.go:27
↓ 6 callersFunctionCopyVersionHistoryItems
(items []*historyspb.VersionHistoryItem)
common/persistence/versionhistory/version_history.go:27
↓ 6 callersMethodCounter
Counter implements [metrics.Handler.Counter].
common/metrics/metricstest/capture_handler.go:117
↓ 6 callersMethodCreateLocalFrontendHTTPClient
()
common/rpc.go:21
↓ 6 callersMethodCreateSentinel
(ctx context.Context, in *CreateSentinelRequest, opts ...grpc.CallOption)
chasm/lib/scheduler/gen/schedulerpb/v1/service_grpc.pb.go:45
↓ 6 callersMethodCreateWorkflowRule
( ctx context.Context, request *workflowservice.CreateWorkflowRuleRequest, opts ...grpc.CallOption, )
client/frontend/client_gen.go:92
↓ 6 callersMethodDecode
Decode bytes to protobuf struct.
common/codec/jsonpb.go:44
↓ 6 callersMethodDecodeCompletion
DecodeCompletion decodes a callback token unwrapping the contained NexusOperationCompletion proto struct.
common/nexus/callback_token.go:56
↓ 6 callersFunctionDefaultTimeout
DefaultTimeout returns the effective default timeout for test-scoped contexts.
common/testing/testcontext/context.go:41
↓ 6 callersMethodDeleteNamespace
DeleteNamespace helper method
common/persistence/persistence-tests/metadata_persistence_v2.go:1490
↓ 6 callersMethodDeleteWorkerDeploymentVersion
( ctx context.Context, namespaceEntry *namespace.Namespace, version string, skipDrainage bool, ident
service/worker/workerdeployment/client.go:103
↓ 6 callersMethodDescribeBatchOperation
( ctx context.Context, request *workflowservice.DescribeBatchOperationRequest, )
service/frontend/workflow_handler.go:5867
↓ 6 callersFunctionDescribePayloadStoreHandler
( ctx context.Context, request DescribePayloadStoreRequest, )
chasm/lib/tests/handler.go:114
↓ 6 callersMethodDeserializeStrippedEvents
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:75
↓ 6 callersFunctionDiscardUnknownProto
DiscardUnknownProto discards unknown fields in a proto message.
common/util.go:705
↓ 6 callersMethodDispatchQueryTask
DispatchQueryTask will dispatch query to local or remote poller. If forwarded then result or error is returned, if dispatched to local poller then nil
service/matching/physical_task_queue_manager_interface.go:54
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/replication/stream_receiver_mock.go:38
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/data_interfaces_mock.go:169
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/data_interfaces_mock.go:1082
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/mock/store_mock.go:1621
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/archival_metadata_mock.go:39
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/archival_metadata_mock.go:91
↓ 6 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/gcloud/connector/client_delegate_mock.go:40
↓ 6 callersFunctionEncodeBytes
(bytes []byte)
common/payload/payload.go:26
↓ 6 callersMethodEnqueueMessageToDLQ
(ctx context.Context, blob *commonpb.DataBlob)
common/persistence/persistence_interface.go:179
↓ 6 callersMethodEquals
(predicate Predicate)
service/history/tasks/predicates.go:94
↓ 6 callersMethodEquals
(predicate Predicate)
service/history/tasks/predicates.go:133
↓ 6 callersMethodEquals
(predicate Predicate)
service/history/tasks/predicates.go:168
↓ 6 callersMethodEquals
(predicate Predicate)
service/history/tasks/predicates.go:218
↓ 6 callersMethodExecutionManager
ExecutionManager returns an execution manager factory from the test cluster
tests/testcore/test_cluster.go:605
↓ 6 callersFunctionFatalIfErr
(err error)
cmd/tools/codegen/helpers.go:54
↓ 6 callersFunctionForwardedTag
(forwarded bool)
common/metrics/tags.go:317
↓ 6 callersFunctionGenerateRandomDBName
()
common/persistence/persistence-tests/persistence_test_base.go:439
↓ 6 callersMethodGenerateRecordWorkflowStartedTasks
( startEvent *historypb.HistoryEvent, )
service/history/workflow/task_generator.go:47
↓ 6 callersMethodGenerateStartWorkflowTaskTasks
( workflowTaskScheduledEventID int64, )
service/history/workflow/task_generator.go:59
↓ 6 callersMethodGetActualTime
()
api/schedule/v1/message.pb.go:114
↓ 6 callersMethodGetAlias
(fieldName string, namespace string)
common/searchattribute/mapper.go:21
↓ 6 callersMethodGetAllowNoPollers
()
api/deployment/v1/message.pb.go:2331
↓ 6 callersMethodGetAndCompleteHistoryTask
( category tasks.Category, task tasks.Task, )
common/persistence/tests/execution_mutable_state_task.go:628
↓ 6 callersMethodGetByName
(ctx context.Context, namespaceID namespace.ID, endpointName string)
chasm/context.go:83
↓ 6 callersMethodGetCancelRequest
()
api/historyservice/v1/request_response.pb.go:2686
↓ 6 callersMethodGetCancelRequested
()
api/persistence/v1/executions.pb.go:2967
↓ 6 callersMethodGetCategoryByID
(id int)
service/history/tasks/task_category_registry.go:11
↓ 6 callersMethodGetClosedTime
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:349
↓ 6 callersMethodGetClusterMetadata
()
service/history/shard/context_impl.go:2214
↓ 6 callersMethodGetClusterMetadata
(ctx context.Context, request *GetClusterMetadataRequest)
common/persistence/data_interfaces.go:1240
↓ 6 callersMethodGetCurrentVersionHistoryIndex
()
api/history/v1/message.pb.go:217
↓ 6 callersMethodGetCurrentWorkflowRunID
( ctx context.Context, namespaceID string, workflowID string, lockPriority locks.Priority, )
service/history/api/consistency_checker.go:30
↓ 6 callersMethodGetDLQAckLevels
(ctx context.Context)
common/persistence/persistence_interface.go:184
↓ 6 callersMethodGetDatetimeFormat
()
common/persistence/visibility/store/query/converter.go:32
↓ 6 callersMethodGetDeclinedTargetVersionUpgrade
()
api/persistence/v1/executions.pb.go:1136
↓ 6 callersMethodGetDestination
()
service/history/tasks/task.go:46
↓ 6 callersMethodGetEffectiveDeployment
GetEffectiveDeployment returns the effective deployment in the following order: 1. DeploymentVersionTransition.Deployment: this is returned when the w
service/history/workflow/mutable_state_impl.go:9647
↓ 6 callersMethodGetEntries
()
api/contextpropagation/v1/message.pb.go:67
↓ 6 callersMethodGetExecution
()
api/cli/v1/message.pb.go:156
↓ 6 callersMethodGetExecutionState
()
service/history/workflow/mutable_state_impl.go:1120
↓ 6 callersMethodGetFailed
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:541
↓ 6 callersMethodGetFailedRequest
()
api/historyservice/v1/request_response.pb.go:2189
↓ 6 callersMethodGetFailoverHistory
()
api/replication/v1/message.pb.go:898
↓ 6 callersFunctionGetFeatureCatalog
GetFeatureCatalog applies all the ArchiveOptions to the catalog and returns the catalog. It should be called inside the Archive method.
common/archiver/options.go:35
↓ 6 callersMethodGetFirstActivationTime
()
api/deployment/v1/message.pb.go:414
↓ 6 callersMethodGetGroups
()
api/persistence/v1/predicates.pb.go:661
↓ 6 callersMethodGetHeartbeatTimeout
()
api/persistence/v1/executions.pb.go:2960
↓ 6 callersFunctionGetHistory
( ctx context.Context, shardContext historyi.ShardContext, namespaceName namespace.Name, namespaceID names
service/history/api/get_history_util.go:146
↓ 6 callersMethodGetHistoryTaskRecorder
()
tests/testcore/onebox.go:643
↓ 6 callersMethodGetInternalTaskQueueStatus
()
service/matching/physical_task_queue_manager_interface.go:65
↓ 6 callersMethodGetInternodeClientConfig
()
common/rpc/encryption/tls_factory.go:19
↓ 6 callersMethodGetItems
()
api/history/v1/message.pb.go:171
↓ 6 callersMethodGetLastCompletionResult
()
api/schedule/v1/message.pb.go:345
↓ 6 callersMethodGetLastHeartbeatTime
()
api/cli/v1/message.pb.go:337
↓ 6 callersMethodGetMemo
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:605
↓ 6 callersMethodGetMessage
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:704
↓ 6 callersMethodGetName
()
common/persistence/visibility/store/sql/visibility_store.go:93
↓ 6 callersMethodGetNamespace
()
common/authorization/authorizer.go:61
↓ 6 callersMethodGetNamespaceID
()
common/definition/workflow_key.go:29
↓ 6 callersMethodGetNexus
()
chasm/lib/callback/gen/callbackpb/v1/message.pb.go:268
↓ 6 callersMethodGetOperationToken
()
api/persistence/v1/chasm.pb.go:739
↓ 6 callersMethodGetPauseRequest
()
api/historyservice/v1/request_response.pb.go:9941
↓ 6 callersMethodGetPendingChildIds
()
service/history/interfaces/mutable_state.go:191
↓ 6 callersFunctionGetPerTaskQueuePartitionTypeScope
GetPerTaskQueuePartitionTypeScope returns GetPerTaskQueueScope scope plus a "partition" tag which can be "__normal__", "__sticky__", "__worker_command
common/metrics/task_queues.go:64
↓ 6 callersMethodGetPointerAttributes
()
api/persistence/v1/chasm.pb.go:178
↓ 6 callersMethodGetPreviousStartedEventId
()
api/historyservice/v1/request_response.pb.go:621
↓ 6 callersMethodGetQuota
(namespace string)
common/quotas/calculator/logged_calculator.go:64
↓ 6 callersMethodGetReadStoreName
(nsName namespace.Name)
common/persistence/visibility/manager/visibility_manager.go:23
↓ 6 callersMethodGetReapplyCandidateEvents
()
service/history/interfaces/mutable_state.go:408
↓ 6 callersMethodGetReason
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:684
↓ 6 callersMethodGetRemoteAdminClient
(string)
client/client_bean.go:29
↓ 6 callersMethodGetReplicationTasks
()
api/replication/v1/message.pb.go:591
↓ 6 callersMethodGetRunID
()
common/definition/workflow_key.go:37
↓ 6 callersMethodGetSdkName
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:563
↓ 6 callersMethodGetSdkVersion
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:570
↓ 6 callersMethodGetSignalRequest
()
api/historyservice/v1/request_response.pb.go:2898
↓ 6 callersMethodGetStartedTime
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:342
↓ 6 callersMethodGetSuccess
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:503
← previousnext →3,601–3,700 of 43,335, ranked by callers