NodeClusterSocket.ts

NodeClusterSocket.ts overview

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.

Since v4.0.0

---

Exports Grouped by Category

• layers
  • layerClientProtocol
  • layerSocketServer

---

layers

layerClientProtocol

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>

Source

Since v4.0.0

layerSocketServer

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
>

Source

Since v4.0.0