Skip to content
actor-ts
Search
Ctrl
K
Cancel
GitHub
Select theme
Dark
Light
Auto
Select language
English
Deutsch
Get Started
What is actor-ts?
Why actors?
Installation
Quickstart
Learning path
Glossary
Build Actors
Fundamentals
Overview
Actor
Messages
Ask pattern
ActorSystem
Actor paths
Props
Become and stash
Death watch
Supervision
Dispatchers
Mailboxes
Timers and scheduling
Receive timeout
Coordinated shutdown
Event stream
Logging
PoisonPill and Kill
Pattern matching
Typed actors
Overview
TypedActor
Behaviors
Spawning typed
Routing
Overview
Router
Strategies
Pool vs group
Patterns
Circuit breaker
Backoff supervisor
Backoff policy
Retry
Future patterns
Distribute
Cluster
Overview
Joining and seeds
Failure detector
Downing strategies
Transports
Weakly-up
Refs across nodes
Distributed PubSub
Singleton
Overview
Manager
With lease
Sharding
Overview
Allocation strategy
Rebalance
Remember entities
With lease
Sharded daemon
Cluster router
Cluster client
Cluster security
Worker mesh
Distributed Data
Overview
CRDT types
Counters
Registers
Sets
Maps
Designing data
Replication
Quorum reads/writes
Durable storage
Coordination
Overview
Lease API
In-memory lease
Kubernetes lease
Discovery
Overview
Seed providers
Config
DNS
Kubernetes API
Aggregate
Receptionist
Persist
Event sourcing
Overview
PersistentActor
Event dispatcher
Snapshots
Durable state
Projections
Persistence query
Push-based query
Journals
In-memory
SQLite
Cassandra
Snapshot stores
In-memory
SQLite
Cached snapshot store
Replicated event sourcing
Overview
Single-writer lease
Vector clocks
Conflict resolver
Snapshotting
Object storage
Overview
Compression
Encryption
Key rotation
Per-actor policies
Snapshot store backend
Migration
Overview
Recipes
Schema registry
Envelope format
Defaults adapter
Migrating adapter
Wrap legacy
FSM
Overview
In-memory FSM
Persistent FSM
Delivery
Overview
Producer controller
Consumer controller
Ack semantics
Integrate
IO (brokers)
Overview
BrokerActor base
Kafka
MQTT
AMQP
NATS
Redis Streams
gRPC
SSE
WebSocket client
WebSocket server
TCP
UDP
HTTP
Overview
Route DSL
Marshalling
Backends
Fastify
Express
Hono
Middleware
Response cache
Rate limit
Idempotency key
Cache
Overview
In-memory
Memcached
Redis
Serialization
Overview
JSON
CBOR
Custom serializers
Observe
Overview
Metrics
Core metrics
Prometheus exporter
prom-client adapter
OTel adapter
Stock metrics
Tracing
Tracer API
OTel adapter
Recording tracer
Actor tracing
Management
Overview
Health checks
HTTP endpoints
Test
Overview
TestKit
TestProbe
ManualScheduler
MultiNodeSpec
ParallelMultiNodeSpec
Operate
Overview
Deployment
Kubernetes
Docker Compose
Process manager
Tuning
Gossip cadence
Failure detector
Mailbox sizing
Dispatcher tuning
Security
Cluster security
Master key rotation
TLS everywhere
Upgrades
Rolling migration
Upgrade strategies
Troubleshooting
Runtime
Overview
Compatibility matrix
Bun
Node
Deno
Examples
Overview
Chat sample
Voice sample
Stand-alone snippets
Migration
Overview
From Akka (JVM)
From Pekko
From Orleans
From Akka.NET
From vanilla TS
Reference
Configuration
Version policy
FAQ
Glossary
API Reference
Enumerations
Directive
LogLevel
Classes
Actor
ActorInitializationError
ActorKilledError
ActorPath
ActorRef
ActorSelection
ActorSystem
ActorSystemTerminateReason
AggregateSeedProvider
AllForOneStrategy
AmqpActor
AskTimeoutError
BackoffSupervisor
BoundedMailbox
Broadcast
BrokerActor
BrokerBufferOverflow
BrokerConnected
BrokerDisconnected
BrokerNotConnected
BrokerReconnectAttempt
BrokerReconnectFailed
BrokerSettingsError
CacheError
CacheExtension
CassandraJournal
CassandraQuery
CassandraRememberEntitiesStore
CassandraSnapshotStore
CborDecodeError
CborDecoder
CborEncodeError
CborEncoder
CborSerializer
CircuitBreaker
CircuitBreakerOpenError
CircuitBreakerTimeoutError
Cluster
ClusterClient
ClusterClientReceptionist
ClusterDowningReason
ClusterLeavingReason
ClusterSharding
ClusterSingleton
ClusterSingletonManager
ClusterSingletonProxy
Config
ConfigError
ConfigSeedProvider
ConsoleLogger
ConsumerController
CoordinatedShutdown
CurrentTopics
CustomMergeResolver
DeadLetter
DeathPactError
DefaultMetricsRegistry
Deregister
DistributedData
DistributedPubSub
DistributedPubSubMediator
DnsSeedProvider
DurableStateActor
DurableStateConcurrencyError
DurableStateOffsetStore
EventStream
ExpressBackend
Extensions
Failure
FailureDetector
FastifyBackend
FilesystemObjectStorageBackend
Find
FSM
GCounter
GetTopics
GrpcClientActor
GrpcServerActor
GSet
HashAllocationStrategy
HealthCheckRegistry
HonoBackend
HttpClient
HttpError
HttpExtension
ImmediateDispatcher
InMemoryCache
InMemoryDurableStateStore
InMemoryJournal
InMemoryLease
InMemoryOffsetStore
InMemoryQuery
InMemorySchemaRegistry
InMemorySnapshotStore
InMemoryTransport
JetStreamActor
JournalConcurrencyError
JournalError
JournalRememberEntitiesStore
JsonSerializer
KafkaActor
KeepMajority
KeepOldest
KeepReferee
Kill
KubernetesApiSeedProvider
KubernetesLease
LastWriterWinsResolver
Lazy
LeaderChanged
LeastShardAllocationStrategy
Left
Listing
LWWRegister
MailboxFullError
ManualScheduler
Member
MemberDown
MemberJoined
MemberLeft
MemberReachable
MemberRemoved
MemberUnreachable
MemberUp
MemberWeaklyUp
MemcachedCache
MessageChannelTransport
MetricsExtension
MicrotaskDispatcher
MigrationChain
MigrationError
MqttActor
NatsActor
NobodyRef
NodeAddress
None
NoopLogger
NoopMetricsRegistry
NoopTracer
ObjectStorageBackendError
ObjectStorageConcurrencyError
ObjectStorageDurableStateStore
ObjectStorageSnapshotStore
OneForOneStrategy
ORSet
Passivate
PersistenceExtension
PersistentActor
PersistentFSM
PhiAccrualFailureDetector
PNCounter
PoisonPill
PriorityMailbox
ProcessTerminateReason
ProducerController
ProjectionActor
Props
Publish
Reason
ReceiveTimeout
Receptionist
ReceptionistExtension
ReceptionistSubscribe
ReceptionistUnsubscribe
RecordingTracer
RedisCache
RedisStreamsActor
Register
Registered
ReliableDelivery
RemoteActorRef
ReplicatedEventSourcedActor
Right
S3ObjectStorageBackend
Scheduler
SelfRemoved
SelfUp
SerializationError
SerializationExtension
ServerWebSocketActor
ServiceKey
ShardCoordinator
ShardedDaemonProcess
ShardMapChanged
ShardRegion
Some
SqliteJournal
SqliteQuery
SqliteSnapshotStore
SseActor
StashOutsideHandlerError
StashOverflowError
StaticQuorum
Subscribe
SubscribeAck
Success
TcpSocketActor
TcpTransport
Terminated
TestKit
TestProbe
ThroughputDispatcher
TracingExtension
TypedActor
UdpSocketActor
UnknownReason
Unsubscribe
UnsubscribeAck
UnsubscribeAll
VectorClock
WebSocketActor
WorkerBroker
WorkerCluster
Interfaces
Ack
ActorContext
ActorSystemSettings
AllocationStrategy
AmqpActorSettings
AmqpDelivery
AmqpPublish
AmqpQueueBinding
BackoffOptions
BackoffPolicy
BoundedMailboxSettings
BrokerCommonSettings
BrokeredMessage
BunServerWebSocketLike
BunWebSocketHandlerOptions
BunWebSocketSlot
ByPidSettings
ByTagSettings
Cache
Cancellable
CancellablePromise
CassandraBatchQuery
CassandraClientLike
CassandraConnection
CassandraJournalOptions
CassandraRememberEntitiesStoreOptions
CassandraRowResult
CassandraSnapshotStoreOptions
CircuitBreakerSettings
ClusterClientEnvelopeMsg
ClusterClientReceptionistSettings
ClusterClientReplyMsg
ClusterClientSettings
ClusterPartitionView
ClusterRouterOptions
ClusterSettings
ClusterSingletonManagerSettings
Codec
CompiledRoute
CompressionConfig
ConfigSeedProviderSettings
ConflictCandidate
ConflictResolver
ConsumerControllerSettings
ConsumerHandle
Counter
CounterOptions
Crdt
DefaultsAdapterSpec
Delivery
Dispatcher
DistributedDataSettings
DistributedPubSubSettings
DnsSeedProviderSettings
DowncastStep
DowningProvider
DurableStateRecord
DurableStateSettings
DurableStateStore
EmptyBehavior
EventAdapter
ExponentialBackoffOptions
ExpressBackendOptions
Extension
ExtensionId
FailureDetectorSettings
FilesystemObjectStorageOptions
FsmStateData
FsmStay
FsmTransition
Gauge
GaugeOptions
GCounterJson
GrpcBidiCall
GrpcClientActorSettings
GrpcServerSettings
GrpcServerStreamCall
GrpcUnaryCall
GSetJson
HealthCheckResult
Histogram
HistogramOptions
HonoBackendOptions
HttpClientRequest
HttpClientResponse
HttpRequest
HttpResponse
HttpServerBackend
IdempotencyOptions
IgnoreBehavior
JetStreamActorSettings
JetStreamClientLike
JetStreamConsumerConfig
JetStreamManagerLike
JetStreamMessage
JetStreamMsgHandleLike
JetStreamMsgInfoLike
JetStreamPublish
JetStreamStreamConfig
JetStreamSubscriptionLike
Journal
JournalEnvelope
KafkaActorSettings
KafkaPublish
KafkaRecord
KeepMajoritySettings
KeepOldestSettings
KeepRefereeSettings
KubernetesApiSeedProviderSettings
KubernetesLeaseSettings
Lease
LeaseSettings
LinearBackoffOptions
LiveQueryOptions
LoadOptions
Logger
LWWRegisterJson
ManagementRoutesSettings
MemberData
MemcachedCacheOptions
MemcachedClientLike
MetricSample
MetricsRegistry
MigrationStep
MqttActorSettings
MqttCredentials
MqttMessage
MqttPublish
MqttSubscription
NatsActorSettings
NatsConnectionLike
NatsMessage
NatsPublish
NodeAddressData
ObjectFetched
ObjectInfo
ObjectStorageBackend
ObjectStorageDurableStateStoreOptions
ObjectStoragePluginHandles
ObjectStoragePluginOptions
ObjectStorageSnapshotStoreOptions
Offset
OffsetStore
ORSetJson
OtelAdapterOptions
OtelApiLike
OtelContextApi
OtelContextLike
OtelPropagationApi
OtelSpanContextLike
OtelSpanLike
OtelTraceApi
OtelTracerLike
OutboundEnvelope
ParserLike
PersistenceQuery
PersistentEvent
PersistentFsmTransition
PhaseDefinition
PhiAccrualSettings
PipeToOptions
PNCounterJson
PortLike
PriorityMailboxSettings
ProducerControllerSettings
ProducerHandle
ProducerSend
ProjectionSettings
PromClientAdapterOptions
PromClientCounter
PromClientGauge
PromClientHistogram
PromClientLabelValues
PromClientLike
PromClientRegistryLike
PropsConfig
PutOptions
RateLimitContext
RateLimitOptions
ReceiveBehavior
ReceptionistGossipMsg
ReceptionistSettings
RecordedSpan
RecordingTracerOptions
RedisCacheOptions
RedisClientLike
RedisStreamEntry
RedisStreamPublish
RedisStreamsActorSettings
RegisterCassandraPluginsOptions
RememberEntitiesStore
ReplicatedEventEnvelope
ResponseCacheOptions
RetryOptions
RouteRegistration
RouterState
S3ClientLike
S3Credentials
S3ObjectStorageOptions
SameBehavior
SchemaDescriptor
SchemaRegistration
SchemaRegistry
SeedProvider
SerializedValue
Serializer
ServerBinding
ServerBuilder
ServerWebSocketActorOptions
ServerWebSocketLike
SetupBehavior
ShardCoordinatorSettings
ShardedDaemonProcessHandle
ShardedDaemonProcessSettings
ShardingSettings
SingletonDeliver
SingletonHandle
Snapshot
SnapshotAdapter
SnapshotStore
Span
SpanContext
SpanOptions
SseActorSettings
SseEvent
StartSettings
StartSingletonSettings
StashBuffer
StaticQuorumSettings
StoppedBehavior
StrategyOptions
SuperviseBehavior
SuperviseBuilder
SupervisorStrategy
TagFilterSpec
TaggedEvent
TcpSocketActorSettings
TestKitOptions
TestProbeOptions
TimerScheduler
TlsTransportSettings
TraceCarrier
Tracer
Transport
TypedActorContext
UdpDatagram
UdpOutbound
UdpSocketActorSettings
UnhandledBehavior
ValidatedAdapterOptions
WebSocketActorSettings
WithStashBehavior
WithTimersBehavior
WorkerClusterSettings
WorkerHandle
WorkerInitMessage
WorkerNodeContext
WorkerReadyMessage
Type Aliases
ActorFactory
AmqpCmd
AttributeValue
Behavior
BoundedMailboxOverflow
CircuitState
ClusterEvent
ClusterRouterType
CompressionAlgo
CompressionResolver
ConfigObject
ConfigValue
ConfirmationCallback
ConnectionState
CrdtFactory
CrdtJson
Decider
DowningDecision
Either
EncryptionConfig
EncryptionResolver
FailureDecision
ForwardStrategy
FsmResult
FsmStateHandler
FsmTransitionCallback
FsmTransitionMap
GrpcClientCmd
GrpcCredentials
GrpcHandler
GrpcInbound
HealthCheckFn
HttpMethod
JetStreamCmd
KafkaCmd
Labels
LabelValue
LogContextData
MemberStatus
MqttCmd
MqttQos
NatsCmd
ObjectStorageBackendSpec
Option
PriorityFunction
Receive
RedisStreamsCmd
RememberEvent
ReplicaId
ResetCounter
RestartPolicy
Route
RoutingStrategy
ShardAllocator
ShutdownTask
Signal
SnapshotPolicy
SpanKind
SpanStatus
SseCmd
StateAdapter
TagFilter
TcpFraming
TcpOutbound
TcpSocketCmd
Try
UdpSocketCmd
VectorClockData
VectorClockOrder
WebSocketCmd
WebSocketFrame
WireHandler
WireMessage
Variables
Behaviors
CacheExtensionId
CASSANDRA_JOURNAL_PLUGIN_ID
CASSANDRA_SNAPSHOT_PLUGIN_ID
ClusterClientReceptionistId
ClusterRouter
ClusterSingletonId
CoordinatedShutdownId
DEFAULT_HISTOGRAM_BUCKETS
DEFAULT_OUTBOUND_BUFFER
DEFAULT_RECONNECT
defaultFailureDetectorSettings
defaultPhiAccrualSettings
defaultStrategy
Dispatchers
DistributedDataId
DistributedPubSubId
escalatingStrategy
HttpExtensionId
IN_MEMORY_CACHE_PLUGIN_ID
inMemoryLeaseStore
lazy
LogContext
MEMCACHED_CACHE_PLUGIN_ID
MetricsExtensionId
moduloAllocator
Nobody
none
NOOP_TRACER
OBJECT_STORAGE_DURABLE_STATE_PLUGIN_ID
OBJECT_STORAGE_SNAPSHOT_PLUGIN_ID
offsetStart
PersistenceExtensionId
Phases
ReceptionistId
REDIS_CACHE_PLUGIN_ID
REFERENCE_CONF
rendezvousAllocator
Router
SerializationExtensionId
Status
stoppingStrategy
TracingExtensionId
WorkerNode
Functions
after
ask
broadcastStrategy
bunWebSocketHandlers
cached
compile
complete
completeJson
completeText
composeCodecs
compressionByPrefix
concat
createCassandraClient
decideBy
decodeTraceparent
deepMerge
defaultsAdapter
defaultsSnapshotAdapter
del
eitherOf
eitherSequence
empty
encodeTraceparent
encryptionByPrefix
entity
eventMatchesTagFilter
everyNEvents
exponentialBackoff
exportPrometheus
extensionId
failure
firstSome
fromNullable
fromPredicate
get
hashShardId
head
idempotent
ignore
inMemoryTransport
isHealthy
jsonCodec
keyspaceDdl
left
linearBackoff
managementRoutes
marshal
matchesMqttPattern
mediatorPath
metricsOf
migratingAdapter
migratingSnapshotAdapter
newSpanId
newTraceId
normalizeTagFilter
offsetCompare
offsetGreater
offsetGreaterOrEqual
offsetOfEvent
options
otelTracer
parseDuration
parseHocon
parseSelectionPath
parseSize
patch
path
pathParam
pathPrefix
pickRendezvous
pickRequestSerializer
pickResponseSerializer
pipeTo
post
promClientRegistry
prometheusHandler
put
queryParam
randomStrategy
rateLimit
redirect
registerCassandraPlugins
registerObjectStoragePlugins
reject
rememberEntitiesDdl
resolveCompression
resolveEncryption
resolveSubstitutions
retry
right
roundRobinStrategy
same
seedsFromEnv
serverWebSocketActorOf
singletonManagerPath
some
spawnTyped
spawnTypedChild
stopped
success
tracerOf
tryOf
trySequence
typedProps
unhandled
validatedEventAdapter
validatedSnapshotAdapter
zodCodec
Extras
Design decisions
Architecture Decision Records
GitHub
Select theme
Dark
Light
Auto
Select language
English
Deutsch
otelTracer
otelTracer
(
opts
):
Tracer
Defined in:
src/tracing/OtelAdapter.ts:120
Parameters
Section titled “Parameters”
opts
Section titled “opts”
OtelAdapterOptions
Returns
Section titled “Returns”
Tracer