MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 4 callersFunctioncliHandler
root handler for all cli commands
tools/sql/main.go:23
↓ 4 callersMethodclip
clip updates ready to an allowable range based on the given parameters.
service/matching/matcher_data.go:726
↓ 4 callersMethodcloseTransactionPrepareReplicationTasks
( transactionPolicy historyi.TransactionPolicy, eventBatches [][]*historypb.HistoryEvent, clearBufferEvents
service/history/workflow/mutable_state_impl.go:8219
↓ 4 callersFunctionconstructHistoryFilenameMultipart
(namespaceID, workflowID, runID string, version int64, partNumber int)
common/archiver/gcloud/util.go:27
↓ 4 callersFunctionconstructIndexedVisibilitySearchPrefix
( path string, namespaceID string, primaryIndexKey string, primaryIndexValue string, secondaryIndexType s
common/archiver/s3store/util.go:161
↓ 4 callersFunctioncontainsFullyRamped
containsFullyRamped returns true if there exists a fully-ramped assignment rule. A fully-ramped assignment rule has a ramp percentage of 100.
service/matching/version_rule_helpers.go:434
↓ 4 callersFunctionconvertErrors
( conflictRecord map[string]any, conflictIter gocql.Iter, currentRecordRunID string, requestShardID int32,
common/persistence/cassandra/errors.go:48
↓ 4 callersFunctionconvertHistoryReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.HistoryReplicationTask, shardID
service/history/replication/raw_task_converter.go:334
↓ 4 callersFunctionconvertInt
(val any)
common/dynamicconfig/collection.go:577
↓ 4 callersFunctionconvertSyncHSMReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.SyncHSMTask, workflowCache wcac
service/history/replication/raw_task_converter.go:251
↓ 4 callersMethodconvertValueExpr
( exprRef *sqlparser.Expr, name string, saFieldName string, saType enumspb.IndexedValueType, )
common/persistence/visibility/store/sql/query_converter_legacy.go:478
↓ 4 callersMethodconvertWhereExpr
(expr sqlparser.Expr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:78
↓ 4 callersMethodconvertWhereExpr
(expr sqlparser.Expr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:71
↓ 4 callersMethodconvertWhereExpr
(expr sqlparser.Expr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:82
↓ 4 callersFunctioncopyMapPayload
(input map[string]*commonpb.Payload)
service/history/visibility_queue_task_executor.go:684
↓ 4 callersMethodcopyPersistenceConfig
()
tests/testcore/onebox.go:314
↓ 4 callersFunctioncopyVertex
(vertex []Vertex)
common/testing/history_event_util.go:966
↓ 4 callersMethodcountGroupByExecutions
( ctx context.Context, selectFilter *sqlplugin.VisibilitySelectFilter, chasmMapper *chasm.VisibilitySearchA
common/persistence/visibility/store/sql/visibility_store.go:694
↓ 4 callersMethodcreateAddWorkflowTaskRequest
( task *tasks.WorkflowTask, mutableState historyi.MutableState, )
service/history/transfer_queue_active_task_executor_test.go:3121
↓ 4 callersFunctioncreateAssignmentRuleWithRamp
(buildId string, ramp float32)
service/matching/version_rule_helper_test.go:91
↓ 4 callersMethodcreateChildWorkflowExecutionRequest
( childNamespace namespace.Name, task *tasks.StartChildExecutionTask, mutableState historyi.MutableState,
service/history/transfer_queue_active_task_executor_test.go:3209
↓ 4 callersMethodcreateCluster
(t *testing.T, dynamicConfig map[dynamicconfig.Key]any, shared bool, clusterOpts []TestClusterOption)
tests/testcore/test_cluster_pool.go:266
↓ 4 callersFunctioncreateDeploymentOptions
(deploymentName string, buildID string)
tests/task_queue_stats_test.go:1613
↓ 4 callersMethodcreateHistoryEventReplicationTaskFromHistoryEventBatch
( namespaceID string, workflowID string, runID string, events []*historypb.HistoryEvent, newRunEvents []*
tests/ndc/replication_migration_back_test.go:578
↓ 4 callersFunctioncreateNexusOperationFailure
(operation Operation, scheduledEventID int64, cause *failurepb.Failure)
components/nexusoperations/executors.go:948
↓ 4 callersMethodcreatePauseRuleRequest
( namespace, activityType, ruleID string, )
tests/activity_api_rules_test.go:623
↓ 4 callersMethodcreateResponse
( info *persistencespb.NamespaceInfo, config *persistencespb.NamespaceConfig, replicationConfig *persistenc
service/frontend/namespace_handler.go:883
↓ 4 callersMethodcreateTaskQueue
( rangeID int64, )
common/persistence/tests/task_queue_task.go:236
↓ 4 callersFunctiondecodePayloadsInJSON
decodePayloadsInJSON parses JSON data, finds Payload objects, and makes them human-readable: metadata bytes are decoded from base64 to strings, and da
tools/tdbg/proto_decoder.go:19
↓ 4 callersMethoddecodePayloadsString
(ps *commonpb.Payloads)
tests/xdc/failover_test.go:87
↓ 4 callersMethoddefinition
()
chasm/search_attribute.go:104
↓ 4 callersMethoddeleteHistoryBranch
( shardID int32, branchToken []byte, )
common/persistence/tests/history_store.go:783
↓ 4 callersMethoddescribeNamespaceID
describeNamespaceID looks up the namespace ID from cluster[0]; the same ID is shared on standby once the namespace replicates.
tests/xdc/timeskipping_replication_test.go:61
↓ 4 callersFunctiondeserializePageTokenLegacy
(data []byte)
common/persistence/visibility/store/sql/pagination_token_legacy.go:16
↓ 4 callersFunctiondeserializeTask
( registrableTask *RegistrableTask, taskBlob *commonpb.DataBlob, )
chasm/tree.go:3128
↓ 4 callersMethoddial
(rpcAddress string)
common/testing/nettest/rpc_factory.go:61
↓ 4 callersFunctiondialTestServiceAndGetTLSInfo
( s *suite.Suite, hostport string, clientFactory *TestFactory, serverType ServerUsageType, )
common/rpc/test/rpc_common_test.go:136
↓ 4 callersMethoddispatchUpgrade
( env *testcore.TestEnv, newVersioning, stopOld bool, )
tests/versioning_test.go:1646
↓ 4 callersMethoddoPollWftAndHandle
doPollWftAndHandle can be used in sync and async mode. For async mode pass the async channel. It will be closed when the task is handled. Returns the
tests/versioning_3_test.go:4710
↓ 4 callersMethoddoReconcileOutboundStreams
( streamKeys map[ClusterShardKeyPair]struct{}, )
service/history/replication/stream_receiver_monitor.go:267
↓ 4 callersMethoddropKeyspace
dropKeyspace drops a Keyspace
tools/cassandra/cqlclient.go:155
↓ 4 callersFunctiondualWriteWrapper
( ctx context.Context, v *VisibilityManagerDual, request *RequestT, fn func(manager.VisibilityManager, con
common/persistence/visibility/visibility_manager_dual.go:221
↓ 4 callersFunctiondurationMultipleOf
(amt int64, mult time.Duration)
common/primitives/timestamp/duration.go:53
↓ 4 callersFunctionemitOperationOutcome
emitOperationOutcome records the terminal outcome counter and the shared latency metrics for a closed operation. The outcome-specific counter is suppl
components/nexusoperations/metrics.go:70
↓ 4 callersMethodemitTaskDispatchLatency
emitTaskDispatchLatency emits latency metrics for a task dispatched to a worker. Here is what task_dispatch_latency measures vs schedule_to_start_late
service/matching/matching_engine.go:2921
↓ 4 callersMethodemptyDataBlob
()
chasm/tree_test.go:4086
↓ 4 callersMethodendNetworkDial
(ndt *networkDialTrace, dialErr error)
common/rpc/dial_tracer.go:59
↓ 4 callersFunctionenqueueTask
( ctx context.Context, manager persistence.HistoryTaskQueueManager, queueKey persistence.QueueKey, task *t
common/persistence/tests/history_task_queue_manager_test_suite.go:329
↓ 4 callersMethodensureCreateDeployment
( env *VersioningTestEnv, tv *testvars.TestVars, )
tests/worker_deployment_test.go:153
↓ 4 callersMethodensureNotDeleted
()
service/worker/workerdeployment/version_workflow.go:381
↓ 4 callersMethodenterSplitBrainState
(ctx context.Context)
tests/xdc/history_replication_signals_and_updates_test.go:620
↓ 4 callersMethodequalHistoryEvents
( expectedHistoryEvents []*historypb.HistoryEvent, expectedEventsAttributes []map[string]any, actualHistory
common/testing/historyrequire/history_require.go:263
↓ 4 callersMethoderr
()
service/matching/task.go:125
↓ 4 callersMethoderror
()
chasm/lib/callback/tasks.go:30
↓ 4 callersFunctionerrorIfOverThreshold
(checkType string, value float64, threshold float64, message string)
service/history/deep_health_check.go:98
↓ 4 callersFunctionescapeTableCell
escapeTableCell replaces pipe characters so they don't corrupt GFM table rows.
tools/flakereport/writer.go:117
↓ 4 callersMethodevictByCapacity
(threshold time.Time)
service/matching/workers/registry_impl.go:211
↓ 4 callersMethodexecute
(task tasks.Task)
service/history/visibility_queue_task_executor_test.go:806
↓ 4 callersMethodexecuteDeleteHistoryEventTask
( ctx context.Context, task *tasks.DeleteHistoryEventTask, )
service/history/timer_queue_task_executor_base.go:81
↓ 4 callersFunctionexecuteRecordCompletedAction
(t *testing.T, tc recordCompletedActionTestCase)
chasm/lib/scheduler/scheduler_record_completed_action_test.go:24
↓ 4 callersMethodexecuteTransaction
( ctx context.Context, transactionPolicy nDCTransactionPolicy, currentWorkflow Workflow, targetWorkflow Wo
service/history/ndc/transaction_manager_new_workflow.go:303
↓ 4 callersFunctionexecutionExistsOnSource
( ctx context.Context, workflowKey definition.WorkflowKey, archetypeID chasm.ArchetypeID, logger log.Logge
service/history/ndc_standby_task_util.go:82
↓ 4 callersFunctionexpiredBlock
(n int)
service/matching/backlog_manager_test.go:488
↓ 4 callersMethodfailTest
failTest fails the test while dumping the stack, allowing us to know where in the code the failure arose.
common/testing/testlogger/testlogger.go:590
↓ 4 callersFunctionfailWorkflowTask
( mutableState historyi.MutableState, workflowTask *historyi.WorkflowTaskInfo, workflowTaskFailureCause enu
service/history/workflow/util.go:27
↓ 4 callersMethodfairLevel
()
service/matching/task.go:336
↓ 4 callersMethodfatal
(err error)
temporaltest/server.go:35
↓ 4 callersFunctionfile_temporal_server_api_cluster_v1_message_proto_rawDescGZIP
()
api/cluster/v1/message.pb.go:313
↓ 4 callersFunctionfile_temporal_server_api_common_v1_dlq_proto_rawDescGZIP
()
api/common/v1/dlq.pb.go:271
↓ 4 callersMethodfind
(set S, key K)
common/collection/sorted_set_manager.go:65
↓ 4 callersMethodfindAndCompactLowSliceCount
( readers map[int64]Reader, readerPredicate func(int64) bool, slicePredicate SlicePredicate, targetSliceCo
service/history/queues/action_slice_count.go:112
↓ 4 callersFunctionfindRequiredModuleVersion
(modFile *modfile.File, modulePath string)
cmd/tools/check-dependencies/main.go:172
↓ 4 callersMethodflush
( ctx context.Context, )
service/history/ndc/buffer_event_flusher.go:16
↓ 4 callersMethodflushWorkerCommandsTasks
flushWorkerCommandsTasks creates WorkerCommandsTasks for all collected worker commands, batched by control queue.
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:752
↓ 4 callersFunctionformatSinkPath
(sinkPath string)
common/archiver/gcloud/connector/client.go:179
↓ 4 callersFunctionformatValue
(t tag.Tag)
common/testing/testlogger/testlogger.go:698
↓ 4 callersMethodfound
()
cmd/tools/genrpcwrappers/main.go:38
↓ 4 callersMethodgenerateInboundStreamKeys
()
service/history/replication/stream_receiver_monitor.go:173
↓ 4 callersMethodgenerateReplicationAttribute
( namespaceId string, workflowId string, runId string, )
service/history/replication/executable_activity_state_task_test.go:447
↓ 4 callersMethodgenerateReplicationTask
()
service/history/workflow/mutable_state_impl.go:9006
↓ 4 callersMethodgenerateResponse
generateResponse is a helper for generating StartWorkflowExecutionResponse for eager and non-eager workflow start requests.
service/history/api/startworkflow/api.go:755
↓ 4 callersFunctiongenerateStateReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, workflowKey definition.WorkflowKey, archetypeID
service/history/replication/raw_task_converter.go:397
↓ 4 callersFunctiongenericTypePrefix
(t reflect.Type)
chasm/fields_iterator.go:137
↓ 4 callersMethodget
()
common/dynamicconfig/gradual_change_test.go:375
↓ 4 callersFunctiongetArchetype
(c *cli.Context)
tools/tdbg/util.go:312
↓ 4 callersMethodgetBacklogCountHint
()
service/matching/ack_manager.go:130
↓ 4 callersMethodgetBacklogHeadAge
()
service/matching/task_reader.go:78
↓ 4 callersMethodgetCoalesceCloseTimeExpr
()
common/persistence/visibility/store/sql/query_converter_legacy_mysql.go:87
↓ 4 callersMethodgetCoalesceCloseTimeExpr
()
common/persistence/visibility/store/sql/query_converter_legacy_sqlite.go:52
↓ 4 callersMethodgetCoalesceCloseTimeExpr
()
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:68
↓ 4 callersMethodgetCommandBase
()
tools/common/schema/test/updatetest.go:155
↓ 4 callersMethodgetCommandBase
()
tools/common/schema/test/setuptest.go:133
↓ 4 callersMethodgetCompletionCh
()
service/history/workflow/query.go:28
↓ 4 callersFunctiongetDeploymentVersionAndRevisionNumberForWorkflowID
TODO (Shahab): move this method to a better place
service/history/api/recordactivitytaskstarted/api.go:307
↓ 4 callersMethodgetEventTime
()
service/history/ndc/replication_task.go:33
↓ 4 callersMethodgetForwardInfo
(task *internalTask)
service/matching/forwarder.go:163
↓ 4 callersMethodgetForwardInfo
(task *internalTask)
service/matching/pri_forwarder.go:130
↓ 4 callersMethodgetFxOptionsForService
(serviceName primitives.ServiceName)
tests/testcore/onebox.go:631
↓ 4 callersFunctiongetHistoryRequest
(nextPageToken []byte)
service/frontend/workflow_handler_test.go:3860
↓ 4 callersMethodgetIDs
(m map[string]query)
service/history/workflow/query_registry.go:183
← previousnext →5,201–5,300 of 43,335, ranked by callers