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
↓ 1 callers
Method
ShrinkScope
()
service/history/queues/slice.go:305
↓ 1 callers
Method
ShutdownWorker
( ctx context.Context, request *workflowservice.ShutdownWorkerRequest, opts ...grpc.CallOption, )
client/frontend/client_gen.go:952
↓ 1 callers
Method
SignalInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:85
↓ 1 callers
Function
SignalWithStartWorkflow
( ctx context.Context, shard historyi.ShardContext, namespaceEntry *namespace.Namespace, currentWorkflowLe
service/history/api/signalwithstartworkflow/signal_with_start_workflow.go:22
↓ 1 callers
Method
SilenceAlert
(AlertType)
service/history/queues/monitor.go:40
↓ 1 callers
Method
Since
Since returns the time elapsed since t
common/clock/time_source.go:43
↓ 1 callers
Method
Size
()
service/history/tasks/predicates.go:64
↓ 1 callers
Method
Size
()
service/history/tasks/predicates.go:103
↓ 1 callers
Method
Size
()
service/history/tasks/predicates.go:142
↓ 1 callers
Method
Size
()
service/history/tasks/predicates.go:177
↓ 1 callers
Method
Size
()
service/history/tasks/predicates.go:227
↓ 1 callers
Method
Size
Size returns the size of the object, in bytes, once serialized
api/adminservice/v1/request_response.go-helpers.pb.go:2979
↓ 1 callers
Method
Size
Size returns the size of the object, in bytes, once serialized
api/persistence/v1/executions.go-helpers.pb.go:685
↓ 1 callers
Method
Size
Size returns the size of the object, in bytes, once serialized
api/persistence/v1/executions.go-helpers.pb.go:722
↓ 1 callers
Method
Size
Size returns the size of the object, in bytes, once serialized
api/persistence/v1/executions.go-helpers.pb.go:759
↓ 1 callers
Method
Size
Size returns the size of the object, in bytes, once serialized
api/persistence/v1/executions.go-helpers.pb.go:796
↓ 1 callers
Method
SkipRate
()
service/matching/counter/cmsketch.go:104
↓ 1 callers
Method
Snapshot
Snapshot returns all nodes in the tree that have been modified after the given min versioned transition. A nil exclusiveMinVT will be treated as the s
chasm/tree.go:2381
↓ 1 callers
Method
Spans
()
common/testing/testtelemetry/collector.go:56
↓ 1 callers
Method
SplitByRange
( key tasks.Key, )
service/history/queues/scope.go:38
↓ 1 callers
Method
SpoolTask
(taskInfo *persistencespb.TaskInfo)
service/matching/pri_backlog_manager.go:249
↓ 1 callers
Method
SpoolTask
(taskInfo *persistencespb.TaskInfo)
service/matching/fair_backlog_manager.go:237
↓ 1 callers
Method
SpoolTask
SpoolTask spools a task to persistence to be matched asynchronously when a poller is available.
service/matching/physical_task_queue_manager_interface.go:42
↓ 1 callers
Method
Start
Start is called to start replicator
service/worker/replicator/replicator.go:91
↓ 1 callers
Method
Start
()
service/matching/task_queue_partition_manager.go:291
↓ 1 callers
Method
Start
Start is called when the task queue partition manager for the hooks partition is started
service/matching/hooks/task_lifecycle_hooks.go:55
↓ 1 callers
Method
Start
()
service/history/replication/stream_receiver_monitor.go:29
↓ 1 callers
Method
Start
()
service/history/events/notifier.go:33
↓ 1 callers
Method
Start
Start temporal server.
temporaltest/internal/lite_server.go:305
↓ 1 callers
Method
Start
()
common/goro/example_group_test.go:15
↓ 1 callers
Method
Start
()
common/persistence/health_signal_aggregator.go:23
↓ 1 callers
Method
Start
()
common/cluster/metadata.go:63
↓ 1 callers
Method
Start
( ctx context.Context, args startArgs, options nexus.StartOperationOptions, )
chasm/lib/nexusoperation/invocation.go:57
↓ 1 callers
Method
StartBatch
StartBatch returns a BatchHandler that can emit a series of metrics as a single "wide event". If wide events aren't supported in the underlying implem
common/metrics/metrics.go:41
↓ 1 callers
Function
StartMemoryCollector
(tb testing.TB)
common/testing/testtelemetry/collector.go:26
↓ 1 callers
Method
StartOperation
(ctx context.Context, service, operation string, input *nexus.LazyValue, options nexus.StartOperationOptions)
common/nexus/nexusrpc/cancel_test.go:18
↓ 1 callers
Method
StartWorkerDeployment
Used internally by the Worker Deployment Version workflow in its StartWorkerDeployment Activity Deprecated.
service/worker/workerdeployment/client.go:157
↓ 1 callers
Method
StartWorkerDeploymentVersion
Used internally by the Worker Deployment workflow in its StartWorkerDeploymentVersion Activity
service/worker/workerdeployment/client.go:166
↓ 1 callers
Method
State
()
common/circuitbreaker/circuitbreaker.go:14
↓ 1 callers
Method
StateMachineState
StateMachineState returns the current status of the activity.
chasm/lib/activity/statemachine.go:24
↓ 1 callers
Method
Stop
Stop stops the server.
temporal/fx.go:339
↓ 1 callers
Method
Stop
Stop stops the scavenger
service/worker/scanner/executions/scavenger.go:120
↓ 1 callers
Method
Stop
()
service/history/replication/stream_receiver_monitor.go:90
↓ 1 callers
Method
Stop
()
service/history/replication/stream_sender.go:45
↓ 1 callers
Method
Stop
()
service/history/events/notifier.go:34
↓ 1 callers
Method
Stop
()
service/history/interfaces/engine.go:110
↓ 1 callers
Method
Stop
Stop halts any background processing, and should be called when the cache will no longer be used.
common/cache/cache.go:42
↓ 1 callers
Method
StreamInterceptor
StreamInterceptor returns a gRPC stream client interceptor that captures stream messages
tests/testcore/replication_stream_recorder.go:191
↓ 1 callers
Method
StreamWorkflowReplicationMessages
(ctx context.Context, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:293
↓ 1 callers
Method
String
String converts the config object into a string
common/config/config.go:716
↓ 1 callers
Function
StringVariable
StringVariable returns a [Component] that represents a string variable in a Route.
common/routing/route.go:130
↓ 1 callers
Method
SubscribeNotification
(string)
service/history/replication/ack_manager.go:37
↓ 1 callers
Function
SuggestContinueAsNewReasonHistorySizeTooLargeTag
(present bool)
common/metrics/tags.go:503
↓ 1 callers
Function
SuggestContinueAsNewReasonTooManyHistoryEventsTag
(present bool)
common/metrics/tags.go:495
↓ 1 callers
Function
SuggestContinueAsNewReasonTooManyUpdatesTag
(present bool)
common/metrics/tags.go:487
↓ 1 callers
Method
SupportedMethods
()
common/authorization/token_key_provider.go:17
↓ 1 callers
Method
Swap
Swap implements sort.Interface.
service/history/tasks/key.go:131
↓ 1 callers
Method
SyncVersionWorkflowFromWorkerDeployment
Used internally by the Worker Deployment workflow in its SyncWorkerDeploymentVersion Activity
service/worker/workerdeployment/client.go:174
↓ 1 callers
Function
TLSCertFile
TLSCertFile returns tag for TLS cert file name
common/log/tag/tags.go:961
↓ 1 callers
Function
TLSCertFiles
TLSCertFiles returns tag for TLS cert file names
common/log/tag/tags.go:971
↓ 1 callers
Function
TLSKeyFile
TLSKeyFile returns tag for TLS key file
common/log/tag/tags.go:966
↓ 1 callers
Method
TagRPC
(ctx context.Context, info *stats.RPCTagInfo)
common/telemetry/grpc.go:88
↓ 1 callers
Function
TaskAddResultTag
(result string)
common/metrics/tags.go:333
↓ 1 callers
Method
TaskCreationTime
()
service/history/replication/executable_task_tracker.go:25
↓ 1 callers
Method
TaskIDFor
TaskIDFor converts registered task instance to task type ID. This method should only be used by CHASM framework internal code, NOT CHASM library devel
chasm/registry.go:174
↓ 1 callers
Method
TaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:88
↓ 1 callers
Method
TaskInfoToBlob
(info *persistencespb.AllocatedTaskInfo)
common/persistence/serialization/serializer.go:49
↓ 1 callers
Method
TaskOf
(taskGoType reflect.Type)
chasm/export_test.go:28
↓ 1 callers
Method
TaskQueue
()
common/testing/testvars/test_vars.go:300
↓ 1 callers
Method
TaskQueueUserDataToBlob
(info *persistencespb.TaskQueueUserData)
common/persistence/serialization/serializer.go:51
↓ 1 callers
Function
TaskSourceTag
(source enumsspb.TaskSource)
common/metrics/tags.go:313
↓ 1 callers
Function
TearDownCassandraKeyspace
(t *testing.T, cfg *config.Cassandra)
common/persistence/tests/cassandra_test_util.go:139
↓ 1 callers
Method
TearDownTest
()
service/frontend/operator_handler_test.go:93
↓ 1 callers
Method
TearDownTest
()
service/history/history_engine2_test.go:242
↓ 1 callers
Method
TearDownTest
()
service/history/history_engine_test.go:243
↓ 1 callers
Function
TemporalFailureToNexusFailureInPlace
TemporalFailureToNexusFailureInPlace converts an API proto Failure to a Nexus SDK Failure setting the metadata "type" field to the proto fullname of t
common/nexus/failure.go:109
↓ 1 callers
Method
Terminate
Terminate implements the chasm.RootComponent interface.
chasm/lib/activity/activity.go:557
↓ 1 callers
Method
TerminateWorkflowExecution
TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event in the history and immediately ter
service/frontend/workflow_handler.go:2428
↓ 1 callers
Function
TestClient
TestClient works by doing the following: 1. Enqueue some tasks 2. Start a server which serves the DLQ endpoints 3. Create a client which connects to t
client/history/historytest/clienttest.go:48
↓ 1 callers
Method
TestCreateFromMigrationState
(ctx context.Context, req *schedulerpb.CreateFromMigrationStateRequest)
chasm/lib/scheduler/export_test.go:20
↓ 1 callers
Function
TestInvoke
TestInvoke is a library test function intended to be invoked from a persistence test suite. It works by enqueueing a task into the DLQ and then callin
service/history/api/getdlqtasks/getdlqtaskstest/apitest.go:19
↓ 1 callers
Function
TestInvoke
TestInvoke is a library test function intended to be invoked from a persistence test suite. It works by enqueueing a task into the DLQ and then callin
service/history/api/listqueues/listqueuestest/apitest.go:19
↓ 1 callers
Function
TestInvoke
(t *testing.T, manager persistence.HistoryTaskQueueManager)
service/history/api/deletedlqtasks/deletedlqtaskstest/apitest.go:19
↓ 1 callers
Method
TestMigrateToWorkflow
(ctx context.Context, req *schedulerpb.MigrateToWorkflowRequest)
chasm/lib/scheduler/export_test.go:24
↓ 1 callers
Method
TimeSinceLastPoll
()
service/matching/matcher_data.go:588
↓ 1 callers
Method
TimerInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:87
↓ 1 callers
Method
TimerTaskInfoToBlob
(info *persistencespb.TimerTaskInfo)
common/persistence/serialization/serializer.go:61
↓ 1 callers
Function
TimerTaskStatus
TimerTaskStatus returns tag for TimerTaskStatus
common/log/tag/tags.go:665
↓ 1 callers
Method
TlsConfigProvider
()
tests/testcore/onebox.go:660
↓ 1 callers
Function
ToPersistenceAndPredicate
( andPredicate *predicates.AndImpl[tasks.Task], )
service/history/queues/convert.go:191
↓ 1 callers
Function
ToPersistenceDestinationPredicate
( taskDestinationPredicate *tasks.DestinationPredicate, )
service/history/queues/convert.go:306
↓ 1 callers
Function
ToPersistenceEmptyPredicate
( _ *predicates.EmptyImpl[tasks.Task], )
service/history/queues/convert.go:176
↓ 1 callers
Function
ToPersistenceNamespaceIDPredicate
( namespaceIDPredicate *tasks.NamespacePredicate, )
service/history/queues/convert.go:268
↓ 1 callers
Function
ToPersistenceNotPredicate
( notPredicate *predicates.NotImpl[tasks.Task], )
service/history/queues/convert.go:249
↓ 1 callers
Function
ToPersistenceOrPredicate
( orPredicate *predicates.OrImpl[tasks.Task], )
service/history/queues/convert.go:220
↓ 1 callers
Function
ToPersistenceOutboundTaskGroupPredicate
( pred *tasks.OutboundTaskGroupPredicate, )
service/history/queues/convert.go:325
↓ 1 callers
Function
ToPersistenceOutboundTaskPredicate
( pred *tasks.OutboundTaskPredicate, )
service/history/queues/convert.go:344
↓ 1 callers
Function
ToPersistenceTaskTypePredicate
( taskTypePredicate *tasks.TypePredicate, )
service/history/queues/convert.go:287
↓ 1 callers
Function
ToPersistenceUniversalPredicate
( _ *predicates.UniversalImpl[tasks.Task], )
service/history/queues/convert.go:161
↓ 1 callers
Method
ToStrings
(payloads *commonpb.Payloads)
tests/testcore/test_data_converter.go:83
← previous
next →
10,601–10,700 of 43,335, ranked by callers