MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 12 callersFunctionNewNamespaceFloatSetting
(key string, def float64, description string)
common/dynamicconfig/setting_gen.go:317
↓ 12 callersFunctionNewNexusServiceProcessor
NewNexusServiceProcessor constructs a processor for a single Nexus service that can register and invoke operation processors by name.
chasm/nexus_operation_processor.go:122
↓ 12 callersFunctionNewOutboundTaskGroupPredicate
( groups []string, )
service/history/tasks/predicates.go:111
↓ 12 callersFunctionNewPipe
NewPipe returns a Pipe.
common/testing/nettest/pipe.go:29
↓ 12 callersFunctionNewUnknownEncodingTypeError
NewUnknownEncodingTypeError returns a new instance of encoding type error
common/persistence/serialization/serializer.go:302
↓ 12 callersFunctionOperationPossiblySucceeded
(err error)
common/persistence/error_type.go:5
↓ 12 callersMethodPaginateTasks
( category tasks.Category, inclusiveMinTaskKey tasks.Key, exclusiveMaxTaskKey tasks.Key, batchSize int, )
common/persistence/tests/execution_mutable_state_task.go:570
↓ 12 callersMethodPossible
Possible returns a boolean indicating whether the transition is possible for the current state.
chasm/statemachine.go:45
↓ 12 callersMethodReadComponent
( context.Context, ComponentRef, func(Context, Component) error, ...TransitionOption, )
chasm/engine.go:37
↓ 12 callersMethodRecordChildExecutionCompleted
(ctx context.Context, request *historyservice.RecordChildExecutionCompletedRequest)
service/history/interfaces/engine.go:55
↓ 12 callersMethodRegenerateTimerTasksForTimeSkipping
time skipping tasks
service/history/workflow/task_generator.go:84
↓ 12 callersMethodReplicateEventsV2
(ctx context.Context, request *historyservice.ReplicateEventsV2Request)
service/history/interfaces/engine.go:66
↓ 12 callersMethodReplicateWorkflowState
(ctx context.Context, request *historyservice.ReplicateWorkflowStateRequest)
service/history/interfaces/engine.go:67
↓ 12 callersMethodRequestCancelNexusOperationExecution
(context.Context, *workflowservice.RequestCancelNexusOperationExecutionRequest)
chasm/lib/nexusoperation/frontend.go:29
↓ 12 callersMethodSetSlicePendingTaskCount
(slice Slice, count int)
service/history/queues/monitor.go:27
↓ 12 callersMethodSignalVersionReactivation
SignalVersionReactivation sends a reactivation signal to a version workflow. Used when workflows are pinned to a potentially DRAINED/INACTIVE version.
service/worker/workerdeployment/client.go:213
↓ 12 callersMethodStart
()
service/history/shard/controller.go:21
↓ 12 callersMethodSyncActivity
(ctx context.Context, request *historyservice.SyncActivityRequest)
service/history/interfaces/engine.go:70
↓ 12 callersMethodSyncState
( ctx context.Context, syncStateErr *serviceerrors.SyncState, remainingAttempt int, )
service/history/replication/executable_task.go:85
↓ 12 callersMethodTryAcquire
(priority Priority, n int)
common/locks/priority_semaphore.go:8
↓ 12 callersMethodUnmarshal
Unmarshal an object of type FairLevel from the protobuf v3 wire format
api/taskqueue/v1/message.go-helpers.pb.go:51
↓ 12 callersMethodUnmarshal
Unmarshal an object of type BufferedStart from the protobuf v3 wire format
api/schedule/v1/message.go-helpers.pb.go:14
↓ 12 callersMethodUpdateUserData
UpdateUserData updates user data for this task queue and replicates across clusters if necessary. Extra care should be taken to avoid mutating the exi
service/matching/user_data_manager.go:59
↓ 12 callersMethodUpdateWorkflowTask
UpdateWorkflowTask updates a workflow task.
service/history/workflow/workflow_task_state_machine.go:1129
↓ 12 callersMethodValidateCustomSearchAttributes
Validate search attributes based on the store constraints. It returns a new map containing only search attributes with valid values. If there are inva
common/persistence/visibility/store/visibility_store.go:27
↓ 12 callersFunctionValidateUpdateWorkflowStateStatus
ValidateUpdateWorkflowStateStatus validate workflow state and status
common/persistence/workflow_state_status_validator.go:57
↓ 12 callersMethodWithDefault
(v T)
common/dynamicconfig/setting_gen.go:901
↓ 12 callersMethodWithNamespaceIDRedirect
(ctx context.Context, namespaceID namespace.ID, apiName string, req any, call func(string) error)
common/rpc/interceptor/dc_redirection_policy.go:38
↓ 12 callersFunctionassertAborted
(t *testing.T, upd *update.Update, expectedErr error)
service/history/workflow/update/update_test.go:1171
↓ 12 callersFunctionassertContextValue
(chasmContext chasm.Context)
chasm/lib/tests/payload.go:75
↓ 12 callersFunctionassertNotCompletedYet
(t *testing.T, upd *update.Update)
service/history/workflow/update/update_test.go:1150
↓ 12 callersFunctionchasmExec
(id string)
service/worker/scanner/scheduleinvariants/invariants_test.go:160
↓ 12 callersFunctioncompleteCmd
completeCmd builds a CompleteWorkflowExecution command with an empty payload.
tests/timeskipping_propagation_test.go:879
↓ 12 callersMethodconstructCallContext
(clientVersion, clientName, supportedServerVersions, supportedFeatures string)
common/headers/version_checker_test.go:115
↓ 12 callersFunctionfile_temporal_server_api_persistence_v1_predicates_proto_rawDescGZIP
()
api/persistence/v1/predicates.pb.go:782
↓ 12 callersFunctionfile_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_rawDescGZIP
()
chasm/lib/activity/gen/activitypb/v1/request_response.pb.go:616
↓ 12 callersFunctionfile_temporal_server_chasm_lib_nexusoperation_proto_v1_request_response_proto_rawDescGZIP
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/request_response.pb.go:626
↓ 12 callersFunctionfiredTimers
firedTimers returns the set of TimerFired event timer IDs delivered in the WFT batch (events newer than task.PreviousStartedEventId).
tests/timeskipping_propagation_test.go:831
↓ 12 callersMethodgetBuildIds
(env *testcore.TestEnv, execution *commonpb.WorkflowExecution)
tests/advanced_visibility_test.go:2638
↓ 12 callersFunctiongetConfigOrDefault
(config []eventConfig)
service/history/historybuilder/history_builder_categorization_test.go:1609
↓ 12 callersMethodgetExecutionInfoFromCluster
getExecutionInfoFromCluster reads the persisted ExecutionInfo from the given cluster's history service. Use the database (not cache) view to ensure we
tests/xdc/timeskipping_replication_test.go:71
↓ 12 callersMethodgetMutableStateFromCache
( workflowKey definition.WorkflowKey, )
service/history/timer_queue_active_task_executor_test.go:2330
↓ 12 callersMethodgetTaskQueueDeploymentData
getTaskQueueDeploymentData gets the deployment data for a given TQ type. The data is always returned from the WF type root partition, so no need to wa
tests/versioning_3_test.go:4309
↓ 12 callersFunctioninsertAssignmentRule
(rule *taskqueuepb.BuildIdAssignmentRule, data *persistencespb.VersioningData, clock *hlc.Clock, idx int32,
service/matching/version_rule_test.go:118
↓ 12 callersMethodisComponent
()
chasm/tree.go:649
↓ 12 callersFunctionlatestLogicalBacklogCount
latestLogicalBacklogCount returns the most recent approximate_backlog_count recording for the given worker_version and task_priority tag values.
service/matching/task_queue_partition_manager_test.go:624
↓ 12 callersMethodmakeOneTimeOverride
(tv *testvars.TestVars)
tests/versioning_3_test.go:2255
↓ 12 callersMethodnewContext
()
tests/ndc/ndc_test.go:2417
↓ 12 callersMethodnewGlobalNamespaceResponse
( id namespace.ID, name string, activeCluster string, notificationVersion int64, )
common/namespace/nsregistry/registry_watch_test.go:166
↓ 12 callersFunctionnewHistoryBuilderFromConfig
(config builderConfig)
service/history/historybuilder/history_builder_categorization_test.go:1213
↓ 12 callersFunctionnewMsgList
(msgs ...*protocolpb.Message)
service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler_test.go:504
↓ 12 callersFunctionnewPersistedTypeMismatchError
( fieldName string, expectedType any, received any, payload map[string]any, )
common/persistence/cassandra/common.go:33
↓ 12 callersMethodnewRandomCurrentExecutionRow
( shardID int32, namespaceID primitives.UUID, workflowID string, runID primitives.UUID, requestID string,
common/persistence/sql/sqlplugin/tests/history_current_execution.go:314
↓ 12 callersMethodnewRandomExecutionRow
( shardID int32, namespaceID primitives.UUID, workflowID string, runID primitives.UUID, nextEventID int64
common/persistence/sql/sqlplugin/tests/history_execution.go:308
↓ 12 callersMethodnewRandomTasksQueueRow
( queueID []byte, rangeID int64, )
common/persistence/sql/sqlplugin/tests/matching_task_queue.go:279
↓ 12 callersFunctionnewResponseBuilder
( request *schedulespb.WatchWorkflowRequest, workflowStatus enumspb.WorkflowExecutionStatus, logger log.Log
service/worker/scheduler/activities.go:287
↓ 12 callersFunctionnewRootPartition
(namespaceID string, name string, taskType enumspb.TaskQueueType)
service/matching/matching_engine_test.go:5174
↓ 12 callersFunctionnewSyncVersionedTransitionTaskConverter
( shardContext historyi.ShardContext, workflowCache wcache.Cache, eventBlobCache persistence.XDCCache, rep
service/history/replication/raw_task_converter.go:638
↓ 12 callersMethodnewTestEnv
newTestEnv creates a TestEnv with the dynamic config this suite needs. Additional per-test options may be passed in opts.
tests/task_queue_test.go:50
↓ 12 callersFunctionnewTestTaskQueue
(namespaceID string, name string, taskType enumspb.TaskQueueType)
service/matching/matching_engine_test.go:5178
↓ 12 callersFunctionparseValueTyped
(valStr string, t enumspb.IndexedValueType)
common/searchattribute/stringify.go:126
↓ 12 callersMethodprepareWorkflowRuns
prepareWorkflowRuns prepares a workflow with n runs. If isCurrentRunning is true then the last run is kept open.
tests/workflow_reset_test.go:466
↓ 12 callersFunctionprettyPrintJSONObject
(c *cli.Context, o any)
tools/tdbg/util.go:41
↓ 12 callersFunctionrandomTaskInfo
()
service/matching/matcher_test.go:836
↓ 12 callersFunctionrequireExpectedMetricsCaptured
(t *testing.T, snap map[string][]*metricstest.CapturedRecording, ns string, method string, expectedOutcome str
tests/xdc/nexus_request_forwarding_test.go:695
↓ 12 callersFunctionrespondWftWithActivities
( tvWf *testvars.TestVars, tvAct *testvars.TestVars, sticky bool, behavior enumspb.VersioningBehavior, ac
tests/versioning_3_test.go:4541
↓ 12 callersMethodsetAndCheckOverride
(env *testcore.TestEnv, tv *testvars.TestVars, override *workflowpb.VersioningOverride)
tests/worker_deployment_version_test.go:1853
↓ 12 callersMethodsetAndValidateManagerIdentity
(env *VersioningTestEnv, tv *testvars.TestVars, self, useWrongConflictToken bool, newManager, expectedError st
tests/worker_deployment_test.go:3441
↓ 12 callersFunctionsetUpMySQLTest
(t *testing.T)
common/persistence/tests/mysql_test_util.go:49
↓ 12 callersFunctionsetUpPostgreSQLTest
(t *testing.T, pluginName string, connectAttrs map[string]string)
common/persistence/tests/postgresql_test_util.go:48
↓ 12 callersFunctionsizeOfInt64BlobMap
( kvBlob map[int64]*commonpb.DataBlob, )
common/persistence/size_util.go:30
↓ 12 callersFunctionstoreOperation
StoreOperation returns tag for StoreOperation
common/log/tag/tags.go:388
↓ 12 callersMethodsyncTaskQueueDeploymentDataWithRoutingConfig
( env *testcore.TestEnv, tv *testvars.TestVars, routingConfig *deploymentpb.RoutingConfig, upsertVersions
tests/versioning_3_test.go:4327
↓ 12 callersMethodvalidateSliceState
( slice *SliceImpl, )
service/history/queues/slice_test.go:696
↓ 12 callersMethodworkflowExecution
()
service/matching/task.go:274
↓ 11 callersMethodAdmit
(ctx context.Context, currentCluster string, task *replicationspb.NamespaceTaskAttributes)
common/namespace/nsreplication/replication_admitter.go:13
↓ 11 callersMethodAppendHistoryNodes
The below are history V2 APIs V2 regards history events growing as a tree, decoupled from workflow concepts For Temporal, treeID is new runID, except
common/persistence/data_interfaces.go:1152
↓ 11 callersMethodArchiverBase
()
tests/testcore/test_cluster.go:573
↓ 11 callersFunctionBuildId
(buildId string)
common/log/tag/tags.go:992
↓ 11 callersMethodChannel
Channel for shutdown notification
common/channel/shutdown_once.go:19
↓ 11 callersMethodCloseShard
(namespaceID string, workflowID string)
tests/testcore/test_env.go:56
↓ 11 callersMethodConstant
Constant adds a [Constant] component to the [Route].
common/routing/route.go:59
↓ 11 callersMethodCountActivityExecutions
(context.Context, *workflowservice.CountActivityExecutionsRequest)
chasm/lib/activity/frontend.go:29
↓ 11 callersMethodCurrentTaskQueue
()
service/history/interfaces/mutable_state.go:223
↓ 11 callersMethodCurrentVersionedTransition
()
service/history/workflow/mutable_state_impl.go:9117
↓ 11 callersFunctionDebugMode
()
common/telemetry/config.go:411
↓ 11 callersMethodDeleteTaskQueue
(ctx context.Context, request *DeleteTaskQueueRequest)
common/persistence/data_interfaces.go:1183
↓ 11 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/replication/stream_sender_mock.go:38
↓ 11 callersFunctionEndpoint
(endpoint string)
common/log/tag/tags.go:988
↓ 11 callersMethodError
Error implements log.Logger.
common/testing/testlogger/testlogger.go:498
↓ 11 callersMethodExecute
(ctx context.Context, shardID int32, op ClientOperation[C])
client/history/redirector.go:19
↓ 11 callersMethodExecuteSideEffectDiscardTask
( ctx context.Context, executionKey chasm.ExecutionKey, task *tasks.ChasmTask, validate func(chasm.Nod
service/history/interfaces/chasm_tree.go:40
↓ 11 callersMethodFlushAndCreateNewBatch
()
service/history/historybuilder/event_store.go:202
↓ 11 callersFunctionFromPersistencePredicate
( predicate *persistencespb.Predicate, )
service/history/queues/convert.go:132
↓ 11 callersMethodGenerateScheduleWorkflowTaskTasks
( workflowTaskScheduledEventID int64, )
service/history/workflow/task_generator.go:53
↓ 11 callersMethodGetActivityInfo
GetActivityInfo gives details about an activity that is currently in progress.
service/history/workflow/mutable_state_impl.go:1609
↓ 11 callersMethodGetArchivalMetadata
()
service/history/interfaces/shard_context.go:57
↓ 11 callersMethodGetClusterMetadata
(ctx context.Context, filter *ClusterMetadataFilter)
common/persistence/sql/sqlplugin/cluster_metadata.go:57
↓ 11 callersMethodGetCurrentVersion
()
service/history/workflow/mutable_state_impl.go:1172
↓ 11 callersMethodGetDLQReplicationMessages
(ctx context.Context, taskInfos []*replicationspb.ReplicationTaskInfo)
service/history/interfaces/engine.go:75
← previousnext →2,101–2,200 of 43,335, ranked by callers