MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 6 callersFunctioncheckWorkflowState
(state enumsspb.WorkflowExecutionState)
common/persistence/operation_mode_validator.go:292
↓ 6 callersMethodclear
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 callersMethodcompareVersionHistory
( mutableState historyi.MutableState, incomingVersionHistory *historyspb.VersionHistory, )
service/history/ndc/hsm_state_replicator.go:218
↓ 6 callersMethodconn
()
common/persistence/sql/sqlplugin/postgresql/db.go:66
↓ 6 callersMethodconn
()
common/persistence/sql/sqlplugin/mysql/db.go:78
↓ 6 callersFunctionconstructHistoryFilename
File name construction
common/archiver/filestore/util.go:163
↓ 6 callersFunctioncontextNearDeadline
(ctx context.Context, tailroom time.Duration)
service/frontend/workflow_handler.go:1186
↓ 6 callersFunctionconvertActivityStateReplicationTask
( ctx context.Context, shardContext historyi.ShardContext, taskInfo *tasks.SyncActivityTask, workflowCache
service/history/replication/raw_task_converter.go:118
↓ 6 callersFunctionconvertClusterReplicationConfigToProto
( input []string, )
common/namespace/nsreplication/transmission_task_handler.go:124
↓ 6 callersMethodconvertColName
(exprRef *sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter_legacy.go:436
↓ 6 callersFunctionconvertCommonErrors
( operation string, err error, )
common/persistence/sql/common.go:128
↓ 6 callersMethodconvertError
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 callersMethodcopyIteratorState
(itr *historyIterator)
common/archiver/history_iterator_test.go:630
↓ 6 callersMethodcreateBatchResetWorkflow
(env *testcore.TestEnv, workflowFn WorkflowFunction)
tests/activity_api_batch_reset_test.go:42
↓ 6 callersMethodcreateFile
(dir string, filename string)
common/archiver/filestore/util_test.go:408
↓ 6 callersMethodcreateWorkflow
(env *testcore.TestEnv, workflowFn any)
tests/admin_batch_refresh_workflow_tasks_test.go:49
↓ 6 callersMethoddeleteAssignmentRule
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 callersMethoddeleteInternal
(element *list.Element)
common/cache/lru.go:380
↓ 6 callersMethoddescribeNamespace
( t require.TestingT, testCluster *testcore.TestCluster, ns string, isGlobal bool, )
tests/xdc/base.go:418
↓ 6 callersMethoddescribeStatsEventually
( buildIds map[string]bool, includeAllActive, reportPollers, internalTaskQueueStatus bool, check func(resp
service/matching/task_queue_partition_manager_test.go:1326
↓ 6 callersFunctiondetailedErrorMessage
(err error)
common/persistence/visibility/store/elasticsearch/visibility_store.go:1306
↓ 6 callersFunctiondirectoryExists
(path string)
common/archiver/filestore/util.go:41
↓ 6 callersFunctiondrainAndCalc
(sim *simulator)
tools/fairsim/sim_test.go:48
↓ 6 callersMethoddrivePollsUntilClosed
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 callersMethodemitDispatchLatency
(task *internalTask, forwarded bool)
service/matching/matcher.go:375
↓ 6 callersFunctionemitStateTransitionCount
( metricsHandler metrics.Handler, clusterMetadata cluster.Metadata, mutableState historyi.MutableState, )
service/history/workflow/context.go:1216
↓ 6 callersFunctionensureContextTimeout
(ctx context.Context)
common/archiver/s3store/util.go:181
↓ 6 callersMethodensureNotDeleted
()
service/worker/workerdeployment/workflow.go:457
↓ 6 callersMethodevaluateSingleStreamConnection
(key *ClusterShardKeyPair, current *streamStatus, previous *streamStatus)
service/history/replication/stream_receiver_monitor.go:339
↓ 6 callersFunctionexecuteNexusCompletion
(t *testing.T, tc nexusCompletionTestCase)
chasm/lib/scheduler/scheduler_nexus_completion_test.go:31
↓ 6 callersFunctionextractCurrentWorkflowConflictError
( conflictRecord map[string]any, currentRecordRunID string, requestCurrentRunID string, )
common/persistence/cassandra/errors.go:190
↓ 6 callersFunctionfairLevelFromProto
(l *taskqueuespb.FairLevel)
service/matching/fair_level.go:57
↓ 6 callersMethodfetchAndEmitLogicalBacklogMetrics
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 callersFunctionfile_temporal_server_api_cli_v1_message_proto_rawDescGZIP
()
api/cli/v1/message.pb.go:668
↓ 6 callersFunctionfile_temporal_server_api_persistence_v1_nexus_proto_rawDescGZIP
()
api/persistence/v1/nexus.pb.go:448
↓ 6 callersMethodfindTransitionedEvents
(history []*historypb.HistoryEvent)
tests/timeskipping_fast_forward_test.go:54
↓ 6 callersFunctionformatDuration
formatDuration formats a duration in human-readable form
tools/ci-notify/github.go:141
↓ 6 callersMethodgenerateRSAToken
(subject string, permissions []string, options errorTestOptions)
common/authorization/default_jwt_claim_mapper_test.go:369
↓ 6 callersMethodgenerateStartedEventRefLink
(runID string)
service/history/api/startworkflow/api.go:818
↓ 6 callersMethodgetBuildIdsOfInterest
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 callersMethodgetGetUserDataCount
getGetUserDataCount returns how many times GetUserData was called
service/matching/matching_engine_test.go:5530
↓ 6 callersMethodgetHistory
( env *testcore.TestEnv, token []byte, isLongPoll bool, eventFilter enumspb.HistoryEventFilterType, )
tests/gethistory_test.go:728
↓ 6 callersMethodgetHistoryReverse
(env *testcore.TestEnv, execution *commonpb.WorkflowExecution, pageSize int32)
tests/gethistory_test.go:635
↓ 6 callersFunctiongetNextBackoffRange
(duration time.Duration)
common/backoff/retrypolicy_test.go:342
↓ 6 callersMethodgetOrCreateClientConn
(addr rpcAddress)
client/history/connections.go:41
↓ 6 callersMethodgetPerTypeUserData
()
service/matching/task_queue_partition_manager.go:2441
↓ 6 callersMethodgetPollerInfo
(earliestAccessTime time.Time)
service/matching/poller_history.go:49
↓ 6 callersMethodgetRecorder
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 callersMethodgetTaskBatch
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 callersFunctiongetUpdatedInfo
(subStateMachine map[K]V, versionedTransition *persistencespb.VersionedTransition)
service/history/replication/sync_state_retriever.go:560
↓ 6 callersMethodgoContext
()
chasm/context.go:68
↓ 6 callersMethodhandleErr
(err error)
service/matching/forwarder.go:344
↓ 6 callersMethodhandleWriteError
( requestRangeID int64, err error, )
service/history/shard/context_impl.go:1378
↓ 6 callersMethodhistoryArchived
(ctx context.Context, request *workflowservice.GetWorkflowExecutionHistoryRequest, namespaceID namespace.ID)
service/frontend/workflow_handler.go:6451
↓ 6 callersMethodhttpGet
(env *testcore.TestEnv, expectedStatus int, url, contentType string)
tests/http_api_test.go:374
↓ 6 callersFunctioni
(r *rpc.RPCFactory)
common/rpc/test/rpc_localstore_tls_test.go:449
↓ 6 callersFunctionindent
(b *strings.Builder, depth int)
common/testing/protoassert/pretty_print.go:120
↓ 6 callersMethodisCloseTransferTaskAcked
( closeTransferTask *tasks.CloseExecutionTask, )
service/history/replication/raw_task_converter.go:894
↓ 6 callersFunctionisFinalRetry
isFinalRetry returns true if the test name has the "(final)" suffix, indicating the test runner exhausted all retries.
tools/flakereport/parser.go:317
↓ 6 callersFunctionisReplicationMethod
(method string)
tests/testcore/replication_stream_recorder.go:324
↓ 6 callersFunctionisRetryableError
(err error)
common/archiver/s3store/history_archiver.go:384
↓ 6 callersMethodisStopped
()
common/tasks/fifo_scheduler.go:229
↓ 6 callersFunctionisSuccess
(item *elastic.BulkResponseItem)
common/persistence/visibility/store/elasticsearch/processor.go:364
↓ 6 callersFunctionisWorkflowTaskValid
( workflowLease api.WorkflowLease, scheduledEventID int64, stamp int32, )
service/history/api/isworkflowtaskvalid/api.go:49
↓ 6 callersMethodloadAndSubmitTasks
()
service/history/queues/reader.go:426
↓ 6 callersFunctionmakeDeleteKeyInMapQry
(tableName string, mapKeyName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:113
↓ 6 callersFunctionmakeDeleteKeyInMapQry
(tableName string, mapKeyName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:80
↓ 6 callersFunctionmakeDeleteKeyInMapQry
(tableName string, mapKeyName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:79
↓ 6 callersFunctionmakeDeleteMapQry
(tableName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:96
↓ 6 callersFunctionmakeDeleteMapQry
(tableName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:63
↓ 6 callersFunctionmakeDeleteMapQry
(tableName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:62
↓ 6 callersFunctionmakeGetMapQryTemplate
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:119
↓ 6 callersFunctionmakeGetMapQryTemplate
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:86
↓ 6 callersFunctionmakeGetMapQryTemplate
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:85
↓ 6 callersMethodmakeSet
makeSet returns an otel attribute.Set with the given tags merged with the otelMetricsHandler's tags.
common/metrics/otel_metrics_handler.go:218
↓ 6 callersFunctionmakeSetKeyInMapQry
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/postgresql/execution_maps.go:100
↓ 6 callersFunctionmakeSetKeyInMapQry
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/mysql/execution_maps.go:67
↓ 6 callersFunctionmakeSetKeyInMapQry
(tableName string, nonPrimaryKeyColumns []string, mapKeyName string)
common/persistence/sql/sqlplugin/sqlite/execution_maps.go:66
↓ 6 callersFunctionmarshalTimestamp
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 callersMethodmaybeReadTasksLocked
()
service/matching/fair_task_reader.go:199
↓ 6 callersMethodmetricsHandler
metricsHandler returns a metrics handler enriched with nexus operation tags.
chasm/lib/nexusoperation/operation.go:581
↓ 6 callersFunctionmkNewCommitBuildIdReq
(target string, force bool)
service/matching/version_rule_test.go:87
↓ 6 callersFunctionmkNewDefReq
(id string)
service/matching/version_sets_test.go:44
↓ 6 callersFunctionmkdirAll
(path string, dirMode os.FileMode)
common/archiver/filestore/util.go:53
↓ 6 callersFunctionmustNewMergedSummary
(t *testing.T, reports ...*junitReport)
tools/testrunner/summary_test.go:190
↓ 6 callersFunctionnewActivityTaskScheduledEvent
(eventID int64, workflowTaskCompletedEventID int64, scheduleAttributes *commandpb.ScheduleActivityTaskCommand
service/matching/matching_engine_test.go:4659
↓ 6 callersFunctionnewApplicationFailure
(err error, nonRetryable bool, details *commonpb.Payloads)
tests/testcore/taskpoller.go:527
↓ 6 callersFunctionnewBusinessKey
(key chasm.ExecutionKey)
chasm/chasmtest/test_engine.go:655
↓ 6 callersMethodnewCachingDirector
(staleTTL time.Duration)
client/history/caching_redirector_test.go:55
↓ 6 callersFunctionnewConflictRecord
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 callersFunctionnewContext
(opts *options)
common/testing/taskpoller/taskpoller.go:675
↓ 6 callersFunctionnewEncoder
(writer io.Writer)
tools/tdbg/dlq_v2_service.go:123
↓ 6 callersFunctionnewFieldInternalWithValue
(ft fieldType, v any)
chasm/field_internal.go:17
↓ 6 callersFunctionnewFieldNotFoundError
(fieldName string, payload map[string]any)
common/persistence/cassandra/common.go:18
↓ 6 callersFunctionnewInternalStartedTask
(info *startedTaskInfo)
service/matching/task.go:223
↓ 6 callersFunctionnewLinkValidator
( maxLinksPerRequest dynamicconfig.IntPropertyFnWithNamespaceFilter, maxLinksPerComponent dynamicconfig.IntP
chasm/lib/activity/link_validator.go:19
↓ 6 callersFunctionnewOptions
( tv *testvars.TestVars, opts []optionFunc, )
common/testing/taskpoller/taskpoller.go:658
↓ 6 callersMethodnewPartitionManager
(prtn tqid.Partition, config *Config)
service/matching/matching_engine_test.go:275
↓ 6 callersFunctionnewSearchAttributeKeywordListByField
(field string)
chasm/search_attribute.go:413
↓ 6 callersFunctionnewSearchAttributesMapFromProto
newSearchAttributesMapFromProto creates a new SearchAttributesMap from commonpb.SearchAttributes.
chasm/search_attribute.go:482
← previousnext →3,901–4,000 of 43,335, ranked by callers