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
↓ 11 callers
Function
WithGlobalFlag
WithGlobalFlag sets whether or not this Namespace is global.
common/namespace/mutate.go:45
↓ 11 callers
Function
WorkerDeploymentVersionToStringV32
(v *deploymentspb.WorkerDeploymentVersion)
common/worker_versioning/worker_versioning.go:1155
↓ 11 callers
Function
WorkflowInitiatedID
WorkflowInitiatedID returns tag for WorkflowInitiatedID
common/log/tag/tags.go:226
↓ 11 callers
Method
assertChanState
(expectedClosed bool, chans ...<-chan struct{})
service/history/workflow/query_registry_test.go:217
↓ 11 callers
Method
assertClosedExecutionEquals
( req *manager.RecordWorkflowExecutionClosedRequest, resp *workflowpb.WorkflowExecutionInfo)
common/persistence/tests/visibility_persistence_suite.go:1138
↓ 11 callers
Method
checkIfPayloadSizeExceedsLimit
( commandTypeTag metrics.Tag, payloadSize int, message string, )
service/history/api/respondworkflowtaskcompleted/workflow_size_checker.go:54
↓ 11 callers
Function
convertToExecutionInfo
(record *archiverspb.VisibilityRecord, saTypeMap searchattribute.NameTypeMap)
common/archiver/s3store/util.go:252
↓ 11 callers
Function
createAssignmentRuleWithoutRamp
(buildId string)
service/matching/version_rule_helper_test.go:87
↓ 11 callers
Function
deleteMessages
( ctx context.Context, q persistence.QueueV2, queueType persistence.QueueV2Type, queueName string, maxID
common/persistence/tests/cassandra_test.go:1239
↓ 11 callers
Function
describeResp
(paused bool, overlap enumspb.ScheduleOverlapPolicy, runningCount int)
service/worker/scanner/scheduleinvariants/invariants_test.go:223
↓ 11 callers
Method
dispatchForExistingWorkflow
( ctx context.Context, isWorkflowRebuilt bool, archetypeID chasm.ArchetypeID, targetWorkflow Workf
service/history/ndc/transaction_manager_existing_workflow.go:18
↓ 11 callers
Function
extractWorkflowConflictError
( conflictRecord map[string]any, requestRunID string, requestDBVersion int64, requestNextEventID int64, //
common/persistence/cassandra/errors.go:237
↓ 11 callers
Function
file_temporal_server_api_persistence_v1_chasm_proto_rawDescGZIP
()
api/persistence/v1/chasm.pb.go:999
↓ 11 callers
Function
file_temporal_server_api_persistence_v1_task_queues_proto_rawDescGZIP
()
api/persistence/v1/task_queues.pb.go:831
↓ 11 callers
Function
file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_rawDescGZIP
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:1016
↓ 11 callers
Method
findNode
( path []string, )
chasm/tree.go:2707
↓ 11 callers
Function
formatComparisonExprStringForError
formatComparisonExprStringForError formats comparison expression after custom search attribute was mapped to field name to show alias name for better
common/persistence/visibility/store/sql/query_converter_util_legacy.go:115
↓ 11 callers
Method
fqType
fqType returns the fully qualified name of the task, which is a combination of the library name and the task type. This is used to uniquely identify t
chasm/registrable_task.go:180
↓ 11 callers
Function
generateEventHistory
Pattern contains either c or f representing completed or failed task. Schedule events for each task has id of NumTotalEvents*i + 1 where i is the inde
service/worker/batcher/activities_test.go:100
↓ 11 callers
Method
getActivityHeartbeatTimeout
( activityInfo *persistencespb.ActivityInfo, )
service/history/workflow/timer_sequence.go:323
↓ 11 callers
Method
getActivityScheduleToStartTimeout
( activityInfo *persistencespb.ActivityInfo, )
service/history/workflow/timer_sequence.go:231
↓ 11 callers
Method
getDLQTypeFromQueueType
()
common/persistence/sql/queue.go:311
↓ 11 callers
Function
info
(format string, args ...any)
cmd/tools/protogen/main.go:20
↓ 11 callers
Method
initMockExecutionManager
(batchInfo []int, returnErrorOnPage int, addNotExistCall bool, pages ...page)
common/archiver/history_iterator_test.go:592
↓ 11 callers
Method
isStarted
isStarted is true when this task is already marked as started
service/matching/task.go:246
↓ 11 callers
Function
isSupportedComparisonOperator
(operator string)
common/persistence/visibility/store/sql/query_converter_legacy.go:663
↓ 11 callers
Function
makeStartRequest
( requestID, workflowID, identity, workflowType string, namespaceEntry *namespace.Namespace, memo *commonpb
service/worker/workerdeployment/util.go:417
↓ 11 callers
Function
mergeActivityOptions
( mergeInto *activitypb.ActivityOptions, mergeFrom *activitypb.ActivityOptions, updateFields map[string]str
service/history/api/updateactivityoptions/api.go:210
↓ 11 callers
Method
newBacklogTask
(id int64, age time.Duration, f func(*internalTask, taskResponse))
service/matching/matcher_data_test.go:119
↓ 11 callers
Function
newFinalizer
(mh metrics.Handler)
common/finalizer/finalizer_test.go:154
↓ 11 callers
Method
newImpl
(pollWaitForToken bool)
common/rpc/interceptor/namespace_rate_limit_test.go:45
↓ 11 callers
Function
newInvokerExecuteTestEnv
(t *testing.T)
chasm/lib/scheduler/invoker_execute_task_test.go:32
↓ 11 callers
Method
newRandomShardRow
( shardID int32, rangeID int64, )
common/persistence/sql/sqlplugin/tests/history_shard.go:206
↓ 11 callers
Function
newRegistry
(t *testing.T)
components/nexusoperations/helpers_test.go:38
↓ 11 callers
Method
newRespondActivityTaskFailedRequest
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:417
↓ 11 callers
Function
newTestDeps
(t *testing.T)
service/worker/scanner/scheduleinvariants/invariants_test.go:42
↓ 11 callers
Function
newUseCase
(uconfig UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:384
↓ 11 callers
Function
newVisibilityArchiver
(logger log.Logger, metricsHandler metrics.Handler, storage connector.Client)
common/archiver/gcloud/visibility_archiver.go:53
↓ 11 callers
Function
newWorkerQueryEngine
* FilterWorkers filters the list of per-namespace worker heartbeats against the provided query. The query should be a valid SQL query without WHERE cl
service/matching/workers/worker_query_engine.go:84
↓ 11 callers
Function
nextBackoffInterval
( now time.Time, currentAttempt int32, maxAttempts int32, initInterval *durationpb.Duration, maxInterval
service/history/workflow/retry.go:70
↓ 11 callers
Function
overrideWorkflowTaskTimeout
overrideWorkflowTaskTimeout override the workflow task timeout according to default timeout or max timeout
service/history/api/create_workflow_util.go:376
↓ 11 callers
Method
pollWithIdentity
UpdatePollerData is a no-op if the poller context has no identity, so we need a context with identity for any tests that check poller info
service/matching/task_queue_partition_manager_test.go:1288
↓ 11 callers
Method
processTimer
( ctx context.Context, timerTask tasks.Task, actionFn standbyActionFn, postActionFn standbyPostActionFn, )
service/history/timer_queue_standby_task_executor.go:720
↓ 11 callers
Method
read
persistence helper
common/persistence/persistence-tests/history_v2_persistence.go:735
↓ 11 callers
Method
release
()
service/matching/forwarder.go:359
↓ 11 callers
Function
replaceRedirectRule
(rule *taskqueuepb.CompatibleBuildIdRedirectRule, data *persistencespb.VersioningData, clock *hlc.Clock, ma
service/matching/version_rule_test.go:145
↓ 11 callers
Function
respondSuccess
(t *testing.T, store mockEventStore, upd *update.Update)
service/history/workflow/update/update_test.go:1115
↓ 11 callers
Method
serializeEvents
(events []*historypb.HistoryEvent)
tests/ndc/replication_migration_back_test.go:374
↓ 11 callers
Method
setFailureSource
(source string)
service/frontend/nexus_handler.go:829
↓ 11 callers
Function
setupSentinelForTest
(t *testing.T)
chasm/lib/scheduler/helper_test.go:419
↓ 11 callers
Method
setupStubs
(uc UsecaseConfig)
service/history/api/respondactivitytaskfailed/api_test.go:404
↓ 11 callers
Method
signalIfFatal
signalIfFatal calls UnloadFromPartitionManager of the physicalTaskQueueManager if and only if the supplied error represents a fatal condition, e.g. th
service/matching/backlog_manager.go:114
↓ 11 callers
Method
startWorkflow
( env *testcore.TestEnv, tv *testvars.TestVars, override *workflowpb.VersioningOverride, )
tests/worker_deployment_version_test.go:1810
↓ 11 callers
Function
testComponentSerializedNodes
returns serialized version of TestComponent from above. Generated by generateMapInit function below.
chasm/test_component_test.go:211
↓ 11 callers
Function
testWorkerCommandsTask
()
service/history/worker_commands_task_dispatcher_test.go:25
↓ 11 callers
Method
track
( taskMaps ...map[tasks.Category][]tasks.Task, )
service/history/shard/task_request_tracker.go:36
↓ 11 callers
Method
verifyOverrides
( expectedBehavior, expectedBehaviorOverride enumspb.VersioningBehavior, expectedDeployment, expectedDeploym
service/history/workflow/mutable_state_impl_test.go:1184
↓ 10 callers
Method
AddActivityTaskCancelRequestedEvent
(int64, int64, string)
service/history/interfaces/mutable_state.go:50
↓ 10 callers
Method
AddChildWorkflowExecutionStartedEvent
(*commonpb.WorkflowExecution, *commonpb.WorkflowType, int64, *commonpb.Header, *clockspb.VectorClock)
service/history/interfaces/mutable_state.go:71
↓ 10 callers
Method
AddTasks
(...tasks.Task)
chasm/tree.go:215
↓ 10 callers
Method
AddTimeoutWorkflowEvent
(enumspb.RetryState, string)
service/history/interfaces/mutable_state.go:95
↓ 10 callers
Method
AddTimerFiredEvent
(string)
service/history/interfaces/mutable_state.go:97
↓ 10 callers
Method
AssertHEPrefixWithDB
(branchToken []byte, events ...[]*p.WorkflowEvents)
common/persistence/tests/execution_mutable_state.go:2700
↓ 10 callers
Method
Assign
(Executable)
service/history/queues/priority_assigner.go:12
↓ 10 callers
Method
BeginTx
(ctx context.Context)
common/persistence/sql/sqlplugin/interfaces.go:104
↓ 10 callers
Method
CanMergeByRange
( incomingScope Scope, )
service/history/queues/scope.go:63
↓ 10 callers
Method
CanMergeWithSlice
(Slice)
service/history/queues/slice.go:30
↓ 10 callers
Method
CanSplit
(tasks.Key)
service/history/queues/iterator.go:15
↓ 10 callers
Method
CanSplitByRange
(tasks.Key)
service/history/queues/slice.go:27
↓ 10 callers
Method
Cancel
Cancel invokes the buffered rollback functions in the reverse of the order that they were added to this Buffer. It returns true if any effects were ca
common/effect/buffer.go:43
↓ 10 callers
Method
CancelOutstandingWorkerPolls
(ctx context.Context, request *matchingservice.CancelOutstandingWorkerPollsRequest)
service/matching/matching_engine_interfaces.go:22
↓ 10 callers
Function
ChasmRunID
ChasmRunID returns tag for an entity run ID
common/log/tag/tags.go:926
↓ 10 callers
Method
ClearStickyTaskQueue
()
service/history/workflow/mutable_state_impl.go:1444
↓ 10 callers
Method
Close
()
common/archiver/gcloud/connector/client_delegate.go:54
↓ 10 callers
Method
ContainsHistoryEvents
ContainsHistoryEvents checks if expectedHistorySegment is contained in actualHistoryEvents. actualHistoryEvents are sanitized based on the first event
common/testing/historyrequire/history_require.go:130
↓ 10 callers
Function
ConvertGradualChange
ConvertGradualChange is a conversion function that can handle a plain T (which represents a static value) as well as a GradualChange[T]. It can be use
common/dynamicconfig/gradual_change.go:58
↓ 10 callers
Function
CopyVersionHistoryItem
CopyVersionHistoryItem create a new instance of VersionHistoryItem.
common/persistence/versionhistory/version_history_item.go:19
↓ 10 callers
Method
CountChasmExecutions
(ctx context.Context, request *visibilityservice.CountChasmExecutionsRequest)
common/persistence/visibility/store/visibility_store.go:41
↓ 10 callers
Method
CreateQueue
( ctx context.Context, request *persistence.CreateQueueRequest, )
service/history/queues/dlq_writer.go:30
↓ 10 callers
Function
Decode
Decode decodes search attributes to the map of search attribute values using (in order): 1. type from typeMap, 2. if typeMap is nil, type from Metadat
common/searchattribute/encode.go:55
↓ 10 callers
Method
DeepHealthCheck
(ctx context.Context, in *DeepHealthCheckRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:156
↓ 10 callers
Method
DeleteMessagesBefore
(ctx context.Context, messageID int64)
common/persistence/persistence_interface.go:175
↓ 10 callers
Function
Deployment
(d string)
common/log/tag/tags.go:1000
↓ 10 callers
Function
DeploymentFromDeploymentVersion
DeploymentFromDeploymentVersion Temporary helper function to convert WorkerDeploymentVersion to Deployment proto until we update code to use the new p
common/worker_versioning/worker_versioning.go:522
↓ 10 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/membership/interfaces_mock.go:41
↓ 10 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/s3store/query_parser_mock.go:38
↓ 10 callers
Function
ExternalWorkerDeploymentVersionFromVersion
ExternalWorkerDeploymentVersionFromVersion Temporary helper function to convert internal Worker Deployment to WorkerDeploymentVersion proto until we u
common/worker_versioning/worker_versioning.go:498
↓ 10 callers
Function
FindBuildId
FindBuildId finds a build ID in the version data's sets, returning (set index, index within that set). Returns -1, -1 if not found.
common/worker_versioning/worker_versioning.go:138
↓ 10 callers
Method
ForwardTask
(background context.Context, task *internalTask)
service/matching/forwarder_test.go:37
↓ 10 callers
Method
FromPayload
(payload *commonpb.Payload, valuePtr any)
tests/testcore/test_data_converter.go:69
↓ 10 callers
Method
Get
(k string)
common/metrics/baggage_bench_test.go:28
↓ 10 callers
Method
GetActivityOptions
()
api/historyservice/v1/request_response.pb.go:9512
↓ 10 callers
Function
GetActivityState
(ai *persistencespb.ActivityInfo)
service/history/workflow/activity.go:53
↓ 10 callers
Method
GetAttempt
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/tasks.pb.go:170
↓ 10 callers
Method
GetCategories
()
service/history/tasks/task_category_registry.go:12
↓ 10 callers
Method
GetCompletionState
()
service/history/workflow/query.go:30
↓ 10 callers
Method
GetCreateRequestId
()
api/persistence/v1/executions.pb.go:3439
↓ 10 callers
Method
GetDefaultClient
GetDefaultClient returns the default Temporal client configured for making requests to the server. It is configured to use a pre-registered test name
temporaltest/server.go:68
↓ 10 callers
Method
GetError
GetError returns a gRPC INVALID_ARGUMENT error representing the issues in the set or nil if there are no issues.
common/rpc/request_issues.go:27
↓ 10 callers
Method
GetExecutionState
TODO: Add methods needed from MutateState here.
chasm/tree.go:207
← previous
next →
2,301–2,400 of 43,335, ranked by callers