MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 9 callersMethodmarkAlive
()
service/matching/liveness.go:45
↓ 9 callersFunctionmergeReports
(reports []*junitReport)
tools/testrunner/junit.go:257
↓ 9 callersMethodmergeUpdateWithNewReplicationTasks
( currentWorkflowMutation *persistence.WorkflowMutation, newWorkflowSnapshot *persistence.WorkflowSnapshot,
service/history/workflow/context.go:707
↓ 9 callersMethodmetricNameWithTags
(originalName string, tags map[string]string)
common/metrics/tally/statsd/reporter.go:27
↓ 9 callersMethodmockGetMutableState
( namespaceId string, workflowId string, runId string, mutableState historyi.MutableState, err error, )
service/history/replication/executable_verify_versioned_transition_task_test.go:270
↓ 9 callersFunctionmustToPayload
(t *testing.T, v any)
common/nexus/payload_serializer_test.go:12
↓ 9 callersFunctionnewMetricDefinition
(name string, opts ...Option)
common/metrics/defs_base.go:12
↓ 9 callersFunctionnewNode
( base *nodeBase, parent *Node, nodeName string, )
chasm/tree.go:3010
↓ 9 callersMethodnewQueueBase
( mockShard *shard.ContextTest, category tasks.Category, paginationFnProvider PaginationFnProvider, )
service/history/queues/queue_base_test.go:657
↓ 9 callersFunctionnewReplicationTask
( clusterMetadata cluster.Metadata, logger log.Logger, workflowKey definition.WorkflowKey, baseExecutionIn
service/history/ndc/replication_task.go:168
↓ 9 callersMethodnewSchedulerWithExecution
(maxQueues int, queueTTL time.Duration)
common/tasks/execution_queue_scheduler_test.go:585
↓ 9 callersFunctionnewSearchAttributeKeywordByField
(field string)
chasm/search_attribute.go:376
↓ 9 callersFunctionnewTestConn
( database string, host string, port string, pluginName string, )
tools/sql/clitest/conn_tests.go:82
↓ 9 callersMethodnewTestEnv
(opts ...testcore.TestOption)
tests/workflow_reset_with_child_test.go:49
↓ 9 callersMethodnewTestExecutionFn
( activityID string, )
service/history/chasm_engine_test.go:524
↓ 9 callersFunctionnewTestMetadataContext
( requestValue string, )
service/history/chasm_engine_test.go:2012
↓ 9 callersFunctionnewTestVersionMembershipCache
()
common/worker_versioning/worker_versioning_test.go:51
↓ 9 callersFunctionnewUnexpectedResponseError
(message string, response *http.Response, body []byte)
common/nexus/nexusrpc/client.go:62
↓ 9 callersMethodoneOf
(counterName string)
service/history/workflow/update/util.go:99
↓ 9 callersMethodopMetricsHandler
( namespaceID string, taskQueue *taskqueuepb.TaskQueue, taskQueueType enumspb.TaskQueueType, operation str
service/matching/handler.go:144
↓ 9 callersFunctionparseValue
Parses a single value (integer or day-of-week or month name).
service/worker/scheduler/calendar.go:508
↓ 9 callersFunctionpersistenceGetNamespaceResponse
(historyArchivalState, visibilityArchivalState *namespace.ArchivalConfigState)
service/frontend/workflow_handler_test.go:3801
↓ 9 callersMethodpollActivityAndHandle
( env *testcore.TestEnv, tv *testvars.TestVars, async chan<- struct{}, handler func(task *workflowservice.
tests/versioning_3_test.go:4817
↓ 9 callersMethodpollWorkflowTask
(ctx context.Context, client workflowservice.WorkflowServiceClient, ns string)
tests/xdc/nexus_state_replication_test.go:699
↓ 9 callersMethodrUnlock
()
service/history/shard/context_impl.go:1521
↓ 9 callersMethodregister
register adds a metric definition to the list of pending metric definitions. This method is thread-safe.
common/metrics/registry.go:45
↓ 9 callersFunctionregisterNamespaceRequest
( historyArchivalState enumspb.ArchivalState, historyArchivalURI string, visibilityArchivalState enumspb.Ar
service/frontend/workflow_handler_test.go:3834
↓ 9 callersFunctionreject
(t *testing.T, store mockEventStore, upd *update.Update)
service/history/workflow/update/update_test.go:1054
↓ 9 callersFunctionrequireMetricValue
(t *testing.T, snap map[string][]*metricstest.CapturedRecording, expectedOutcome string)
service/history/worker_commands_task_dispatcher_test.go:37
↓ 9 callersFunctionrunExecuteTestCase
(t *testing.T, env *invokerExecuteTestEnv, c *executeTestCase)
chasm/lib/scheduler/invoker_execute_task_test.go:72
↓ 9 callersFunctionrunProcessBufferTestCase
(t *testing.T, env *testEnv, c *processBufferTestCase)
chasm/lib/scheduler/invoker_process_buffer_task_test.go:113
↓ 9 callersFunctionschedulerWorkflowWithSpecBuilder
(ctx workflow.Context, args *schedulespb.StartScheduleArgs, specBuilder *SpecBuilder, enableCHASMMigration fun
service/worker/scheduler/workflow.go:235
↓ 9 callersMethodsetAndTrackTaskKeys
( taskMaps ...map[tasks.Category][]tasks.Task, )
service/history/shard/task_key_manager.go:45
↓ 9 callersMethodsetDefaultMergeParams
(t *testing.T)
service/worker/dlq/workflow_test.go:533
↓ 9 callersMethodsetStateChanged
()
service/worker/workerdeployment/version_workflow.go:1153
↓ 9 callersFunctionsetUpCassandraTest
(t *testing.T)
common/persistence/tests/cassandra_test_util.go:52
↓ 9 callersFunctionsetVisibilityExpect
setVisibilityExpect resets the cache and sets the expected visibility results for the mock visibility inside it
service/matching/reachability_test.go:321
↓ 9 callersMethodsetupMockForTaskNotification
()
service/history/workflow/transaction_test.go:348
↓ 9 callersMethodsetupMocksForAcquireShard
( shardID int32, mockEngine *historyi.MockEngine, currentRangeID, newRangeID int64, required bool, )
service/history/shard/controller_test.go:1043
↓ 9 callersMethodsetupPartitionManagerWithCapture
setupPartitionManagerWithCapture creates a partition manager with a capturing metrics handler and returns the manager, capture, and a cleanup function
service/matching/task_queue_partition_manager_test.go:1421
↓ 9 callersFunctionsortErrors
( errors []error, )
common/persistence/cassandra/errors.go:146
↓ 9 callersMethodsorterToJSON
(sorters []elastic.Sorter)
common/persistence/visibility/store/elasticsearch/visibility_store_read_test.go:333
↓ 9 callersMethodstartEagerWorkflow
(env *testcore.TestEnv, baseOptions *workflowservice.StartWorkflowExecutionRequest)
tests/eager_workflow_start_test.go:42
↓ 9 callersMethodstartWorkflowOptions
(env *testcore.TestEnv)
tests/workflow_reset_with_child_test.go:700
↓ 9 callersMethodstoreFaultInjector
(storeName config.DataStoreName)
common/persistence/faultinjection/data_store_factory.go:200
↓ 9 callersMethodtestCan
(crossTq bool, behavior enumspb.VersioningBehavior, upgradeOnCaN bool, expectPinnedInherit bool, pinnedOverrid
tests/versioning_3_test.go:3664
↓ 9 callersMethodtestHelperForReadOnce
(env *testcore.TestEnv, expectedRunID string, query string)
tests/advanced_visibility_test.go:879
↓ 9 callersMethodtestWireEventIDs
( scheduledEventID int64, startEvent *historypb.HistoryEvent, finishEvent *historypb.HistoryEvent, )
service/history/historybuilder/history_builder_test.go:2134
↓ 9 callersMethodvalidate
()
common/config/persistence.go:284
↓ 9 callersMethodverifyMemberDiff
(curr []string, new []string, expectedDiff []string)
common/membership/ringpop/monitor_test.go:179
↓ 9 callersFunctionwrapConverterError
(message string, err error)
common/persistence/visibility/store/query/errors.go:51
↓ 9 callersMethodwrite
()
tools/testrunner/junit.go:86
↓ 8 callersMethodAccess
Access a state machine Node for the given ref. When using AccessRead, the accessor must guarantee not to mutate any state, accessor errors will not c
service/history/hsm/executor.go:54
↓ 8 callersMethodAddActivityTaskCanceledEvent
(int64, int64, int64, *commonpb.Payloads, string)
service/history/interfaces/mutable_state.go:51
↓ 8 callersFunctionAddBearer
(token string)
common/authorization/default_jwt_claim_mapper_test.go:324
↓ 8 callersFunctionAddChild
AddChild adds a new operation child machine to the given node and transitions it to the SCHEDULED state.
components/nexusoperations/statemachine.go:46
↓ 8 callersMethodAddChildWorkflowExecutionTerminatedEvent
(int64, *commonpb.WorkflowExecution)
service/history/interfaces/mutable_state.go:72
↓ 8 callersMethodAddHistoryEvent
(t enumspb.EventType, setAttributes func(*historypb.HistoryEvent))
service/history/interfaces/mutable_state.go:45
↓ 8 callersMethodAddRequestCancelExternalWorkflowExecutionInitiatedEvent
(int64, string, *commandpb.RequestCancelExternalWorkflowExecutionCommandAttributes, namespace.ID)
service/history/interfaces/mutable_state.go:89
↓ 8 callersMethodAddSearchAttributes
Admin APIs AddSearchAttributes makes schema changes to add the search attributes. This function must be idempotent, ie., if a search attribute already
common/persistence/visibility/store/visibility_store.go:48
↓ 8 callersMethodAddSignalExternalWorkflowExecutionInitiatedEvent
(int64, string, *commandpb.SignalExternalWorkflowExecutionCommandAttributes, namespace.ID)
service/history/interfaces/mutable_state.go:91
↓ 8 callersMethodAddWorkflowExecutionSignaledEvent
( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, extern
service/history/interfaces/mutable_state.go:111
↓ 8 callersMethodAddWorkflowExecutionUpdateAcceptedEvent
AddWorkflowExecutionUpdateAcceptedEvent writes an Update accepted event. The data may not be durable when this function returns.
service/history/workflow/update/store.go:35
↓ 8 callersMethodAddWorkflowExecutionUpdateAdmittedEvent
(request *updatepb.Request, origin enumspb.UpdateAdmittedEventOrigin)
service/history/interfaces/mutable_state.go:138
↓ 8 callersMethodApplySnapshot
(chasm.NodesSnapshot)
service/history/interfaces/chasm_tree.go:23
↓ 8 callersFunctionAttemptStart
AttemptStart returns tag for AttemptStart
common/log/tag/tags.go:695
↓ 8 callersMethodAwaitf
Awaitf is like [Await] but includes a format string appended to the failure message.
common/testing/parallelsuite/suite.go:113
↓ 8 callersMethodBackfillWorkflow
( ctx context.Context, targetWorkflow Workflow, targetWorkflowEventsSlice ...*persistence.WorkflowEve
service/history/ndc/transaction_manager.go:105
↓ 8 callersFunctionBuildZapLogger
BuildZapLogger builds and returns a new zap.Logger for this logging configuration
common/log/zap_logger.go:93
↓ 8 callersFunctionCalculateTaskQueueVersioningInfo
CalculateTaskQueueVersioningInfo calculates the current and ramping versioning info for a task queue. revive:disable-next-line:cognitive-complexity,c
common/worker_versioning/worker_versioning.go:925
↓ 8 callersMethodCanMerge
( input Range, )
service/history/queues/range.go:64
↓ 8 callersMethodCancelDLQJob
(ctx context.Context, in *CancelDLQJobRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:153
↓ 8 callersMethodChasmWorkflowComponent
ChasmWorkflowComponent gets the root workflow component from the CHASM tree. Returns the workflow component (which is *chasmworkflow.Workflow) and the
service/history/workflow/mutable_state_impl.go:703
↓ 8 callersMethodCheckRunning
CheckRunning has two modes of operation: 1. If the node is **not** attached to a workflow (not yet supported), it returns nil. 2. If the node is attac
service/history/hsm/tree.go:495
↓ 8 callersMethodCheckWorkflowExists
( ctx context.Context, namespaceID namespace.ID, workflowID string, runID string, archetypeID c
service/history/ndc/transaction_manager.go:111
↓ 8 callersMethodCherryPick
CherryPick (a.k.a "reapply") an event from a different history branch. Implementations should apply the event to the machine state and return nil in c
chasm/lib/workflow/events.go:26
↓ 8 callersMethodClientSupported
(ctx context.Context)
common/headers/version_checker.go:66
↓ 8 callersFunctionCloneMapNonNil
CloneMapNonNil is like maps.Clone except it can't return nil, it will return an empty map instead.
common/util/util.go:61
↓ 8 callersMethodComponentFqnByID
ComponentFqnByID converts component type ID to fully qualified component type name. This method should only be used by CHASM framework internal code,
chasm/registry.go:114
↓ 8 callersMethodComponentIDFor
ComponentIDFor converts registered component instance to component type ID. This method should only be used by CHASM framework internal code, NOT CHAS
chasm/registry.go:144
↓ 8 callersFunctionContextMetadataGetActivityTypeAndTaskQueue
ContextMetadataGetActivityTypeAndTaskQueue scans the context metadata for a single activity's type and task queue. Returns false if no activity metada
common/contextutil/metadata.go:55
↓ 8 callersFunctionConvertFileToBase64
(file string)
tests/testutils/tls.go:31
↓ 8 callersMethodCountSchedules
( ctx context.Context, request *workflowservice.CountSchedulesRequest, opts ...grpc.CallOption, )
client/frontend/client_gen.go:32
↓ 8 callersMethodCreateFromMigrationState
(ctx context.Context, in *CreateFromMigrationStateRequest, opts ...grpc.CallOption)
chasm/lib/scheduler/gen/schedulerpb/v1/service_grpc.pb.go:44
↓ 8 callersMethodDeleteNexusEndpoint
(ctx context.Context, request *matchingservice.DeleteNexusEndpointRequest)
service/matching/matching_engine_interfaces.go:45
↓ 8 callersMethodDeleteWorkerDeployment
( ctx context.Context, namespaceEntry *namespace.Namespace, deploymentName string, identity string, )
service/worker/workerdeployment/client.go:111
↓ 8 callersMethodDeleteWorkflowExecution
( ctx context.Context, nsID namespace.ID, we *commonpb.WorkflowExecution, weCtx historyi.WorkflowC
service/history/deletemanager/delete_manager.go:30
↓ 8 callersMethodDeleteWorkflowVisibilityRecord
DeleteWorkflowVisibilityRecord force delete a workflow's visibility record. This is used by admin delete workflow execution API to delete visibility r
api/historyservice/v1/service_grpc.pb.go:284
↓ 8 callersMethodDescribe
(ctx context.Context, buildIds map[string]bool, includeAllActive, reportStats, reportPollers, internalTaskQueu
service/matching/task_queue_partition_manager_interface.go:61
↓ 8 callersMethodDescribeDLQJob
(ctx context.Context, in *DescribeDLQJobRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:152
↓ 8 callersMethodDeserializeChasmComponentRef
(data []byte)
common/tasktoken/serializer.go:54
↓ 8 callersMethodDeserializeTask
(category tasks.Category, blob *commonpb.DataBlob)
common/persistence/serialization/serializer.go:104
↓ 8 callersFunctionESRequest
ElasticSearch ESRequest returns tag for ESRequest
common/log/tag/tags.go:712
↓ 8 callersFunctionEncode
Encode encodes the given proto message. It respects the `TEMPORAL_TEST_DATA_ENCODING` environment variable; otherwise, it defaults to "ENCODING_TYPE_P
common/persistence/serialization/codec.go:59
↓ 8 callersMethodEncodeHistories
Encode History slice to bytes.
common/codec/jsonpb.go:56
↓ 8 callersMethodEqualHistoryEventsPrefix
(expectedHistoryPrefix string, actualHistoryEvents []*historypb.HistoryEvent)
common/testing/historyrequire/history_require.go:114
↓ 8 callersMethodExec
Exec executes a cql statement
tools/common/schema/types.go:37
↓ 8 callersMethodExecuteImmediateTask
ExecuteImmediateTask gets an [ImmediateExecutor] from the registry and invokes it. Returns [ErrNotRegistered] if an executor is not registered for the
service/history/hsm/registry.go:151
↓ 8 callersMethodExecuteSideEffectTask
( ctx context.Context, executionKey chasm.ExecutionKey, task *tasks.ChasmTask, validate func(chasm.Nod
service/history/interfaces/chasm_tree.go:34
↓ 8 callersMethodExecuteTimerTask
ExecuteTimerTask gets a [TimerExecutor] from the registry and invokes it. Returns [ErrNotRegistered] if an executor is not registered for the given ta
service/history/hsm/registry.go:225
← previousnext →2,801–2,900 of 43,335, ranked by callers