NodeClusterSocket unstable
Node TCP socket transport for Effect Cluster runner-to-runner RPC.
This module provides the shared Node layers used by socket-based cluster
transports. layerClientProtocol opens TCP sockets to peer runner addresses
and wraps them in the current RPC serialization protocol. layerSocketServer
exposes the socket server that receives incoming runner RPC traffic.
Layers
layerClientProtocol
unstable Since v4.0.0 Source
Provides the cluster RpcClientProtocol by opening TCP sockets to runner
addresses and using the current RPC serialization service.
Signature
declare const layerClientProtocol: Layer.Layer<Runners.RpcClientProtocol, never, RpcSerialization.RpcSerialization>layerSocketServer
unstable Since v4.0.0 Source
Provides the socket server used by cluster runners, listening on
ShardingConfig.runnerListenAddress or runnerAddress.
Signature
declare const layerSocketServer: Layer.Layer<SocketServer.SocketServer, SocketServer.SocketServerError, ShardingConfig.ShardingConfig>