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
↓ 126 callers
Function
Eq
Eq returns a gomock.Matcher that uses proto.Equal to check equality
common/testing/protomock/matchers.go:20
↓ 126 callers
Method
Log
(args ...any)
common/testing/testlogger/testlogger.go:54
↓ 125 callers
Method
NamespaceName
()
service/history/replication/executable_task.go:105
↓ 124 callers
Method
RunID
()
common/testing/testvars/any.go:79
↓ 123 callers
Method
AddWorkflowExecutionStartedEvent
(*commonpb.WorkflowExecution, *historyservice.StartWorkflowExecutionRequest)
service/history/interfaces/mutable_state.go:120
↓ 123 callers
Method
ListWorkflowExecutions
Read APIs.
common/persistence/visibility/store/visibility_store.go:36
↓ 123 callers
Function
newContext
(c *cli.Context)
tools/tdbg/util.go:182
↓ 122 callers
Method
GetClusterMetadata
()
service/history/interfaces/shard_context.go:43
↓ 122 callers
Method
LoadMutableState
(ctx context.Context, shardContext ShardContext)
service/history/interfaces/workflow_context.go:27
↓ 122 callers
Method
WorkflowExecution
()
common/testing/testvars/test_vars.go:207
↓ 122 callers
Method
finishMetricsRecording
( handler metrics.Handler, startTime time.Time, err error, )
client/frontend/metric_client.go:46
↓ 122 callers
Method
startMetricsRecording
( ctx context.Context, operation string, )
client/frontend/metric_client.go:36
↓ 120 callers
Function
EncodeString
(str string)
common/payload/payload.go:20
↓ 119 callers
Method
Printf
(format string, v ...any)
common/persistence/visibility/store/elasticsearch/client/logger.go:31
↓ 119 callers
Function
TimeValue
(t *timestamppb.Timestamp)
common/primitives/timestamp/time.go:13
↓ 119 callers
Function
addWorkflowTaskCompletedEvent
(s *suite.Suite, ms historyi.MutableState, scheduledEventID, startedEventID int64, identity string)
service/history/history_engine_test.go:6703
↓ 119 callers
Method
createContext
(parent context.Context)
client/frontend/client.go:42
↓ 117 callers
Function
NewStringTag
(key string, value string)
common/log/tag/zap_tag.go:46
↓ 116 callers
Function
NewEventTimeSource
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 callers
Method
ActivityType
()
common/testing/testvars/test_vars.go:356
↓ 115 callers
Method
ClientIdentity
()
common/testing/testvars/test_vars.go:389
↓ 115 callers
Method
GetNamespaceRegistry
()
service/history/interfaces/shard_context.go:42
↓ 115 callers
Function
NewExponentialRetryPolicy
NewExponentialRetryPolicy returns an instance of ExponentialRetryPolicy using the provided initialInterval
common/backoff/retrypolicy.go:82
↓ 115 callers
Function
TestNameTypeMap
()
common/searchattribute/test_provider.go:60
↓ 114 callers
Method
Wait
Wait will block go routine until the sender is allowed to send a task
service/history/replication/stream_sender_flow_controller.go:28
↓ 113 callers
Method
Run
Run should execute the task and return well known status codes
service/worker/scanner/executor/executor.go:16
↓ 113 callers
Method
getWorkflowHandler
(config *Config)
service/frontend/workflow_handler_test.go:171
↓ 113 callers
Method
newConfig
()
service/frontend/workflow_handler_test.go:3780
↓ 112 callers
Function
GetBoolPropertyFn
(value bool)
common/dynamicconfig/setting_gen.go:38
↓ 112 callers
Function
NewGlobalDurationSetting
(key string, def time.Duration, description string)
common/dynamicconfig/setting_gen.go:572
↓ 112 callers
Method
PollActivityTaskQueue
(ctx context.Context, request *matchingservice.PollActivityTaskQueueRequest, opMetrics metrics.Handler)
service/matching/matching_engine_interfaces.go:18
↓ 112 callers
Method
Update
( runID string, targetClusterID int32, versionedTransitions []*persistencespb.VersionedTransition,
service/history/replication/progress_cache.go:25
↓ 111 callers
Method
AdminClient
()
tests/testcore/test_env.go:54
↓ 111 callers
Method
GetMetricsHandler
()
service/history/interfaces/shard_context.go:48
↓ 111 callers
Method
TaskID
()
service/history/replication/executable_task.go:56
↓ 111 callers
Method
WaitForChannel
WaitForChannel waits for ch to receive using the TestEnv context.
tests/testcore/test_env.go:459
↓ 110 callers
Method
GetNextEventID
()
service/history/interfaces/mutable_state.go:186
↓ 110 callers
Function
NewSQLDB
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 callers
Method
PollAndHandleWorkflowTask
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 callers
Function
NewRange
( inclusiveMin tasks.Key, exclusiveMax tasks.Key, )
service/history/queues/range.go:16
↓ 108 callers
Method
FailoverVersion
FailoverVersion of a Mutable State at the time of Registry creation.
service/history/workflow/update/registry.go:78
↓ 108 callers
Method
GetOutcome
()
api/persistence/v1/chasm.pb.go:693
↓ 108 callers
Function
NewDynamicConfig
()
service/history/tests/vars.go:160
↓ 107 callers
Function
TimePtr
(t time.Time)
common/primitives/timestamp/time.go:9
↓ 107 callers
Method
pollWftAndHandle
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 callers
Method
CloseTransaction
()
service/history/interfaces/chasm_tree.go:19
↓ 106 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/tasks/task_mock.go:88
↓ 106 callers
Method
GetNamespaceEntry
()
service/history/interfaces/mutable_state.go:171
↓ 106 callers
Method
Go
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 callers
Function
NewNamespaceIntSetting
(key string, def int, description string)
common/dynamicconfig/setting_gen.go:181
↓ 106 callers
Method
Skip
(extraSkip int)
common/log/interface.go:45
↓ 105 callers
Method
verifyWorkflowVersioning
(env *testcore.TestEnv, tv *testvars.TestVars, behavior enumspb.VersioningBehavior, deployment *deploymentp
tests/versioning_3_test.go:4484
↓ 104 callers
Method
BuildID
()
common/testing/testvars/test_vars.go:222
↓ 104 callers
Method
DeploymentVersion
()
common/testing/testvars/test_vars.go:248
↓ 104 callers
Function
NewMockRegistry
NewMockRegistry creates a new mock instance.
common/namespace/registry_mock.go:32
↓ 104 callers
Function
Run
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 callers
Method
TaskPoller
()
tests/testcore/test_env.go:407
↓ 103 callers
Method
GetNamespaceInfo
( ctx context.Context, namespaceID string, businessID string, )
service/history/replication/executable_task.go:80
↓ 103 callers
Method
GetTimeSource
()
service/history/interfaces/shard_context.go:49
↓ 103 callers
Function
NewUnsafeSQLString
(val string)
common/persistence/visibility/store/query/util.go:72
↓ 102 callers
Method
SignalWorkflowExecution
(ctx context.Context, request *historyservice.SignalWorkflowExecutionRequest)
service/history/interfaces/engine.go:43
↓ 101 callers
Method
GetEventId
()
chasm/lib/workflow/gen/workflowpb/v1/state.pb.go:167
↓ 101 callers
Function
addWorkflowExecutionStartedEvent
(ms historyi.MutableState, workflowExecution *commonpb.WorkflowExecution, workflowType, taskQueue string, inp
service/history/history_engine_test.go:6668
↓ 100 callers
Function
GetBoolPropertyFnFilteredByNamespace
(value bool)
common/dynamicconfig/setting_gen.go:55
↓ 100 callers
Method
HasNext
HasNext return whether this iterator has next value
common/collection/iterator.go:7
↓ 100 callers
Function
NewHostInfoFromAddress
NewHostInfoFromAddress creates a new HostInfo instance from a socket address.
common/membership/hostinfo.go:14
↓ 100 callers
Method
NewTimer
(d time.Duration)
common/clock/time_source.go:14
↓ 100 callers
Function
NewVersionHistory
NewVersionHistory create a new instance of VersionHistory.
common/persistence/versionhistory/version_history.go:10
↓ 100 callers
Method
Remove
Remove pop an item from the queue
common/collection/interface.go:11
↓ 100 callers
Method
println
(f string, args ...any)
cmd/tools/protoc-gen-go-chasm/main.go:33
↓ 99 callers
Function
ConvertError
( operation string, err error, )
common/persistence/nosql/nosqlplugin/cassandra/gocql/errors.go:15
↓ 99 callers
Function
NewTimerDef
(name string, opts ...Option)
common/metrics/defs.go:22
↓ 98 callers
Method
Size
()
service/history/replication/executable_task_tracker.go:37
↓ 98 callers
Function
file_temporal_server_api_adminservice_v1_request_response_proto_rawDescGZIP
()
api/adminservice/v1/request_response.pb.go:6361
↓ 97 callers
Method
DescribeMutableState
(ctx context.Context, request *historyservice.DescribeMutableStateRequest)
service/history/interfaces/engine.go:31
↓ 97 callers
Function
MustEncodeValue
MustEncodeValue encodes search attribute value and IndexedValueType to Payload. Panics if it fails to encode.
common/searchattribute/sadefs/encode_value.go:27
↓ 97 callers
Function
TestLocalMutableState
( shard historyi.ShardContext, eventsCache events.Cache, ns *namespace.Namespace, workflowID string, runI
service/history/workflow/test_util.go:19
↓ 96 callers
Method
Advance
Advance the timer by the specified duration.
common/clock/event_time_source.go:118
↓ 96 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/tasks/task_mock.go:40
↓ 96 callers
Method
GetDeploymentVersion
()
api/taskqueue/v1/message.pb.go:139
↓ 96 callers
Method
StopCapture
StopCapture stops capturing metrics for the given capture instance.
common/metrics/metricstest/capture_handler.go:78
↓ 96 callers
Function
mkRedirectRule
(source, target string)
service/matching/version_rule_test.go:102
↓ 95 callers
Method
GetShardByNamespaceWorkflow
(namespaceID namespace.ID, workflowID string)
service/history/shard/controller.go:18
↓ 94 callers
Function
StringTag
(key string, value string)
common/metrics/tags.go:442
↓ 94 callers
Method
Unmarshal
Unmarshal an object of type Task from the protobuf v3 wire format
api/adminservice/v1/request_response.go-helpers.pb.go:532
↓ 93 callers
Function
GetDurationPropertyFn
(value time.Duration)
common/dynamicconfig/setting_gen.go:582
↓ 93 callers
Method
GetExecutions
()
api/adminservice/v1/request_response.pb.go:5574
↓ 92 callers
Method
ClusterName
()
tests/testcore/test_cluster.go:622
↓ 92 callers
Method
Deployment
[cleanup-wv-pre-release]
common/testing/testvars/test_vars.go:241
↓ 92 callers
Function
DurationFromDays
(d int32)
common/primitives/timestamp/duration.go:49
↓ 92 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/interfaces/shard_context_mock.go:64
↓ 92 callers
Method
GetState
()
common/archiver/history_iterator.go:28
↓ 92 callers
Function
NewSAColumn
(alias string, fieldName string, valueType enumspb.IndexedValueType)
common/persistence/visibility/store/query/util.go:80
↓ 91 callers
Method
Host
TODO (alex): expose only needed objects from TemporalImpl.
tests/testcore/test_cluster.go:610
↓ 91 callers
Method
generate
(methodName string, request ...any)
common/persistence/faultinjection/fault_generator.go:5
↓ 90 callers
Method
Equals
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 callers
Function
NewMutableContext
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 callers
Method
StartActivityExecution
(ctx context.Context, req *workflowservice.StartActivityExecutionRequest)
chasm/lib/activity/frontend.go:26
↓ 89 callers
Function
file_temporal_server_api_matchingservice_v1_request_response_proto_rawDescGZIP
()
api/matchingservice/v1/request_response.pb.go:6318
↓ 88 callers
Function
NewData
( state State, )
service/history/hsm/hsmtest/sm.go:28
← previous
next →
201–300 of 43,335, ranked by callers