Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/temporalio/temporal
/ functions
Functions
43,335 in github.com/temporalio/temporal
⨍
Functions
43,335
◇
Types & classes
5,614
↓ 4 callers
Function
cliHandler
root handler for all cli commands
tools/sql/main.go:23
↓ 4 callers
Method
clip
clip updates ready to an allowable range based on the given parameters.
service/matching/matcher_data.go:726
↓ 4 callers
Method
closeTransactionPrepareReplicationTasks
( transactionPolicy historyi.TransactionPolicy, eventBatches [][]*historypb.HistoryEvent, clearBufferEvents
service/history/workflow/mutable_state_impl.go:8219
↓ 4 callers
Function
constructHistoryFilenameMultipart
(namespaceID, workflowID, runID string, version int64, partNumber int)
common/archiver/gcloud/util.go:27
↓ 4 callers
Function
constructIndexedVisibilitySearchPrefix
( path string, namespaceID string, primaryIndexKey string, primaryIndexValue string, secondaryIndexType s
common/archiver/s3store/util.go:161
↓ 4 callers
Function
containsFullyRamped
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 callers
Function
convertErrors
( conflictRecord map[string]any, conflictIter gocql.Iter, currentRecordRunID string, requestShardID int32,
common/persistence/cassandra/errors.go:48
↓ 4 callers
Function
convertHistoryReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.HistoryReplicationTask, shardID
service/history/replication/raw_task_converter.go:334
↓ 4 callers
Function
convertInt
(val any)
common/dynamicconfig/collection.go:577
↓ 4 callers
Function
convertSyncHSMReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.SyncHSMTask, workflowCache wcac
service/history/replication/raw_task_converter.go:251
↓ 4 callers
Method
convertValueExpr
( exprRef *sqlparser.Expr, name string, saFieldName string, saType enumspb.IndexedValueType, )
common/persistence/visibility/store/sql/query_converter_legacy.go:478
↓ 4 callers
Method
convertWhereExpr
(expr sqlparser.Expr, parsedQuery *parsedQuery)
common/archiver/gcloud/query_parser.go:78
↓ 4 callers
Method
convertWhereExpr
(expr sqlparser.Expr, parsedQuery *parsedQuery)
common/archiver/filestore/query_parser.go:71
↓ 4 callers
Method
convertWhereExpr
(expr sqlparser.Expr, parsedQuery *parsedQuery)
common/archiver/s3store/query_parser.go:82
↓ 4 callers
Function
copyMapPayload
(input map[string]*commonpb.Payload)
service/history/visibility_queue_task_executor.go:684
↓ 4 callers
Method
copyPersistenceConfig
()
tests/testcore/onebox.go:314
↓ 4 callers
Function
copyVertex
(vertex []Vertex)
common/testing/history_event_util.go:966
↓ 4 callers
Method
countGroupByExecutions
( ctx context.Context, selectFilter *sqlplugin.VisibilitySelectFilter, chasmMapper *chasm.VisibilitySearchA
common/persistence/visibility/store/sql/visibility_store.go:694
↓ 4 callers
Method
createAddWorkflowTaskRequest
( task *tasks.WorkflowTask, mutableState historyi.MutableState, )
service/history/transfer_queue_active_task_executor_test.go:3121
↓ 4 callers
Function
createAssignmentRuleWithRamp
(buildId string, ramp float32)
service/matching/version_rule_helper_test.go:91
↓ 4 callers
Method
createChildWorkflowExecutionRequest
( childNamespace namespace.Name, task *tasks.StartChildExecutionTask, mutableState historyi.MutableState,
service/history/transfer_queue_active_task_executor_test.go:3209
↓ 4 callers
Method
createCluster
(t *testing.T, dynamicConfig map[dynamicconfig.Key]any, shared bool, clusterOpts []TestClusterOption)
tests/testcore/test_cluster_pool.go:266
↓ 4 callers
Function
createDeploymentOptions
(deploymentName string, buildID string)
tests/task_queue_stats_test.go:1613
↓ 4 callers
Method
createHistoryEventReplicationTaskFromHistoryEventBatch
( namespaceID string, workflowID string, runID string, events []*historypb.HistoryEvent, newRunEvents []*
tests/ndc/replication_migration_back_test.go:578
↓ 4 callers
Function
createNexusOperationFailure
(operation Operation, scheduledEventID int64, cause *failurepb.Failure)
components/nexusoperations/executors.go:948
↓ 4 callers
Method
createPauseRuleRequest
( namespace, activityType, ruleID string, )
tests/activity_api_rules_test.go:623
↓ 4 callers
Method
createResponse
( info *persistencespb.NamespaceInfo, config *persistencespb.NamespaceConfig, replicationConfig *persistenc
service/frontend/namespace_handler.go:883
↓ 4 callers
Method
createTaskQueue
( rangeID int64, )
common/persistence/tests/task_queue_task.go:236
↓ 4 callers
Function
decodePayloadsInJSON
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 callers
Method
decodePayloadsString
(ps *commonpb.Payloads)
tests/xdc/failover_test.go:87
↓ 4 callers
Method
definition
()
chasm/search_attribute.go:104
↓ 4 callers
Method
deleteHistoryBranch
( shardID int32, branchToken []byte, )
common/persistence/tests/history_store.go:783
↓ 4 callers
Method
describeNamespaceID
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 callers
Function
deserializePageTokenLegacy
(data []byte)
common/persistence/visibility/store/sql/pagination_token_legacy.go:16
↓ 4 callers
Function
deserializeTask
( registrableTask *RegistrableTask, taskBlob *commonpb.DataBlob, )
chasm/tree.go:3128
↓ 4 callers
Method
dial
(rpcAddress string)
common/testing/nettest/rpc_factory.go:61
↓ 4 callers
Function
dialTestServiceAndGetTLSInfo
( s *suite.Suite, hostport string, clientFactory *TestFactory, serverType ServerUsageType, )
common/rpc/test/rpc_common_test.go:136
↓ 4 callers
Method
dispatchUpgrade
( env *testcore.TestEnv, newVersioning, stopOld bool, )
tests/versioning_test.go:1646
↓ 4 callers
Method
doPollWftAndHandle
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 callers
Method
doReconcileOutboundStreams
( streamKeys map[ClusterShardKeyPair]struct{}, )
service/history/replication/stream_receiver_monitor.go:267
↓ 4 callers
Method
dropKeyspace
dropKeyspace drops a Keyspace
tools/cassandra/cqlclient.go:155
↓ 4 callers
Function
dualWriteWrapper
( ctx context.Context, v *VisibilityManagerDual, request *RequestT, fn func(manager.VisibilityManager, con
common/persistence/visibility/visibility_manager_dual.go:221
↓ 4 callers
Function
durationMultipleOf
(amt int64, mult time.Duration)
common/primitives/timestamp/duration.go:53
↓ 4 callers
Function
emitOperationOutcome
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 callers
Method
emitTaskDispatchLatency
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 callers
Method
emptyDataBlob
()
chasm/tree_test.go:4086
↓ 4 callers
Method
endNetworkDial
(ndt *networkDialTrace, dialErr error)
common/rpc/dial_tracer.go:59
↓ 4 callers
Function
enqueueTask
( ctx context.Context, manager persistence.HistoryTaskQueueManager, queueKey persistence.QueueKey, task *t
common/persistence/tests/history_task_queue_manager_test_suite.go:329
↓ 4 callers
Method
ensureCreateDeployment
( env *VersioningTestEnv, tv *testvars.TestVars, )
tests/worker_deployment_test.go:153
↓ 4 callers
Method
ensureNotDeleted
()
service/worker/workerdeployment/version_workflow.go:381
↓ 4 callers
Method
enterSplitBrainState
(ctx context.Context)
tests/xdc/history_replication_signals_and_updates_test.go:620
↓ 4 callers
Method
equalHistoryEvents
( expectedHistoryEvents []*historypb.HistoryEvent, expectedEventsAttributes []map[string]any, actualHistory
common/testing/historyrequire/history_require.go:263
↓ 4 callers
Method
err
()
service/matching/task.go:125
↓ 4 callers
Method
error
()
chasm/lib/callback/tasks.go:30
↓ 4 callers
Function
errorIfOverThreshold
(checkType string, value float64, threshold float64, message string)
service/history/deep_health_check.go:98
↓ 4 callers
Function
escapeTableCell
escapeTableCell replaces pipe characters so they don't corrupt GFM table rows.
tools/flakereport/writer.go:117
↓ 4 callers
Method
evictByCapacity
(threshold time.Time)
service/matching/workers/registry_impl.go:211
↓ 4 callers
Method
execute
(task tasks.Task)
service/history/visibility_queue_task_executor_test.go:806
↓ 4 callers
Method
executeDeleteHistoryEventTask
( ctx context.Context, task *tasks.DeleteHistoryEventTask, )
service/history/timer_queue_task_executor_base.go:81
↓ 4 callers
Function
executeRecordCompletedAction
(t *testing.T, tc recordCompletedActionTestCase)
chasm/lib/scheduler/scheduler_record_completed_action_test.go:24
↓ 4 callers
Method
executeTransaction
( ctx context.Context, transactionPolicy nDCTransactionPolicy, currentWorkflow Workflow, targetWorkflow Wo
service/history/ndc/transaction_manager_new_workflow.go:303
↓ 4 callers
Function
executionExistsOnSource
( ctx context.Context, workflowKey definition.WorkflowKey, archetypeID chasm.ArchetypeID, logger log.Logge
service/history/ndc_standby_task_util.go:82
↓ 4 callers
Function
expiredBlock
(n int)
service/matching/backlog_manager_test.go:488
↓ 4 callers
Method
failTest
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 callers
Function
failWorkflowTask
( mutableState historyi.MutableState, workflowTask *historyi.WorkflowTaskInfo, workflowTaskFailureCause enu
service/history/workflow/util.go:27
↓ 4 callers
Method
fairLevel
()
service/matching/task.go:336
↓ 4 callers
Method
fatal
(err error)
temporaltest/server.go:35
↓ 4 callers
Function
file_temporal_server_api_cluster_v1_message_proto_rawDescGZIP
()
api/cluster/v1/message.pb.go:313
↓ 4 callers
Function
file_temporal_server_api_common_v1_dlq_proto_rawDescGZIP
()
api/common/v1/dlq.pb.go:271
↓ 4 callers
Method
find
(set S, key K)
common/collection/sorted_set_manager.go:65
↓ 4 callers
Method
findAndCompactLowSliceCount
( readers map[int64]Reader, readerPredicate func(int64) bool, slicePredicate SlicePredicate, targetSliceCo
service/history/queues/action_slice_count.go:112
↓ 4 callers
Function
findRequiredModuleVersion
(modFile *modfile.File, modulePath string)
cmd/tools/check-dependencies/main.go:172
↓ 4 callers
Method
flush
( ctx context.Context, )
service/history/ndc/buffer_event_flusher.go:16
↓ 4 callers
Method
flushWorkerCommandsTasks
flushWorkerCommandsTasks creates WorkerCommandsTasks for all collected worker commands, batched by control queue.
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go:752
↓ 4 callers
Function
formatSinkPath
(sinkPath string)
common/archiver/gcloud/connector/client.go:179
↓ 4 callers
Function
formatValue
(t tag.Tag)
common/testing/testlogger/testlogger.go:698
↓ 4 callers
Method
found
()
cmd/tools/genrpcwrappers/main.go:38
↓ 4 callers
Method
generateInboundStreamKeys
()
service/history/replication/stream_receiver_monitor.go:173
↓ 4 callers
Method
generateReplicationAttribute
( namespaceId string, workflowId string, runId string, )
service/history/replication/executable_activity_state_task_test.go:447
↓ 4 callers
Method
generateReplicationTask
()
service/history/workflow/mutable_state_impl.go:9006
↓ 4 callers
Method
generateResponse
generateResponse is a helper for generating StartWorkflowExecutionResponse for eager and non-eager workflow start requests.
service/history/api/startworkflow/api.go:755
↓ 4 callers
Function
generateStateReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, workflowKey definition.WorkflowKey, archetypeID
service/history/replication/raw_task_converter.go:397
↓ 4 callers
Function
genericTypePrefix
(t reflect.Type)
chasm/fields_iterator.go:137
↓ 4 callers
Method
get
()
common/dynamicconfig/gradual_change_test.go:375
↓ 4 callers
Function
getArchetype
(c *cli.Context)
tools/tdbg/util.go:312
↓ 4 callers
Method
getBacklogCountHint
()
service/matching/ack_manager.go:130
↓ 4 callers
Method
getBacklogHeadAge
()
service/matching/task_reader.go:78
↓ 4 callers
Method
getCoalesceCloseTimeExpr
()
common/persistence/visibility/store/sql/query_converter_legacy_mysql.go:87
↓ 4 callers
Method
getCoalesceCloseTimeExpr
()
common/persistence/visibility/store/sql/query_converter_legacy_sqlite.go:52
↓ 4 callers
Method
getCoalesceCloseTimeExpr
()
common/persistence/visibility/store/sql/query_converter_legacy_postgresql.go:68
↓ 4 callers
Method
getCommandBase
()
tools/common/schema/test/updatetest.go:155
↓ 4 callers
Method
getCommandBase
()
tools/common/schema/test/setuptest.go:133
↓ 4 callers
Method
getCompletionCh
()
service/history/workflow/query.go:28
↓ 4 callers
Function
getDeploymentVersionAndRevisionNumberForWorkflowID
TODO (Shahab): move this method to a better place
service/history/api/recordactivitytaskstarted/api.go:307
↓ 4 callers
Method
getEventTime
()
service/history/ndc/replication_task.go:33
↓ 4 callers
Method
getForwardInfo
(task *internalTask)
service/matching/forwarder.go:163
↓ 4 callers
Method
getForwardInfo
(task *internalTask)
service/matching/pri_forwarder.go:130
↓ 4 callers
Method
getFxOptionsForService
(serviceName primitives.ServiceName)
tests/testcore/onebox.go:631
↓ 4 callers
Function
getHistoryRequest
(nextPageToken []byte)
service/frontend/workflow_handler_test.go:3860
↓ 4 callers
Method
getIDs
(m map[string]query)
service/history/workflow/query_registry.go:183
← previous
next →
5,201–5,300 of 43,335, ranked by callers