actor4k-cluster/io.github.smyrgeorge.actor4k.cluster.rpc

Package-level declarations

Types

A base interface representing messages exchanged in a clustered actor system.

class RpcManager<R>(loggerFactory: Logger.Factory, timeout: Duration)

Manages Remote Procedure Call (RPC) communication within the system.

class RpcReceiveService(loggerFactory: Logger.Factory, protoBuf: ProtoBuf, registry: ClusterActorRegistry)

Service responsible for handling RPC requests received via WebSocket frames.

class RpcSendService(loggerFactory: Logger.Factory, protoBuf: ProtoBuf, session: RpcWebSocketSession)

Service class responsible for handling RPC (Remote Procedure Call) communication over a WebSocket session.

class RpcWebSocketSession(loggerFactory: Logger.Factory, client: HttpClient, node: ClusterNode)

Maintains a WebSocket connection to a remote node and provides mechanisms for sending and handling communication in a clustered environment.