MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 1 callersFunctionbuildDSNAttr
(cfg *config.SQL)
common/persistence/sql/sqlplugin/sqlite/plugin.go:181
↓ 1 callersFunctionbuildDSNAttrs
(dbKind sqlplugin.DbKind, cfg *config.SQL)
common/persistence/sql/sqlplugin/mysql/session/session.go:156
↓ 1 callersMethodbuildDescribeActivityExecutionResponse
( ctx chasm.Context, req *activitypb.DescribeActivityExecutionRequest, )
chasm/lib/activity/activity.go:922
↓ 1 callersMethodbuildDescribeResponse
( ctx chasm.Context, req *nexusoperationpb.DescribeNexusOperationRequest, )
chasm/lib/nexusoperation/operation.go:427
↓ 1 callersFunctionbuildExpectedURLParams
(dbKind sqlplugin.DbKind, attrs map[string]string, isolationKey string, isolationValue string)
common/persistence/sql/sqlplugin/mysql/session/session_test.go:163
↓ 1 callersFunctionbuildFailureMessage
buildFailureMessage creates failure notification
tools/flakereport/slack.go:211
↓ 1 callersFunctionbuildIndexNameTypeMap
( indexSearchAttributes map[string]*persistencespb.IndexSearchAttributes, )
common/searchattribute/name_type_map.go:42
↓ 1 callersMethodbuildJSONOverlapsExpr
( col *query.SAColumn, value sqlparser.Expr, )
common/persistence/sql/sqlplugin/mysql/query_converter.go:237
↓ 1 callersMethodbuildMutation
( state *MutableStateImpl, tombstones []*persistencespb.StateMachineTombstoneBatch, )
service/history/workflow/mutable_state_impl_test.go:5843
↓ 1 callersFunctionbuildNexusHandler
(chasmRegistry *chasm.Registry)
service/history/fx.go:199
↓ 1 callersFunctionbuildNexusOperationCancellationInfo
( namespaceID namespace.ID, node *hsm.Node, op nexusoperations.Operation, outboundQueueCBPool *circuitbrea
service/history/api/describeworkflow/api.go:764
↓ 1 callersFunctionbuildOnDuplicateKeyUpdate
(fields ...string)
common/persistence/sql/sqlplugin/postgresql/visibility.go:42
↓ 1 callersFunctionbuildOnDuplicateKeyUpdate
(fields ...string)
common/persistence/sql/sqlplugin/sqlite/visibility.go:44
↓ 1 callersMethodbuildOtlpGrpcMetricExporter
( cfg *otlpGrpcMetricExporter, )
common/telemetry/config.go:248
↓ 1 callersMethodbuildOtlpGrpcSpanExporter
( cfg *otlpGrpcSpanExporter, )
common/telemetry/config.go:284
↓ 1 callersFunctionbuildPendingNexusOperationInfo
( namespaceID namespace.ID, node *hsm.Node, op nexusoperations.Operation, outboundQueueCBPool *circuitbrea
service/history/api/describeworkflow/api.go:694
↓ 1 callersFunctionbuildPendingNexusOperationInfosFromHSM
buildPendingNexusOperationInfosFromHSM reads nexus operations from HSM and converts them to API format.
service/history/api/describeworkflow/api.go:649
↓ 1 callersMethodbuildPollActivityExecutionResponse
( ctx chasm.Context, )
chasm/lib/activity/activity.go:1012
↓ 1 callersMethodbuildPollResponse
( ctx chasm.Context, )
chasm/lib/nexusoperation/operation.go:458
↓ 1 callersFunctionbuildReportSummary
buildReportSummary builds the complete report summary from processed data
tools/flakereport/flakereport.go:185
↓ 1 callersFunctionbuildRequestHeader
buildRequestHeader returns a copy of the supplied header, or a new map if nil.
chasm/lib/nexusoperation/operation_tasks.go:219
↓ 1 callersMethodbuildResponseIndex
(response *elastic.BulkResponse)
common/persistence/visibility/store/elasticsearch/processor.go:278
↓ 1 callersFunctionbuildSearchAttributes
()
service/worker/workerdeployment/util.go:438
↓ 1 callersMethodbuildSelectStmt
( namespaceID namespace.ID, queryString string, pageSize int, token *pageTokenLegacy, )
common/persistence/visibility/store/sql/query_converter_legacy.go:28
↓ 1 callersMethodbuildSnapshot
(state *MutableStateImpl)
service/history/workflow/mutable_state_impl_test.go:5606
↓ 1 callersFunctionbuildSuccessMessage
buildSuccessMessage creates success notification with report summary
tools/flakereport/slack.go:41
↓ 1 callersFunctionbuildTLSHTTPClient
Build Http Client with TLS
common/persistence/visibility/store/elasticsearch/client/client_v7.go:109
↓ 1 callersMethodbuildTags
(attrs attribute.Set)
common/metrics/statsd_exporter.go:269
↓ 1 callersFunctionbuildTallyTimerHistogramBuckets
( clientConfig *ClientConfig, config *PrometheusConfig, )
common/metrics/config.go:344
↓ 1 callersFunctionbuildTemplateData
()
cmd/tools/genroutingkeyextractor/main.go:49
↓ 1 callersMethodbuildTemporalPauseInfoEntries
()
service/history/workflow/mutable_state_impl.go:6959
↓ 1 callersFunctioncalcRampThreshold
calcRampThreshold returns a number in [0, 100) that is deterministically calculated based on the passed id. If id is empty, a random threshold is retu
common/worker_versioning/worker_versioning.go:914
↓ 1 callersFunctioncalculateAverage
calculateAverage computes the mean duration
tools/ci-notify/github.go:108
↓ 1 callersFunctioncalculateMedian
calculateMedian computes the median duration
tools/ci-notify/github.go:121
↓ 1 callersMethodcallCreateFromMigrationStateNoRetry
( ctx context.Context, request *CreateFromMigrationStateRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:319
↓ 1 callersMethodcallCreateScheduleNoRetry
( ctx context.Context, request *CreateScheduleRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:61
↓ 1 callersMethodcallCreateSentinelNoRetry
( ctx context.Context, request *CreateSentinelRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:362
↓ 1 callersMethodcallDeleteActivityExecutionNoRetry
( ctx context.Context, request *DeleteActivityExecutionRequest, opts ...grpc.CallOption, )
chasm/lib/activity/gen/activitypb/v1/service_client.pb.go:276
↓ 1 callersMethodcallDeleteNexusOperationNoRetry
( ctx context.Context, request *DeleteNexusOperationRequest, opts ...grpc.CallOption, )
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go:233
↓ 1 callersMethodcallDeleteScheduleNoRetry
( ctx context.Context, request *DeleteScheduleRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:190
↓ 1 callersMethodcallDescribeActivityExecutionNoRetry
( ctx context.Context, request *DescribeActivityExecutionRequest, opts ...grpc.CallOption, )
chasm/lib/activity/gen/activitypb/v1/service_client.pb.go:104
↓ 1 callersMethodcallDescribeNexusOperationNoRetry
( ctx context.Context, request *DescribeNexusOperationRequest, opts ...grpc.CallOption, )
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go:104
↓ 1 callersMethodcallDescribeScheduleNoRetry
( ctx context.Context, request *DescribeScheduleRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:233
↓ 1 callersFunctioncallErrorToFailure
callErrorToFailure converts a Nexus call error to a Temporal failure with retryability. Always returns a non-nil failure.
chasm/lib/nexusoperation/task_handler_helpers.go:142
↓ 1 callersMethodcallListScheduleMatchingTimesNoRetry
( ctx context.Context, request *ListScheduleMatchingTimesRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:276
↓ 1 callersMethodcallMigrateToWorkflowNoRetry
( ctx context.Context, request *MigrateToWorkflowRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:405
↓ 1 callersMethodcallPatchScheduleNoRetry
( ctx context.Context, request *PatchScheduleRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:147
↓ 1 callersMethodcallPollActivityExecutionNoRetry
( ctx context.Context, request *PollActivityExecutionRequest, opts ...grpc.CallOption, )
chasm/lib/activity/gen/activitypb/v1/service_client.pb.go:147
↓ 1 callersMethodcallPollNexusOperationNoRetry
( ctx context.Context, request *PollNexusOperationRequest, opts ...grpc.CallOption, )
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go:276
↓ 1 callersMethodcallRequestCancelActivityExecutionNoRetry
( ctx context.Context, request *RequestCancelActivityExecutionRequest, opts ...grpc.CallOption, )
chasm/lib/activity/gen/activitypb/v1/service_client.pb.go:233
↓ 1 callersMethodcallRequestCancelNexusOperationNoRetry
( ctx context.Context, request *RequestCancelNexusOperationRequest, opts ...grpc.CallOption, )
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go:147
↓ 1 callersMethodcallStartActivityExecutionNoRetry
( ctx context.Context, request *StartActivityExecutionRequest, opts ...grpc.CallOption, )
chasm/lib/activity/gen/activitypb/v1/service_client.pb.go:61
↓ 1 callersMethodcallStartNexusOperationNoRetry
( ctx context.Context, request *StartNexusOperationRequest, opts ...grpc.CallOption, )
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go:61
↓ 1 callersMethodcallTerminateActivityExecutionNoRetry
( ctx context.Context, request *TerminateActivityExecutionRequest, opts ...grpc.CallOption, )
chasm/lib/activity/gen/activitypb/v1/service_client.pb.go:190
↓ 1 callersMethodcallTerminateNexusOperationNoRetry
( ctx context.Context, request *TerminateNexusOperationRequest, opts ...grpc.CallOption, )
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_client.pb.go:190
↓ 1 callersMethodcallTestNoRetry
( ctx context.Context, request *TestRequest, opts ...grpc.CallOption, )
chasm/lib/tests/gen/testspb/v1/service_client.pb.go:62
↓ 1 callersMethodcallUpdateScheduleNoRetry
( ctx context.Context, request *UpdateScheduleRequest, opts ...grpc.CallOption, )
chasm/lib/scheduler/gen/schedulerpb/v1/service_client.pb.go:104
↓ 1 callersFunctioncallbacksRequireRequestID
(msg *updatepb.Request)
service/history/workflow/update/validation.go:47
↓ 1 callersMethodcallerInfoContext
(ctx context.Context)
service/matching/task_queue_partition_manager.go:1886
↓ 1 callersFunctioncanDedup
(startReq *historyservice.StartWorkflowExecutionRequest, currentWorkflowLease api.WorkflowLease)
service/history/api/multioperation/api.go:420
↓ 1 callersFunctioncancelCallOutcomeTag
(callCtx context.Context, callErr error)
components/nexusoperations/executors.go:1002
↓ 1 callersFunctioncancelCallOutcomeTag
cancelCallOutcomeTag returns a metric tag for the outcome of a cancel call.
chasm/lib/nexusoperation/task_handler_helpers.go:118
↓ 1 callersMethodcancelNexusOperation
(ctx context.Context, callbackUrl, callbackToken string)
tests/xdc/nexus_state_replication_test.go:738
↓ 1 callersMethodcancelOnHistoryService
( ctx context.Context, ns *namespace.Namespace, args cancelArgs, )
components/nexusoperations/executors.go:1192
↓ 1 callersMethodcancelOutstandingWorkerPolls
cancelOutstandingWorkerPolls fans out poll cancellation to all partitions of the task queue. This is a best-effort operation - errors are logged but d
service/frontend/workflow_handler.go:3053
↓ 1 callersMethodcancelWorkflow
(ex *commonpb.WorkflowExecution)
service/worker/scheduler/workflow.go:1615
↓ 1 callersMethodcancelWorkflow
( ctx context.Context, scheduler *Scheduler, target *commonpb.WorkflowExecution, )
chasm/lib/scheduler/invoker_tasks.go:726
↓ 1 callersMethodcancelWorkflows
cancelWorkflows does a best-effort attempt to cancel all workflow executions provided in targets.
chasm/lib/scheduler/invoker_tasks.go:261
↓ 1 callersMethodcapturePanicAndRecordMetrics
(ctxPtr *context.Context, errPtr *error)
service/frontend/nexus_completion_http_handler.go:460
↓ 1 callersFunctionchainUnaryInterceptors
(interceptors []grpc.UnaryServerInterceptor)
service/frontend/http_api_server.go:488
↓ 1 callersFunctionchainUnaryServerInterceptors
Mostly taken from https://github.com/grpc/grpc-go/blob/v1.56.1/server.go#L1124-L1158 with slight modifications.
service/frontend/http_api_server.go:477
↓ 1 callersMethodcheckBadBinary
(namespaceEntry *namespace.Namespace, binaryChecksum string)
service/frontend/workflow_handler.go:6585
↓ 1 callersMethodcheckBaseExecutionInfo
(incomingTaskExecutionInfo *workflowspb.BaseExecutionInfo)
service/history/replication/executable_history_task.go:405
↓ 1 callersMethodcheckBatchOperationFails
(env *testcore.TestEnv, jobID string, numWorkflows int)
tests/worker_deployment_version_test.go:2819
↓ 1 callersFunctioncheckClusterIncludedInReplicationConfig
(clusterName string, repCfg []*replicationpb.ClusterReplicationConfig)
common/namespace/nsreplication/replication_admitter.go:35
↓ 1 callersMethodcheckConflict
(token int64)
service/worker/scheduler/workflow.go:1283
↓ 1 callersMethodcheckEvents
( incomingEventBatches [][]*historypb.HistoryEvent, )
service/history/replication/executable_history_task.go:419
↓ 1 callersMethodcheckForMissingTaskQueues
checkForMissingTaskQueues checks if all the task-queues in the previous version are present in the new version
service/worker/workerdeployment/client.go:1952
↓ 1 callersMethodcheckHandoverOnce
Check if remote cluster has caught up on all shards on replication tasks
service/worker/migration/activities.go:353
↓ 1 callersMethodcheckHost
(ctx context.Context, hostAddress string)
service/frontend/health_check.go:170
↓ 1 callersFunctioncheckImports
(files map[string]protoreflect.FileDescriptor)
cmd/tools/getproto/main.go:153
↓ 1 callersMethodcheckInFlightLimit
()
service/history/workflow/update/registry.go:398
↓ 1 callersFunctioncheckMainDatabase
( cfg config.Persistence, r resolver.ServiceResolver, logger log.Logger, )
common/persistence/sql/version_checker.go:28
↓ 1 callersFunctioncheckMainKeyspace
( cfg config.Persistence, r resolver.ServiceResolver, logger log.Logger, )
common/persistence/cassandra/version_checker.go:27
↓ 1 callersMethodcheckNamespace
checkNamespace validates that batchParams targets the worker's own namespace. The NamespaceId, Request.Namespace (if set), and AdminRequest.Namespace
service/worker/batcher/activities.go:291
↓ 1 callersMethodcheckNamespaceMatch
(requestNamespace *namespace.Namespace, tokenNamespace *namespace.Namespace)
common/rpc/interceptor/namespace_validator.go:355
↓ 1 callersMethodcheckNamespaceState
(namespaceEntry *namespace.Namespace, fullMethod string)
common/rpc/interceptor/namespace_validator.go:366
↓ 1 callersMethodcheckPrecond
(ackLevel int64, batchSize int, ignoreTimeCond bool)
service/matching/task_gc.go:87
↓ 1 callersMethodcheckProcessor
()
common/persistence/visibility/store/elasticsearch/visibility_store.go:364
↓ 1 callersMethodcheckQueryBlackholed
nolint:staticcheck // SA1019: [cleanup-wv-3.1]
service/matching/task_queue_partition_manager.go:2408
↓ 1 callersMethodcheckReplicationDLQEmptyLoop
()
service/history/replication/task_processor_manager.go:237
↓ 1 callersMethodcheckReplicationDLQSize
()
service/history/replication/task_processor_manager.go:311
↓ 1 callersMethodcheckReplicationOnRemoteCluster
Check if remote cluster has caught up on all shards on replication tasks from target replica.
service/worker/migration/activities.go:1109
↓ 1 callersMethodcheckReplicationOnce
Check if remote cluster has caught up on all shards on replication tasks
service/worker/migration/activities.go:224
↓ 1 callersMethodcheckReplicationState
(namespaceEntry *namespace.Namespace, fullMethod string, businessID string)
common/rpc/interceptor/namespace_validator.go:388
↓ 1 callersMethodcheckShardReadiness
( ctx context.Context, shards []int32, )
service/history/shard/controller_impl.go:484
↓ 1 callersMethodcheckSkipWorkflowExecution
( ctx context.Context, request *verifyReplicationTasksRequest, execution *ExecutionInfo, ns *namespace.Nam
service/worker/migration/activities.go:798
↓ 1 callersMethodcheckSourceCluster
(incomingTaskSourceCluster string)
service/history/replication/executable_history_task.go:383
↓ 1 callersMethodcheckTableVersion
(ctx context.Context)
service/matching/nexus_endpoint_client.go:388
↓ 1 callersFunctioncheckTemplatingEnabled
(content []byte)
common/config/loader.go:268
← previousnext →11,001–11,100 of 43,335, ranked by callers