MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 7 callersFunctionConvertStructure
ConvertStructure can be used as a conversion function for New*TypedSettingWithConverter. The value from dynamic config will be converted to T, on top
common/dynamicconfig/collection.go:678
↓ 7 callersFunctionConvertWeightsToDynamicConfigValue
( weights map[tasks.Priority]int, )
service/history/configs/task.go:26
↓ 7 callersFunctionCopyVersionedTransition
( transition *persistencespb.VersionedTransition, )
common/persistence/transitionhistory/transition_history.go:25
↓ 7 callersMethodCreateRemoteFrontendGRPCConnection
(rpcAddress string)
common/rpc.go:17
↓ 7 callersMethodDecodeHistories
Decode History slice from bytes.
common/codec/jsonpb.go:76
↓ 7 callersMethodDeleteDLQTasks
( ctx context.Context, in *historyservice.DeleteDLQTasksRequest, opts ...grpc.CallOption, )
service/worker/dlq/workflow.go:81
↓ 7 callersMethodDeletePendingChildExecution
DeletePendingChildExecution deletes details about a ChildExecutionInfo.
service/history/workflow/mutable_state_impl.go:2003
↓ 7 callersMethodDeleteReplicationTaskFromDLQ
(ctx context.Context, request *DeleteReplicationTaskFromDLQRequest)
common/persistence/data_interfaces.go:1143
↓ 7 callersMethodDestination
The destination of this task, used to group tasks into a per namespace-and-destination scheduler. Tasks may return an empty string if the task is deli
service/history/hsm/tasks.go:35
↓ 7 callersMethodDropDatabase
(name string)
tools/common/schema/test/dbtest.go:22
↓ 7 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/matching/task_queue_partition_manager_mock.go:44
↓ 7 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/ndc/transaction_manager_mock.go:42
↓ 7 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/gcloud/connector/client_delegate_mock.go:78
↓ 7 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/filestore/query_parser_mock.go:38
↓ 7 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/sdk/factory_mock.go:40
↓ 7 callersMethodEncodingType
()
common/persistence/serialization/serializer.go:34
↓ 7 callersMethodErr
()
common/clock/context.go:26
↓ 7 callersFunctionErrorType
ErrorType returns tag for ErrorType
common/log/tag/tags.go:398
↓ 7 callersMethodErrorf
Errorf implements testlogger.TestingT.
common/testing/testlogger/testlogger_test.go:20
↓ 7 callersMethodErrorf
(format string, args ...any)
common/testing/await/require_ctx_test.go:497
↓ 7 callersMethodExec
Exec executes a cql statement
tools/cassandra/cqlclient.go:203
↓ 7 callersMethodExec
Exec executes a sql statement
common/persistence/sql/sqlplugin/postgresql/admin.go:51
↓ 7 callersMethodExec
Exec executes a sql statement
common/persistence/sql/sqlplugin/mysql/admin.go:77
↓ 7 callersMethodExecute
()
service/history/replication/executable_verify_versioned_transition_task.go:78
↓ 7 callersMethodExecutePureTask
(baseCtx context.Context, taskAttributes TaskAttributes, taskInstance any)
chasm/tree.go:251
↓ 7 callersMethodFailoverVersion
(businessID string)
common/namespace/replication_resolver.go:30
↓ 7 callersMethodForceDeleteWorkflowExecution
(ctx context.Context, in *ForceDeleteWorkflowExecutionRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:298
↓ 7 callersMethodForwardPoll
(ctx context.Context, p *pollMetadata)
service/matching/forwarder_test.go:39
↓ 7 callersMethodFromPostgreSQLDateTime
(t time.Time)
common/persistence/sql/sqlplugin/postgresql/typeconv.go:14
↓ 7 callersMethodFromSQLiteDateTime
(t time.Time)
common/persistence/sql/sqlplugin/sqlite/typeconv.go:14
↓ 7 callersMethodFrontendClient
()
tests/testcore/functional_test_base.go:225
↓ 7 callersFunctionFullJitter
FullJitter return random number from 0 to input, inclusive, exclusive
common/backoff/jitter.go:6
↓ 7 callersMethodGenerate
Generate immediately kicks off a new GeneratorTask. Used after updating the schedule specification.
chasm/lib/scheduler/generator.go:47
↓ 7 callersMethodGenerateWorkflowStartTasks
( startEvent *historypb.HistoryEvent, )
service/history/workflow/task_generator.go:35
↓ 7 callersMethodGet
(ctx context.Context)
common/future/future.go:7
↓ 7 callersMethodGet
Get is used to access an archived history. When context expires this method should stop trying to fetch history. The URI identifies the resource from
common/archiver/interface.go:56
↓ 7 callersMethodGetActivityScheduledEvent
(context.Context, int64)
service/history/interfaces/mutable_state.go:163
↓ 7 callersMethodGetBaseWorkflowInfo
()
service/history/interfaces/mutable_state.go:204
↓ 7 callersMethodGetBuildId
()
api/deployment/v1/message.pb.go:80
↓ 7 callersMethodGetCallbacks
()
api/historyservice/v1/request_response.pb.go:4191
↓ 7 callersMethodGetChasmLeaseWithConsistencyCheck
( ctx context.Context, reqClock *clockspb.VectorClock, consistencyPredicate MutableStateConsistencyPr
service/history/api/consistency_checker.go:67
↓ 7 callersMethodGetCompleteRequest
()
api/historyservice/v1/request_response.pb.go:2067
↓ 7 callersMethodGetCompleteTime
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:521
↓ 7 callersFunctionGetEffectiveVersioningBehavior
GetEffectiveVersioningBehavior returns the effective versioning behavior in the following order: 1. DeploymentVersionTransition: if there is a transit
service/history/workflow/util.go:216
↓ 7 callersMethodGetEffectiveVersioningBehavior
GetEffectiveVersioningBehavior returns the effective versioning behavior in the following order: 1. DeploymentVersionTransition: if there is a transit
service/history/workflow/mutable_state_impl.go:9716
↓ 7 callersMethodGetExternalPayloadCount
()
service/history/interfaces/mutable_state.go:311
↓ 7 callersMethodGetExternalPayloadSize
()
service/history/interfaces/mutable_state.go:308
↓ 7 callersMethodGetFirstExecutionRunId
()
api/schedule/v1/message.pb.go:616
↓ 7 callersMethodGetFrontendClient
()
client/client_bean.go:28
↓ 7 callersMethodGetHeader
()
chasm/lib/callback/gen/callbackpb/v1/message.pb.go:381
↓ 7 callersMethodGetHeartbeatTimeout
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:258
↓ 7 callersMethodGetHistoryLength
()
api/cli/v1/message.pb.go:191
↓ 7 callersMethodGetIfReady
()
common/future/future_impl.go:58
↓ 7 callersMethodGetInheritedBuildId
()
service/history/interfaces/mutable_state.go:206
↓ 7 callersMethodGetIsMember
()
api/matchingservice/v1/request_response.pb.go:5533
↓ 7 callersMethodGetLastStartedTime
()
api/cli/v1/message.pb.go:344
↓ 7 callersMethodGetLastWorkerIdentity
()
api/cli/v1/message.pb.go:386
↓ 7 callersMethodGetListWorkflowExecutionsResponse
( searchResult *elastic.SearchResult, namespace namespace.Name, pageSize int, chasmMapper *chasm.Visibilit
common/persistence/visibility/store/elasticsearch/visibility_store.go:855
↓ 7 callersMethodGetMeter
()
common/metrics/opentelemetry_provider.go:23
↓ 7 callersFunctionGetOrSetNew
GetOrSetNew looks up k in m and returns the result. If it's not present, it uses `new` to allocate an new value type and sets that in the map, then re
common/util/util.go:83
↓ 7 callersFunctionGetOverrideTargetDeploymentVersion
(override *workflowpb.VersioningOverride)
common/worker_versioning/worker_versioning.go:670
↓ 7 callersMethodGetPauseInfo
()
api/persistence/v1/executions.pb.go:3202
↓ 7 callersFunctionGetPerTaskQueuePartitionIDScope
GetPerTaskQueuePartitionIDScope is similar to GetPerTaskQueuePartitionTypeScope, except that the partition tag will hold the normal partition ID if pa
common/metrics/task_queues.go:43
↓ 7 callersMethodGetQueryRequest
()
api/matchingservice/v1/request_response.pb.go:1243
↓ 7 callersMethodGetQuota
()
common/quotas/calculator/calculator.go:5
↓ 7 callersMethodGetReason
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:375
↓ 7 callersMethodGetRemoteFrontendClient
(string)
client/client_bean.go:30
↓ 7 callersMethodGetRoutingConfigChanged
Deprecated: Marked as deprecated in temporal/server/api/matchingservice/v1/request_response.proto.
api/matchingservice/v1/request_response.pb.go:3014
↓ 7 callersMethodGetScheduleToCloseTimeout
()
api/persistence/v1/executions.pb.go:2946
↓ 7 callersMethodGetScheduleToCloseTimeout
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:370
↓ 7 callersMethodGetScheduleToStartTimeout
()
api/persistence/v1/executions.pb.go:2939
↓ 7 callersMethodGetSingleWorkflowHistoryPaginatedIteratorInclusive
( ctx context.Context, remoteClusterName string, namespaceID namespace.ID, workflowID string, r
service/history/replication/eventhandler/remote_history_paginated_fetcher.go:42
↓ 7 callersMethodGetSourceEventId
()
api/persistence/v1/executions.pb.go:1305
↓ 7 callersMethodGetSourceTaskId
()
api/replication/v1/message.pb.go:100
↓ 7 callersMethodGetStartDelay
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:307
↓ 7 callersFunctionGetStringPropertyFn
(value string)
common/dynamicconfig/setting_gen.go:446
↓ 7 callersMethodGetTaskInfos
()
api/historyservice/v1/request_response.pb.go:148
↓ 7 callersMethodGetTreeId
()
api/persistence/v1/history_tree.pb.go:141
↓ 7 callersMethodGetUpdateCondition
()
service/history/interfaces/mutable_state.go:324
↓ 7 callersMethodGetUpdateTime
()
api/persistence/v1/executions.pb.go:113
↓ 7 callersMethodGetVersionHistory
()
api/replication/v1/message.pb.go:1509
↓ 7 callersMethodGetVersionsInfoInternal
()
api/adminservice/v1/request_response.pb.go:5257
↓ 7 callersMethodGetWorkflowStatus
()
api/historyservice/v1/request_response.pb.go:670
↓ 7 callersMethodHasActivityFinishEvent
( scheduledEventID int64, )
service/history/historybuilder/event_store.go:547
↓ 7 callersMethodHasAnyPollerAfter
HasAnyPollerAfter checks pollers on all versioned and unversioned queues
service/matching/task_queue_partition_manager_interface.go:58
↓ 7 callersMethodHistoryBranchToBlob
(info *persistencespb.HistoryBranch)
common/persistence/serialization/serializer.go:41
↓ 7 callersFunctionIgnoredValue
IgnoredValue returns tag for IgnoredValue
common/log/tag/tags.go:476
↓ 7 callersMethodInitializeSystemNamespaces
(ctx context.Context, currentClusterName string)
common/persistence/data_interfaces.go:1227
↓ 7 callersMethodInsertIntoHistoryTree
(ctx context.Context, row *HistoryTreeRow)
common/persistence/sql/sqlplugin/history_tree.go:45
↓ 7 callersMethodInsertIntoQueueV2Metadata
(ctx context.Context, row *QueueV2MetadataRow)
common/persistence/sql/sqlplugin/queue_v2_metadata.go:31
↓ 7 callersMethodInterceptStream
InterceptStream is a gRPC stream server interceptor that enforces authorization.
common/authorization/interceptor.go:188
↓ 7 callersMethodIsProcessed
(stage DeleteWorkflowExecutionStage)
service/history/tasks/delete_workflow_execution_stage.go:24
↓ 7 callersMethodIsRetryableError
(err error)
service/history/replication/executable_task.go:65
↓ 7 callersFunctionIsServiceHandlerRetryableError
(err error)
common/util.go:354
↓ 7 callersMethodIsStickyTaskQueueSet
()
service/history/interfaces/mutable_state.go:226
↓ 7 callersFunctionIsTaskAcked
( task tasks.Task, persistenceQueueState *persistencespb.QueueState, )
service/history/queues/util.go:8
↓ 7 callersMethodIsTransitionHistoryEnabled
()
service/history/interfaces/mutable_state.go:339
↓ 7 callersMethodIsVersioned
()
service/matching/physical_task_queue_key.go:148
↓ 7 callersMethodLen
()
service/history/replication/sequential_batch_queue.go:85
↓ 7 callersMethodLifecycleState
(Context)
chasm/component.go:14
← previousnext →3,201–3,300 of 43,335, ranked by callers