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
↓ 6 callers
Function
checkWorkflowState
(state enumsspb.WorkflowExecutionState)
common/persistence/operation_mode_validator.go:292
↓ 6 callers
Method
clear
clear clears a bit (and shrinks the slice to the minimum required). note: caller must assign the result, as with append.
service/matching/bits.go:37
↓ 6 callers
Method
compareVersionHistory
( mutableState historyi.MutableState, incomingVersionHistory *historyspb.VersionHistory, )
service/history/ndc/hsm_state_replicator.go:218
↓ 6 callers
Method
conn
()
common/persistence/sql/sqlplugin/postgresql/db.go:66
↓ 6 callers
Method
conn
()
common/persistence/sql/sqlplugin/mysql/db.go:78
↓ 6 callers
Function
constructHistoryFilename
File name construction
common/archiver/filestore/util.go:163
↓ 6 callers
Function
contextNearDeadline
(ctx context.Context, tailroom time.Duration)
service/frontend/workflow_handler.go:1186
↓ 6 callers
Function
convertActivityStateReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.SyncActivityTask, workflowCache
service/history/replication/raw_task_converter.go:118
↓ 6 callers
Function
convertClusterReplicationConfigToProto
( input []string, )
common/namespace/nsreplication/transmission_task_handler.go:124
↓ 6 callers
Method
convertColName
(exprRef *sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter_legacy.go:436
↓ 6 callers
Function
convertCommonErrors
( operation string, err error, )
common/persistence/sql/common.go:128
↓ 6 callers
Method
convertError
convertError converts non-serviceerror errors to appropriate serviceerror types. Known persistence errors are converted to service errors with a reque
service/history/chasm_engine.go:1267
↓ 6 callers
Method
copyIteratorState
(itr *historyIterator)
common/archiver/history_iterator_test.go:630
↓ 6 callers
Method
createBatchResetWorkflow
(env *testcore.TestEnv, workflowFn WorkflowFunction)
tests/activity_api_batch_reset_test.go:42
↓ 6 callers
Method
createFile
(dir string, filename string)
common/archiver/filestore/util_test.go:408
↓ 6 callers
Method
createWorkflow
(env *testcore.TestEnv, workflowFn any)
tests/admin_batch_refresh_workflow_tasks_test.go:49
↓ 6 callers
Method
deleteAssignmentRule
deleteAssignmentRule deletes the versioning assignment rule at a given index. It checks the response and returns the conflict token.
tests/versioning_test.go:4484
↓ 6 callers
Method
deleteInternal
(element *list.Element)
common/cache/lru.go:380
↓ 6 callers
Method
describeNamespace
( t require.TestingT, testCluster *testcore.TestCluster, ns string, isGlobal bool, )
tests/xdc/base.go:418
↓ 6 callers
Method
describeStatsEventually
( buildIds map[string]bool, includeAllActive, reportPollers, internalTaskQueueStatus bool, check func(resp
service/matching/task_queue_partition_manager_test.go:1326
↓ 6 callers
Function
detailedErrorMessage
(err error)
common/persistence/visibility/store/elasticsearch/visibility_store.go:1306
↓ 6 callers
Function
directoryExists
(path string)
common/archiver/filestore/util.go:41
↓ 6 callers
Function
drainAndCalc
(sim *simulator)
tools/fairsim/sim_test.go:48
↓ 6 callers
Method
drivePollsUntilClosed
drivePollsUntilClosed runs the task poller up to maxIterations times or until the named workflow reaches COMPLETED. Poll errors (typically long-poll t
tests/timeskipping_propagation_test.go:732
↓ 6 callers
Method
emitDispatchLatency
(task *internalTask, forwarded bool)
service/matching/matcher.go:375
↓ 6 callers
Function
emitStateTransitionCount
( metricsHandler metrics.Handler, clusterMetadata cluster.Metadata, mutableState historyi.MutableState, )
service/history/workflow/context.go:1216
↓ 6 callers
Function
ensureContextTimeout
(ctx context.Context)
common/archiver/s3store/util.go:181
↓ 6 callers
Method
ensureNotDeleted
()
service/worker/workerdeployment/workflow.go:457
↓ 6 callers
Method
evaluateSingleStreamConnection
(key *ClusterShardKeyPair, current *streamStatus, previous *streamStatus)
service/history/replication/stream_receiver_monitor.go:339
↓ 6 callers
Function
executeNexusCompletion
(t *testing.T, tc nexusCompletionTestCase)
chasm/lib/scheduler/scheduler_nexus_completion_test.go:31
↓ 6 callers
Function
extractCurrentWorkflowConflictError
( conflictRecord map[string]any, currentRecordRunID string, requestCurrentRunID string, )
common/persistence/cassandra/errors.go:190
↓ 6 callers
Function
fairLevelFromProto
(l *taskqueuespb.FairLevel)
service/matching/fair_level.go:57
↓ 6 callers
Method
fetchAndEmitLogicalBacklogMetrics
fetchAndEmitLogicalBacklogMetrics calls Describe to get attributed backlog stats and emits approximate_backlog_count and approximate_backlog_age_secon
service/matching/task_queue_partition_manager.go:1584
↓ 6 callers
Function
file_temporal_server_api_cli_v1_message_proto_rawDescGZIP
()
api/cli/v1/message.pb.go:668
↓ 6 callers
Function
file_temporal_server_api_persistence_v1_nexus_proto_rawDescGZIP
()
api/persistence/v1/nexus.pb.go:448
↓ 6 callers
Method
findTransitionedEvents
(history []*historypb.HistoryEvent)
tests/timeskipping_fast_forward_test.go:54
↓ 6 callers
Function
formatDuration
formatDuration formats a duration in human-readable form
tools/ci-notify/github.go:141
↓ 6 callers
Method
generateRSAToken
(subject string, permissions []string, options errorTestOptions)
common/authorization/default_jwt_claim_mapper_test.go:369
↓ 6 callers
Method
generateStartedEventRefLink
(runID string)
service/history/api/startworkflow/api.go:818
↓ 6 callers
Method
getBuildIdsOfInterest
getBuildIdsOfInterest returns a list of build ids that point to the given buildId in the graph of redirect rules and adds the given build ID to that l
service/matching/reachability.go:174
↓ 6 callers
Method
getGetUserDataCount
getGetUserDataCount returns how many times GetUserData was called
service/matching/matching_engine_test.go:5530
↓ 6 callers
Method
getHistory
( env *testcore.TestEnv, token []byte, isLongPoll bool, eventFilter enumspb.HistoryEventFilterType, )
tests/gethistory_test.go:728
↓ 6 callers
Method
getHistoryReverse
(env *testcore.TestEnv, execution *commonpb.WorkflowExecution, pageSize int32)
tests/gethistory_test.go:635
↓ 6 callers
Function
getNextBackoffRange
(duration time.Duration)
common/backoff/retrypolicy_test.go:342
↓ 6 callers
Method
getOrCreateClientConn
(addr rpcAddress)
client/history/connections.go:41
↓ 6 callers
Method
getPerTypeUserData
()
service/matching/task_queue_partition_manager.go:2441
↓ 6 callers
Method
getPollerInfo
(earliestAccessTime time.Time)
service/matching/poller_history.go:49
↓ 6 callers
Method
getRecorder
getRecorder returns the HistoryTaskRecorder for the specified cluster index. Returns nil if the cluster doesn't have a recorder.
tests/xdc/stream_based_replication_test.go:149
↓ 6 callers
Method
getTaskBatch
Returns a batch of tasks from persistence starting form current read level. Also return a number that can be used to update readLevel Also return a bo
service/matching/task_reader.go:220
↓ 6 callers
Function
getUpdatedInfo
(subStateMachine map[K]V, versionedTransition *persistencespb.VersionedTransition)
service/history/replication/sync_state_retriever.go:560
↓ 6 callers
Method
goContext
()
chasm/context.go:68
↓ 6 callers
Method
handleErr
(err error)
service/matching/forwarder.go:344
↓ 6 callers
Method
handleWriteError
( requestRangeID int64, err error, )
service/history/shard/context_impl.go:1378
↓ 6 callers
Method
historyArchived
(ctx context.Context, request *workflowservice.GetWorkflowExecutionHistoryRequest, namespaceID namespace.ID)
service/frontend/workflow_handler.go:6451
↓ 6 callers
Method
httpGet
(env *testcore.TestEnv, expectedStatus int, url, contentType string)
tests/http_api_test.go:374
↓ 6 callers
Function
i
(r *rpc.RPCFactory)
common/rpc/test/rpc_localstore_tls_test.go:449
↓ 6 callers
Function
indent
(b *strings.Builder, depth int)
common/testing/protoassert/pretty_print.go:120
↓ 6 callers
Method
isCloseTransferTaskAcked
( closeTransferTask *tasks.CloseExecutionTask, )
service/history/replication/raw_task_converter.go:894
↓ 6 callers
Function
isFinalRetry
isFinalRetry returns true if the test name has the "(final)" suffix, indicating the test runner exhausted all retries.
tools/flakereport/parser.go:317
↓ 6 callers
Function
isReplicationMethod
(method string)
tests/testcore/replication_stream_recorder.go:324
↓ 6 callers
Function
isRetryableError
(err error)
common/archiver/s3store/history_archiver.go:384
↓ 6 callers
Method
isStopped
()
common/tasks/fifo_scheduler.go:229
↓ 6 callers
Function
isSuccess
(item *elastic.BulkResponseItem)
common/persistence/visibility/store/elasticsearch/processor.go:364
↓ 6 callers
Function
isWorkflowTaskValid
( workflowLease api.WorkflowLease, scheduledEventID int64, stamp int32, )
service/history/api/isworkflowtaskvalid/api.go:49
↓ 6 callers
Method
loadAndSubmitTasks
()
service/history/queues/reader.go:426
↓ 6 callers
Function
makeDeleteKeyInMapQry
(tableName string, mapKeyName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:113
↓ 6 callers
Function
makeDeleteKeyInMapQry
(tableName string, mapKeyName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:80
↓ 6 callers
Function
makeDeleteKeyInMapQry
(tableName string, mapKeyName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:79
↓ 6 callers
Function
makeDeleteMapQry
(tableName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:96
↓ 6 callers
Function
makeDeleteMapQry
(tableName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:63
↓ 6 callers
Function
makeDeleteMapQry
(tableName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:62
↓ 6 callers
Function
makeGetMapQryTemplate
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:119
↓ 6 callers
Function
makeGetMapQryTemplate
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:86
↓ 6 callers
Function
makeGetMapQryTemplate
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:85
↓ 6 callers
Method
makeSet
makeSet returns an otel attribute.Set with the given tags merged with the otelMetricsHandler's tags.
common/metrics/otel_metrics_handler.go:218
↓ 6 callers
Function
makeSetKeyInMapQry
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:100
↓ 6 callers
Function
makeSetKeyInMapQry
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:67
↓ 6 callers
Function
makeSetKeyInMapQry
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:66
↓ 6 callers
Function
marshalTimestamp
marshalTimestamp marshals a Time instance into string. Uses RFC 3339, where generated output will be Z-normalized and uses 0, 3, 6 or 9 fractional dig
common/nexus/nexusrpc/timestamp.go:17
↓ 6 callers
Method
maybeReadTasksLocked
()
service/matching/fair_task_reader.go:199
↓ 6 callers
Method
metricsHandler
metricsHandler returns a metrics handler enriched with nexus operation tags.
chasm/lib/nexusoperation/operation.go:581
↓ 6 callers
Function
mkNewCommitBuildIdReq
(target string, force bool)
service/matching/version_rule_test.go:87
↓ 6 callers
Function
mkNewDefReq
(id string)
service/matching/version_sets_test.go:44
↓ 6 callers
Function
mkdirAll
(path string, dirMode os.FileMode)
common/archiver/filestore/util.go:53
↓ 6 callers
Function
mustNewMergedSummary
(t *testing.T, reports ...*junitReport)
tools/testrunner/summary_test.go:190
↓ 6 callers
Function
newActivityTaskScheduledEvent
(eventID int64, workflowTaskCompletedEventID int64, scheduleAttributes *commandpb.ScheduleActivityTaskCommand
service/matching/matching_engine_test.go:4659
↓ 6 callers
Function
newApplicationFailure
(err error, nonRetryable bool, details *commonpb.Payloads)
tests/testcore/taskpoller.go:527
↓ 6 callers
Function
newBusinessKey
(key chasm.ExecutionKey)
chasm/chasmtest/test_engine.go:655
↓ 6 callers
Method
newCachingDirector
(staleTTL time.Duration)
client/history/caching_redirector_test.go:55
↓ 6 callers
Function
newConflictRecord
ScyllaDB will return rows with null values to match # of queries in a batch query (see #2683). To support null values, fields type should be a pointer
common/persistence/cassandra/errors.go:41
↓ 6 callers
Function
newContext
(opts *options)
common/testing/taskpoller/taskpoller.go:675
↓ 6 callers
Function
newEncoder
(writer io.Writer)
tools/tdbg/dlq_v2_service.go:123
↓ 6 callers
Function
newFieldInternalWithValue
(ft fieldType, v any)
chasm/field_internal.go:17
↓ 6 callers
Function
newFieldNotFoundError
(fieldName string, payload map[string]any)
common/persistence/cassandra/common.go:18
↓ 6 callers
Function
newInternalStartedTask
(info *startedTaskInfo)
service/matching/task.go:223
↓ 6 callers
Function
newLinkValidator
( maxLinksPerRequest dynamicconfig.IntPropertyFnWithNamespaceFilter, maxLinksPerComponent dynamicconfig.IntP
chasm/lib/activity/link_validator.go:19
↓ 6 callers
Function
newOptions
( tv *testvars.TestVars, opts []optionFunc, )
common/testing/taskpoller/taskpoller.go:658
↓ 6 callers
Method
newPartitionManager
(prtn tqid.Partition, config *Config)
service/matching/matching_engine_test.go:275
↓ 6 callers
Function
newSearchAttributeKeywordListByField
(field string)
chasm/search_attribute.go:413
↓ 6 callers
Function
newSearchAttributesMapFromProto
newSearchAttributesMapFromProto creates a new SearchAttributesMap from commonpb.SearchAttributes.
chasm/search_attribute.go:482
← previous
next →
3,901–4,000 of 43,335, ranked by callers