MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 69 callersFunctionContextMetadataSet
ContextMetadataSet sets a metadata key-value pair in the context, overwriting any existing value.
common/contextutil/metadata.go:149
↓ 69 callersMethodGetTaskQueueUserData
(ctx context.Context, request *matchingservice.GetTaskQueueUserDataRequest)
service/matching/matching_engine_interfaces.go:28
↓ 69 callersMethodGetWorkflowID
()
service/history/tasks/task.go:17
↓ 69 callersMethodadd
( event *historypb.HistoryEvent, )
service/history/historybuilder/event_store.go:85
↓ 68 callersMethodAddTasks
(ctx context.Context, request *historyservice.AddTasksRequest)
service/history/interfaces/engine.go:92
↓ 68 callersMethodGetMutableState
()
service/history/api/workflow_lease.go:9
↓ 68 callersMethodGetOrCreateWorkflowExecution
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, execution *co
service/history/workflow/cache/cache.go:42
↓ 68 callersMethodResetWorkflowExecution
(ctx context.Context, request *historyservice.ResetWorkflowExecutionRequest)
service/history/interfaces/engine.go:49
↓ 68 callersFunctionnewBoolQuery
()
common/persistence/visibility/store/elasticsearch/query_converter_bool_query.go:20
↓ 67 callersMethodGetIndexName
()
common/persistence/visibility/store/visibility_store.go:22
↓ 67 callersMethodGetPendingActivities
()
api/cli/v1/message.pb.go:84
↓ 67 callersFunctionNewMutableStateFromDB
( shard historyi.ShardContext, eventsCache events.Cache, logger log.Logger, namespaceEntry *namespace.Name
service/history/workflow/mutable_state_impl.go:442
↓ 67 callersFunctionProtoSliceEqual
ProtoSliceEqual compares elements in a slice of proto.Message. This is not a method on the suite type because methods cannot have generic parameters a
common/testing/protorequire/require.go:73
↓ 67 callersMethodRequestID
()
common/testing/testvars/test_vars.go:214
↓ 67 callersMethodStop
()
common/tasks/scheduler.go:10
↓ 67 callersMethodTrySubmit
(task T)
common/tasks/scheduler.go:8
↓ 66 callersMethodCountWorkflowExecutions
(ctx context.Context, request *manager.CountWorkflowExecutionsRequest)
common/persistence/visibility/store/visibility_store.go:37
↓ 66 callersMethodExternalDeploymentVersion
()
common/testing/testvars/test_vars.go:255
↓ 66 callersMethodGetVisibilityTime
()
service/history/tasks/task.go:20
↓ 66 callersFunctionNewTestContext
( ctrl *gomock.Controller, shardInfo *persistencespb.ShardInfo, config *configs.Config, )
service/history/shard/context_testutil.go:53
↓ 66 callersMethodStart
()
common/tasks/scheduler.go:9
↓ 65 callersMethodGetPendingActivityInfos
()
service/history/interfaces/mutable_state.go:188
↓ 65 callersFunctionInt32ToString
(v int32)
common/convert/convert.go:30
↓ 65 callersFunctionMachineTransition
MachineTransition runs the given transitionFn on a machine's data for the given key. It updates the state machine's metadata and marks the entry as di
service/history/hsm/tree.go:585
↓ 65 callersFunctionNewScope
( r Range, predicate tasks.Predicate, )
service/history/queues/scope.go:17
↓ 65 callersMethodRegister
Register registers Workflow and Activity types provided by this worker component. The namespace that this worker is running in is also provided. If Re
service/worker/common/interface.go:42
↓ 64 callersMethodClose
Close shutdown the timer
common/timer/gate.go:18
↓ 64 callersMethodExecContext
(ctx context.Context, query string, args ...any)
common/persistence/sql/sqlplugin/interfaces.go:130
↓ 64 callersMethodGetCurrentExecution
(ctx context.Context, request *persistence.GetCurrentExecutionRequest)
service/history/interfaces/shard_context.go:95
↓ 64 callersMethodGetNamespace
GetNamespace reads the state for a single namespace by name or ID from persistent storage, returning an instance of serviceerror.NamespaceNotFound if
common/namespace/nsregistry/registry.go:84
↓ 64 callersFunctionNewRandomKeyInRange
( r Range, )
service/history/queues/test_util.go:26
↓ 63 callersMethodAddWorkflowTaskScheduledEvent
(bypassTaskGeneration bool, workflowTaskType enumsspb.WorkflowTaskType)
service/history/interfaces/mutable_state.go:80
↓ 63 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/replication/executable_task_tracker_mock.go:42
↓ 63 callersMethodGetRoutingConfig
()
api/deployment/v1/message.pb.go:3493
↓ 63 callersMethodGetSpec
()
api/persistence/v1/nexus.pb.go:234
↓ 63 callersMethodPath
Path returns the full path to the node where this operation occurred.
service/history/hsm/tree.go:94
↓ 63 callersMethodSubmit
(task T)
common/tasks/scheduler.go:7
↓ 63 callersFunctionfile_temporal_server_api_deployment_v1_message_proto_rawDescGZIP
()
api/deployment/v1/message.pb.go:4416
↓ 63 callersFunctionmin
(left int, right int)
common/locks/condition_variable_test.go:234
↓ 62 callersMethodExecContext
Helper methods to hide common error handling
common/persistence/sql/sqlplugin/postgresql/db.go:132
↓ 62 callersMethodExecContext
Helper methods to hide common error handling
common/persistence/sql/sqlplugin/mysql/db.go:143
↓ 62 callersFunctionNewVersionHistories
NewVersionHistories create a new instance of VersionHistories.
common/persistence/versionhistory/version_histories.go:9
↓ 62 callersMethodPageState
()
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:47
↓ 62 callersFunctionmkRedirectRulePersistence
(rule *taskqueuepb.CompatibleBuildIdRedirectRule, createTs, deleteTs *hlc.Clock)
service/matching/version_rule_test.go:94
↓ 61 callersMethodGetComponentAttributes
()
api/persistence/v1/chasm.pb.go:151
↓ 61 callersMethodGetVersionHistories
()
api/token/v1/message.pb.go:230
↓ 61 callersMethodnewTestEnv
newTestEnv creates a TestEnv with the dynamic config and test variables this suite needs. Additional per-test options may be passed in opts.
tests/worker_deployment_version_test.go:73
↓ 60 callersMethodGetInput
()
api/matchingservice/v1/request_response.pb.go:727
↓ 60 callersMethodGetNamespaceName
(id ID)
common/namespace/registry.go:28
↓ 60 callersMethodScope
()
service/history/queues/slice.go:26
↓ 60 callersMethodshardIDFromWorkflowID
(namespaceID, workflowID string)
client/history/client.go:291
↓ 59 callersMethodGet
(key XDCCacheKey)
common/persistence/xdc_cache.go:35
↓ 59 callersMethodGetOrCreateChasmExecution
( ctx context.Context, shardContext historyi.ShardContext, namespaceID namespace.ID, execution *co
service/history/workflow/cache/cache.go:50
↓ 59 callersMethodIsGlobalNamespace
()
common/namespace/replication_resolver.go:29
↓ 59 callersFunctionNewMockWorkflow
NewMockWorkflow creates a new mock instance.
service/history/ndc/workflow_mock.go:34
↓ 59 callersMethodRespondActivityTaskFailed
(ctx context.Context, request *historyservice.RespondActivityTaskFailedRequest)
service/history/interfaces/engine.go:39
↓ 59 callersMethodUnmarshal
Unmarshal an object of type VersionLocalState from the protobuf v3 wire format
api/deployment/v1/message.go-helpers.pb.go:125
↓ 59 callersFunctionWorkflowIDToHistoryShard
WorkflowIDToHistoryShard is used to map namespaceID-workflowID pair to a shardID. TODO: rename to BusinessIDToHistoryShard.
common/util.go:416
↓ 58 callersMethodAddChild
AddChild adds an immediate child to a node, serializing the given data. Returns [ErrStateMachineAlreadyExists] if a child with the given key already e
service/history/hsm/tree.go:351
↓ 58 callersMethodClearStickyTaskQueue
()
service/history/interfaces/mutable_state.go:225
↓ 58 callersMethodEqualHistory
(expectedHistory string, actualHistory *historypb.History)
common/testing/historyrequire/history_require.go:195
↓ 58 callersMethodGetResponse
()
api/historyservice/v1/request_response.pb.go:8715
↓ 58 callersMethodPayloads
()
common/testing/testvars/any.go:35
↓ 58 callersFunctionUnexpectedInternalErr
UnexpectedInternalErr creates a serviceerror.Internal from a static message and error details. The error message follows the format "<staticMessage>:
common/softassert/serviceerror.go:21
↓ 58 callersMethodnewTaskExecutable
( task tasks.Task, )
service/history/timer_queue_standby_task_executor_test.go:2581
↓ 58 callersMethodsetCurrentDeployment
(env *testcore.TestEnv, tv *testvars.TestVars)
tests/versioning_3_test.go:4089
↓ 58 callersMethodsetupEnv
(opts ...testcore.TestOption)
tests/versioning_3_test.go:89
↓ 57 callersMethodCreateWorkflowExecution
( ctx context.Context, createMode persistence.CreateWorkflowMode, archetypeID chasm.ArchetypeID, n
service/history/workflow/transaction.go:13
↓ 57 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/queues/executable_mock.go:44
↓ 57 callersMethodGetVersions
Deprecated: Marked as deprecated in temporal/server/api/persistence/v1/task_queues.proto.
api/persistence/v1/task_queues.pb.go:506
↓ 57 callersMethodIsValid
()
service/history/replication/stream_sender.go:43
↓ 57 callersFunctionNewRandomRange
()
service/history/queues/test_util.go:17
↓ 57 callersMethodSerializeEvents
(batch []*historypb.HistoryEvent)
common/persistence/serialization/serializer.go:35
↓ 57 callersMethodfinish
finish marks a task as finished. Must be called after a poller picks up a task and marks it as started. If the task is unable to marked as started, th
service/matching/task.go:370
↓ 56 callersMethodGetMessages
( ctx context.Context, sourceCluster string, lastMessageID int64, pageSize int, pageToken []byt
service/history/replication/dlq_handler.go:27
↓ 56 callersMethodGetStartWorkflow
()
api/historyservice/v1/request_response.pb.go:10329
↓ 56 callersMethodLookup
(key string, index int)
common/client_cache.go:13
↓ 56 callersFunctionNewMockMetadata
NewMockMetadata creates a new mock instance.
common/cluster/metadata_mock.go:32
↓ 56 callersMethodOK
OK returns whether the limiter can provide the requested number of tokens
common/quotas/reservation.go:13
↓ 56 callersMethodnewTestEnv
newTestEnv creates a TestEnv with the dynamic config this suite needs. Additional per-test options may be passed in opts.
tests/worker_deployment_test.go:45
↓ 55 callersMethodAssert
Deprecated: Assert returns non-fatal assertions which are not supported. Use s.NoError, s.Equal, etc. directly (require semantics).
common/testing/parallelsuite/testify.go:30
↓ 55 callersMethodAssertMSEqualWithDB
( archetypeID chasm.ArchetypeID, snapshot *p.WorkflowSnapshot, mutations ...*p.WorkflowMutation, )
common/persistence/tests/execution_mutable_state.go:2737
↓ 55 callersMethodChasmTree
()
service/history/interfaces/mutable_state.go:360
↓ 55 callersFunctionConvertToPersistenceTaskKey
( key tasks.Key, )
service/history/shard/context_util.go:39
↓ 55 callersMethodDescribeNamespace
( ctx context.Context, request *workflowservice.DescribeNamespaceRequest, opts ...grpc.CallOption, )
client/frontend/client_gen.go:212
↓ 55 callersFunctionEncodeBytes
(bytes []byte)
common/payloads/payloads.go:27
↓ 55 callersMethodGetMessage
()
api/cli/v1/message.pb.go:478
↓ 55 callersMethodGetRequest
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:400
↓ 55 callersMethodGetShardId
()
api/common/v1/dlq.pb.go:65
↓ 55 callersMethodGetStartTime
()
api/schedule/v1/message.pb.go:177
↓ 55 callersFunctionNewID
()
common/namespace/namespace.go:75
↓ 55 callersMethodRegisterActivityWithOptions
RegisterActivityWithOptions mocks base method.
common/testing/mocksdk/worker_mock.go:58
↓ 54 callersMethodApplyEvents
( ctx context.Context, namespaceID namespace.ID, requestID string, execution *commonpb.WorkflowExe
service/history/workflow/mutable_state_rebuilder.go:27
↓ 54 callersMethodMustNot
(queries ...elastic.Query)
common/persistence/visibility/store/elasticsearch/query_converter_bool_query.go:24
↓ 54 callersFunctionNewLocalNamespaceForTest
TODO: delete this whole file and transition usages to FromPersistentState NewLocalNamespaceForTest returns an entry with test data
common/namespace/testconstructors.go:11
↓ 54 callersFunctionNewTestLogger
NewTestLogger creates a new TestLogger that logs to the provided testing.T. Mode controls the behavior of the logger for when an expected or unexpecte
common/testing/testlogger/testlogger.go:272
↓ 54 callersMethodNotifyNewTasks
(tasks []tasks.Task)
service/history/queues/queue.go:12
↓ 54 callersFunctionworkflowAction
========== Workflow tags defined here: ( wf is short for workflow) ========== WorkflowAction returns tag for WorkflowAction
common/log/tag/tags.go:72
↓ 53 callersMethodDescribeTaskQueue
(ctx context.Context, request *matchingservice.DescribeTaskQueueRequest)
service/matching/matching_engine_interfaces.go:23
↓ 53 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/history_iterator_mock.go:40
← previousnext →401–500 of 43,335, ranked by callers