MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 126 callersFunctionEq
Eq returns a gomock.Matcher that uses proto.Equal to check equality
common/testing/protomock/matchers.go:20
↓ 126 callersMethodLog
(args ...any)
common/testing/testlogger/testlogger.go:54
↓ 125 callersMethodNamespaceName
()
service/history/replication/executable_task.go:105
↓ 124 callersMethodRunID
()
common/testing/testvars/any.go:79
↓ 123 callersMethodAddWorkflowExecutionStartedEvent
(*commonpb.WorkflowExecution, *historyservice.StartWorkflowExecutionRequest)
service/history/interfaces/mutable_state.go:120
↓ 123 callersMethodListWorkflowExecutions
Read APIs.
common/persistence/visibility/store/visibility_store.go:36
↓ 123 callersFunctionnewContext
(c *cli.Context)
tools/tdbg/util.go:182
↓ 122 callersMethodGetClusterMetadata
()
service/history/interfaces/shard_context.go:43
↓ 122 callersMethodLoadMutableState
(ctx context.Context, shardContext ShardContext)
service/history/interfaces/workflow_context.go:27
↓ 122 callersMethodWorkflowExecution
()
common/testing/testvars/test_vars.go:207
↓ 122 callersMethodfinishMetricsRecording
( handler metrics.Handler, startTime time.Time, err error, )
client/frontend/metric_client.go:46
↓ 122 callersMethodstartMetricsRecording
( ctx context.Context, operation string, )
client/frontend/metric_client.go:36
↓ 120 callersFunctionEncodeString
(str string)
common/payload/payload.go:20
↓ 119 callersMethodPrintf
(format string, v ...any)
common/persistence/visibility/store/elasticsearch/client/logger.go:31
↓ 119 callersFunctionTimeValue
(t *timestamppb.Timestamp)
common/primitives/timestamp/time.go:13
↓ 119 callersFunctionaddWorkflowTaskCompletedEvent
(s *suite.Suite, ms historyi.MutableState, scheduledEventID, startedEventID int64, identity string)
service/history/history_engine_test.go:6703
↓ 119 callersMethodcreateContext
(parent context.Context)
client/frontend/client.go:42
↓ 117 callersFunctionNewStringTag
(key string, value string)
common/log/tag/zap_tag.go:46
↓ 116 callersFunctionNewEventTimeSource
NewEventTimeSource returns a EventTimeSource with the current time set to Unix zero: 1970-01-01 00:00:00 +0000 UTC.
common/clock/event_time_source.go:41
↓ 115 callersMethodActivityType
()
common/testing/testvars/test_vars.go:356
↓ 115 callersMethodClientIdentity
()
common/testing/testvars/test_vars.go:389
↓ 115 callersMethodGetNamespaceRegistry
()
service/history/interfaces/shard_context.go:42
↓ 115 callersFunctionNewExponentialRetryPolicy
NewExponentialRetryPolicy returns an instance of ExponentialRetryPolicy using the provided initialInterval
common/backoff/retrypolicy.go:82
↓ 115 callersFunctionTestNameTypeMap
()
common/searchattribute/test_provider.go:60
↓ 114 callersMethodWait
Wait will block go routine until the sender is allowed to send a task
service/history/replication/stream_sender_flow_controller.go:28
↓ 113 callersMethodRun
Run should execute the task and return well known status codes
service/worker/scanner/executor/executor.go:16
↓ 113 callersMethodgetWorkflowHandler
(config *Config)
service/frontend/workflow_handler_test.go:171
↓ 113 callersMethodnewConfig
()
service/frontend/workflow_handler_test.go:3780
↓ 112 callersFunctionGetBoolPropertyFn
(value bool)
common/dynamicconfig/setting_gen.go:38
↓ 112 callersFunctionNewGlobalDurationSetting
(key string, def time.Duration, description string)
common/dynamicconfig/setting_gen.go:572
↓ 112 callersMethodPollActivityTaskQueue
(ctx context.Context, request *matchingservice.PollActivityTaskQueueRequest, opMetrics metrics.Handler)
service/matching/matching_engine_interfaces.go:18
↓ 112 callersMethodUpdate
( runID string, targetClusterID int32, versionedTransitions []*persistencespb.VersionedTransition,
service/history/replication/progress_cache.go:25
↓ 111 callersMethodAdminClient
()
tests/testcore/test_env.go:54
↓ 111 callersMethodGetMetricsHandler
()
service/history/interfaces/shard_context.go:48
↓ 111 callersMethodTaskID
()
service/history/replication/executable_task.go:56
↓ 111 callersMethodWaitForChannel
WaitForChannel waits for ch to receive using the TestEnv context.
tests/testcore/test_env.go:459
↓ 110 callersMethodGetNextEventID
()
service/history/interfaces/mutable_state.go:186
↓ 110 callersFunctionNewSQLDB
NewSQLDB creates a returns a reference to a logical connection to the underlying SQL database. The returned object is tied to a single SQL database an
common/persistence/sql/store.go:32
↓ 110 callersMethodPollAndHandleWorkflowTask
PollAndHandleWorkflowTask issues a PollWorkflowTaskQueueRequest to obtain a new workflow task, invokes the handler with the task, and completes/fails
common/testing/taskpoller/taskpoller.go:124
↓ 109 callersFunctionNewRange
( inclusiveMin tasks.Key, exclusiveMax tasks.Key, )
service/history/queues/range.go:16
↓ 108 callersMethodFailoverVersion
FailoverVersion of a Mutable State at the time of Registry creation.
service/history/workflow/update/registry.go:78
↓ 108 callersMethodGetOutcome
()
api/persistence/v1/chasm.pb.go:693
↓ 108 callersFunctionNewDynamicConfig
()
service/history/tests/vars.go:160
↓ 107 callersFunctionTimePtr
(t time.Time)
common/primitives/timestamp/time.go:9
↓ 107 callersMethodpollWftAndHandle
pollWftAndHandle can be used in sync and async mode. For async mode pass the async channel. It will be closed when the task is handled. Returns the po
tests/versioning_3_test.go:4687
↓ 106 callersMethodCloseTransaction
()
service/history/interfaces/chasm_tree.go:19
↓ 106 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/tasks/task_mock.go:88
↓ 106 callersMethodGetNamespaceEntry
()
service/history/interfaces/mutable_state.go:171
↓ 106 callersMethodGo
Go spawns a goroutine whose lifecycle will be managed via this Group object. All functions passed to Go on the same instance of Group will be given th
common/goro/group.go:29
↓ 106 callersFunctionNewNamespaceIntSetting
(key string, def int, description string)
common/dynamicconfig/setting_gen.go:181
↓ 106 callersMethodSkip
(extraSkip int)
common/log/interface.go:45
↓ 105 callersMethodverifyWorkflowVersioning
(env *testcore.TestEnv, tv *testvars.TestVars, behavior enumspb.VersioningBehavior, deployment *deploymentp
tests/versioning_3_test.go:4484
↓ 104 callersMethodBuildID
()
common/testing/testvars/test_vars.go:222
↓ 104 callersMethodDeploymentVersion
()
common/testing/testvars/test_vars.go:248
↓ 104 callersFunctionNewMockRegistry
NewMockRegistry creates a new mock instance.
common/namespace/registry_mock.go:32
↓ 104 callersFunctionRun
Run discovers and runs all exported Test* methods on the given suite in parallel. Each method gets its own fresh suite instance initialized for the s
common/testing/parallelsuite/suite.go:139
↓ 104 callersMethodTaskPoller
()
tests/testcore/test_env.go:407
↓ 103 callersMethodGetNamespaceInfo
( ctx context.Context, namespaceID string, businessID string, )
service/history/replication/executable_task.go:80
↓ 103 callersMethodGetTimeSource
()
service/history/interfaces/shard_context.go:49
↓ 103 callersFunctionNewUnsafeSQLString
(val string)
common/persistence/visibility/store/query/util.go:72
↓ 102 callersMethodSignalWorkflowExecution
(ctx context.Context, request *historyservice.SignalWorkflowExecutionRequest)
service/history/interfaces/engine.go:43
↓ 101 callersMethodGetEventId
()
chasm/lib/workflow/gen/workflowpb/v1/state.pb.go:167
↓ 101 callersFunctionaddWorkflowExecutionStartedEvent
(ms historyi.MutableState, workflowExecution *commonpb.WorkflowExecution, workflowType, taskQueue string, inp
service/history/history_engine_test.go:6668
↓ 100 callersFunctionGetBoolPropertyFnFilteredByNamespace
(value bool)
common/dynamicconfig/setting_gen.go:55
↓ 100 callersMethodHasNext
HasNext return whether this iterator has next value
common/collection/iterator.go:7
↓ 100 callersFunctionNewHostInfoFromAddress
NewHostInfoFromAddress creates a new HostInfo instance from a socket address.
common/membership/hostinfo.go:14
↓ 100 callersMethodNewTimer
(d time.Duration)
common/clock/time_source.go:14
↓ 100 callersFunctionNewVersionHistory
NewVersionHistory create a new instance of VersionHistory.
common/persistence/versionhistory/version_history.go:10
↓ 100 callersMethodRemove
Remove pop an item from the queue
common/collection/interface.go:11
↓ 100 callersMethodprintln
(f string, args ...any)
cmd/tools/protoc-gen-go-chasm/main.go:33
↓ 99 callersFunctionConvertError
( operation string, err error, )
common/persistence/nosql/nosqlplugin/cassandra/gocql/errors.go:15
↓ 99 callersFunctionNewTimerDef
(name string, opts ...Option)
common/metrics/defs.go:22
↓ 98 callersMethodSize
()
service/history/replication/executable_task_tracker.go:37
↓ 98 callersFunctionfile_temporal_server_api_adminservice_v1_request_response_proto_rawDescGZIP
()
api/adminservice/v1/request_response.pb.go:6361
↓ 97 callersMethodDescribeMutableState
(ctx context.Context, request *historyservice.DescribeMutableStateRequest)
service/history/interfaces/engine.go:31
↓ 97 callersFunctionMustEncodeValue
MustEncodeValue encodes search attribute value and IndexedValueType to Payload. Panics if it fails to encode.
common/searchattribute/sadefs/encode_value.go:27
↓ 97 callersFunctionTestLocalMutableState
( shard historyi.ShardContext, eventsCache events.Cache, ns *namespace.Namespace, workflowID string, runI
service/history/workflow/test_util.go:19
↓ 96 callersMethodAdvance
Advance the timer by the specified duration.
common/clock/event_time_source.go:118
↓ 96 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/tasks/task_mock.go:40
↓ 96 callersMethodGetDeploymentVersion
()
api/taskqueue/v1/message.pb.go:139
↓ 96 callersMethodStopCapture
StopCapture stops capturing metrics for the given capture instance.
common/metrics/metricstest/capture_handler.go:78
↓ 96 callersFunctionmkRedirectRule
(source, target string)
service/matching/version_rule_test.go:102
↓ 95 callersMethodGetShardByNamespaceWorkflow
(namespaceID namespace.ID, workflowID string)
service/history/shard/controller.go:18
↓ 94 callersFunctionStringTag
(key string, value string)
common/metrics/tags.go:442
↓ 94 callersMethodUnmarshal
Unmarshal an object of type Task from the protobuf v3 wire format
api/adminservice/v1/request_response.go-helpers.pb.go:532
↓ 93 callersFunctionGetDurationPropertyFn
(value time.Duration)
common/dynamicconfig/setting_gen.go:582
↓ 93 callersMethodGetExecutions
()
api/adminservice/v1/request_response.pb.go:5574
↓ 92 callersMethodClusterName
()
tests/testcore/test_cluster.go:622
↓ 92 callersMethodDeployment
[cleanup-wv-pre-release]
common/testing/testvars/test_vars.go:241
↓ 92 callersFunctionDurationFromDays
(d int32)
common/primitives/timestamp/duration.go:49
↓ 92 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/interfaces/shard_context_mock.go:64
↓ 92 callersMethodGetState
()
common/archiver/history_iterator.go:28
↓ 92 callersFunctionNewSAColumn
(alias string, fieldName string, valueType enumspb.IndexedValueType)
common/persistence/visibility/store/query/util.go:80
↓ 91 callersMethodHost
TODO (alex): expose only needed objects from TemporalImpl.
tests/testcore/test_cluster.go:610
↓ 91 callersMethodgenerate
(methodName string, request ...any)
common/persistence/faultinjection/fault_generator.go:5
↓ 90 callersMethodEquals
Equals recursively checks if the given Predicate has the same structure and value as the caller Predicate NOTE: the result will contain false negative
common/predicates/predicates.go:13
↓ 89 callersFunctionNewMutableContext
NewMutableContext creates a new MutableContext from an existing Context and root Node. NOTE: Library authors should not invoke this constructor direc
chasm/context.go:255
↓ 89 callersMethodStartActivityExecution
(ctx context.Context, req *workflowservice.StartActivityExecutionRequest)
chasm/lib/activity/frontend.go:26
↓ 89 callersFunctionfile_temporal_server_api_matchingservice_v1_request_response_proto_rawDescGZIP
()
api/matchingservice/v1/request_response.pb.go:6318
↓ 88 callersFunctionNewData
( state State, )
service/history/hsm/hsmtest/sm.go:28
← previousnext →201–300 of 43,335, ranked by callers