コンテンツにスキップ
actor-ts
検索
Ctrl
K
キャンセル
GitHub
テーマの選択
ダーク
ライト
自動
日本語
English
Deutsch
Español
Français
日本語
한국어
Português (BR)
Русский
简体中文
🚀 はじめに
actor-ts とは?
なぜアクターか?
インストール
クイックスタート
学習パス
用語集
🎭 アクターの構築
基礎
概要
Actor
メッセージ
Ask パターン
ActorSystem
アクターパス
Props
Become と Stash
Death watch
スーパービジョン
Dispatchers
Mailboxes
タイマーとスケジューリング
Receive timeout
協調シャットダウン
イベントストリーム
ロギング
PoisonPill と Kill
パターンマッチング
型付きアクター
概要
TypedActor
Behaviors
型付きアクターの生成
ルーティング
概要
Router
戦略
プール vs グループ
パターン
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
データ設計
レプリケーション
クォーラム読み書き
永続ストレージ
協調
概要
Lease API
インメモリ Lease
Kubernetes Lease
ディスカバリ
概要
シードプロバイダ
設定
DNS
Kubernetes API
集約
Receptionist
💾 永続化
イベントソーシング
概要
PersistentActor
イベントディスパッチャ
Snapshots
永続状態
プロジェクション
永続化クエリ
プッシュ型クエリ
ジャーナル
インメモリ
SQLite
Cassandra
PostgreSQL
MariaDB
スナップショットストア
インメモリ
SQLite
キャッシュ付きスナップショットストア
レプリケーションイベントソーシング
概要
シングルライター Lease
Vector clocks
競合リゾルバ
Snapshotting
オブジェクトストレージ
概要
圧縮
暗号化
鍵ローテーション
アクターごとのポリシー
スナップショットストアバックエンド
移行
概要
レシピ
スキーマレジストリ
エンベロープ形式
デフォルトアダプタ
マイグレーションアダプタ
レガシーのラップ
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 アダプタ
記録トレーサ
アクタートレーシング
管理
概要
ヘルスチェック
HTTP エンドポイント
✅ テスト
概要
TestKit
TestProbe
ManualScheduler
MultiNodeSpec
ParallelMultiNodeSpec
⚙️ 運用
概要
デプロイ
Kubernetes
Docker Compose
プロセスマネージャ
チューニング
Gossip ケイデンス
Failure detector
Mailbox サイジング
Dispatcher チューニング
セキュリティ
クラスタセキュリティ
マスターキーローテーション
TLS everywhere
アップグレード
ローリング移行
アップグレード戦略
トラブルシューティング
ランタイム
概要
互換性マトリクス
Bun
Node
Deno
💡 例
概要
チャットサンプル
音声サンプル
スタンドアロンスニペット
🚚 移行
概要
Akka (JVM) から
Pekko から
Orleans から
Akka.NET から
バニラ TS から
📖 リファレンス
設定
バージョンポリシー
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
🎁 追加機能
設計判断
Architecture Decision Records
GitHub
テーマの選択
ダーク
ライト
自動
日本語
English
Deutsch
Español
Français
日本語
한국어
Português (BR)
Русский
简体中文
SseCmd
このコンテンツはまだ日本語訳がありません。
SseCmd
=
never
Defined in:
src/io/broker/SseActor.ts:27