跳转到内容
actor-ts
搜索
Ctrl
K
取消
GitHub
选择主题
深色
浅色
自动
简体中文
English
Deutsch
Español
Français
日本語
한국어
Português (BR)
Русский
简体中文
🚀 快速开始
什么是 actor-ts?
为什么选择 Actor?
安装
快速上手
学习路径
术语表
🎭 构建 Actor
基础
概览
Actor
消息
Ask 模式
ActorSystem
Actor 路径
Props
Become 与 Stash
Death watch
监督
Dispatchers
Mailboxes
定时器与调度
Receive timeout
协调关闭
事件流
日志
PoisonPill 与 Kill
模式匹配
类型化 Actor
概览
TypedActor
Behaviors
创建类型化 Actor
路由
概览
Router
策略
Pool 与 Group
模式
Circuit Breaker
Backoff 监督者
Backoff 策略
Retry
Future 模式
🌐 分布式
Cluster
概览
加入集群与种子节点
Failure detector
下线策略
传输层
Weakly-up
跨节点引用
Distributed PubSub
Singleton
概览
管理器
基于 Lease
Sharding
概览
分配策略
再平衡
记住实体
基于 Lease
分片守护进程
Cluster router
Cluster client
集群安全
工作节点网格
Distributed Data
概览
CRDT 类型
Counters
Registers
Sets
Maps
数据设计
复制
Quorum 读写
持久化存储
协调
概览
Lease API
内存 Lease
Kubernetes Lease
服务发现
概览
种子节点提供者
配置
DNS
Kubernetes API
聚合
Receptionist
💾 持久化
事件溯源
概览
PersistentActor
事件分发器
Snapshots
持久化状态
投影
持久化查询
基于推送的查询
事件日志
内存
SQLite
Cassandra
PostgreSQL
MariaDB
快照存储
内存
SQLite
带缓存的快照存储
复制式事件溯源
概览
单写者 Lease
Vector clocks
冲突解决器
快照机制
对象存储
概览
压缩
加密
密钥轮换
按 Actor 策略
快照存储后端
迁移
概览
实用方案
Schema 注册中心
信封格式
默认适配器
迁移适配器
包装遗留代码
FSM
概览
内存 FSM
持久化 FSM
投递
概览
生产者控制器
消费者控制器
Ack 语义
🔌 集成
IO (消息代理)
概览
BrokerActor base
Kafka
MQTT
AMQP
NATS
Redis Streams
gRPC
SSE
WebSocket 客户端
WebSocket 服务端
TCP
UDP
HTTP
概览
路由 DSL
编解码
后端
Fastify
Express
Hono
中间件
响应缓存
限流
幂等键
缓存
概览
内存
Memcached
Redis
序列化
概览
JSON
CBOR
自定义序列化器
📊 可观测性
概览
指标
核心指标
Prometheus 导出器
prom-client 适配器
OTel 适配器
内置指标
链路追踪
Tracer API
OTel 适配器
记录式 Tracer
Actor 追踪
管理
概览
健康检查
HTTP 端点
✅ 测试
概览
TestKit
TestProbe
ManualScheduler
MultiNodeSpec
ParallelMultiNodeSpec
⚙️ 运维
概览
部署
Kubernetes
Docker Compose
进程管理器
调优
Gossip 频率
Failure detector
Mailbox 容量配置
Dispatcher 调优
安全
集群安全
主密钥轮换
全链路 TLS
升级
滚动迁移
升级策略
故障排查
运行时
概览
兼容性矩阵
Bun
Node
Deno
💡 示例
概览
聊天示例
语音示例
独立代码片段
🚚 迁移
概览
从 Akka (JVM) 迁移
从 Pekko 迁移
从 Orleans 迁移
从 Akka.NET 迁移
从原生 TypeScript 迁移
📖 参考
配置
版本策略
FAQ
术语表
🧰 API 参考
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
JsonLogger
JsonSerializer
KafkaActor
KeepMajority
KeepOldest
KeepReferee
Kill
KubernetesApiSeedProvider
KubernetesLease
LastWriterWinsResolver
Lazy
LeaderChanged
LeastShardAllocationStrategy
Left
Listing
LWWRegister
MailboxFullError
ManualScheduler
MariaDbDurableStateStore
MariaDbJournal
MariaDbSnapshotStore
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
PostgresDurableStateStore
PostgresJournal
PostgresSnapshotStore
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
AutoDiscoverySettings
BackoffOptions
BackoffPolicy
BearerTokenAuthOptions
BootstrappedCluster
BoundedMailboxSettings
BrokerCommonSettings
BrokeredMessage
BunServerWebSocketLike
BunWebSocketHandlerOptions
BunWebSocketSlot
ByPidSettings
ByTagSettings
Cache
Cancellable
CancellablePromise
CassandraBatchQuery
CassandraClientLike
CassandraConnection
CassandraJournalOptions
CassandraRememberEntitiesStoreOptions
CassandraRowResult
CassandraSnapshotStoreOptions
CircuitBreakerSettings
ClusterBootstrapOptions
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
IpAllowlistOptions
JetStreamActorSettings
JetStreamClientLike
JetStreamConsumerConfig
JetStreamManagerLike
JetStreamMessage
JetStreamMsgHandleLike
JetStreamMsgInfoLike
JetStreamPublish
JetStreamStreamConfig
JetStreamSubscriptionLike
Journal
JournalEnvelope
JsonLogSink
KafkaActorSettings
KafkaPublish
KafkaRecord
KeepMajoritySettings
KeepOldestSettings
KeepRefereeSettings
KubernetesApiSeedProviderSettings
KubernetesLeaseSettings
Lease
LeaseSettings
LinearBackoffOptions
LiveQueryOptions
LoadOptions
Logger
LWWRegisterJson
ManagementRoutesSettings
MariaDbConnection
MariaDbConnectionLike
MariaDbDurableStateStoreOptions
MariaDbJournalOptions
MariaDbPluginHandles
MariaDbPoolLike
MariaDbSnapshotStoreOptions
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
OtelLoggerAdapterOptions
OtelLoggerLike
OtelLoggerProviderLike
OtelLogRecord
OtelLogsApiLike
OtelPropagationApi
OtelSeverityNumber
OtelSpanContextLike
OtelSpanLike
OtelTraceApi
OtelTracerLike
OutboundEnvelope
ParserLike
PersistenceQuery
PersistentEvent
PersistentFsmTransition
PgClientLike
PgPoolLike
PhaseDefinition
PhiAccrualSettings
PipeToOptions
PNCounterJson
PortLike
PostgresConnection
PostgresDurableStateStoreOptions
PostgresJournalOptions
PostgresPluginHandles
PostgresSnapshotStoreOptions
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
RegisterMariaDbPluginsOptions
RegisterPostgresPluginsOptions
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
Middleware
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
MARIADB_DURABLE_STATE_PLUGIN_ID
MARIADB_JOURNAL_PLUGIN_ID
MARIADB_SNAPSHOT_PLUGIN_ID
MEMCACHED_CACHE_PLUGIN_ID
MetricsExtensionId
moduloAllocator
Nobody
none
NOOP_TRACER
OBJECT_STORAGE_DURABLE_STATE_PLUGIN_ID
OBJECT_STORAGE_SNAPSHOT_PLUGIN_ID
offsetStart
PersistenceExtensionId
Phases
POSTGRES_DURABLE_STATE_PLUGIN_ID
POSTGRES_JOURNAL_PLUGIN_ID
POSTGRES_SNAPSHOT_PLUGIN_ID
ReceptionistId
REDIS_CACHE_PLUGIN_ID
REFERENCE_CONF
rendezvousAllocator
Router
SerializationExtensionId
Status
stoppingStrategy
TracingExtensionId
WorkerNode
Functions
after
autoDiscovery
BearerTokenAuth
bootstrapCluster
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
IpAllowlist
isHealthy
jsonCodec
keyspaceDdl
left
linearBackoff
managementRoutes
marshal
matchesMqttPattern
mediatorPath
metricsOf
migratingAdapter
migratingSnapshotAdapter
newSpanId
newTraceId
normalizeTagFilter
offsetCompare
offsetGreater
offsetGreaterOrEqual
offsetOfEvent
options
otelLogger
otelTracer
parseDuration
parseHocon
parseSelectionPath
parseSize
patch
path
pathParam
pathPrefix
pickRendezvous
pickRequestSerializer
pickResponseSerializer
pipeTo
post
promClientRegistry
prometheusHandler
put
queryParam
randomStrategy
rateLimit
redirect
registerCassandraPlugins
registerMariaDbPlugins
registerObjectStoragePlugins
registerPostgresPlugins
reject
rememberEntitiesDdl
resolveCompression
resolveEncryption
resolveSubstitutions
retry
right
roundRobinStrategy
same
seedsFromEnv
serverWebSocketActorOf
singleProviderDiscovery
singletonManagerPath
some
stopped
success
tracerOf
tryOf
trySequence
typedProps
unhandled
validatedEventAdapter
validatedSnapshotAdapter
withMiddleware
zodCodec
🎁 附加内容
设计决策
架构决策记录
GitHub
选择主题
深色
浅色
自动
简体中文
English
Deutsch
Español
Français
日本語
한국어
Português (BR)
Русский
简体中文
Try
此内容尚不支持你的语言。
Try
<
T
> =
Success
<
T
> |
Failure
Defined in:
src/util/Try.ts:156
Type Parameters
Section titled “Type Parameters”
T
Section titled “T”
T