Package-level declarations

Types

Link copied to clipboard
interface RpcEnvelope

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

Link copied to clipboard
class RpcManager<R>(loggerFactory: Logger.Factory, timeout: Duration)

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

Link copied to clipboard
class RpcReceiveService(loggerFactory: Logger.Factory, protoBuf: ProtoBuf, registry: ClusterActorRegistry)

Service responsible for handling RPC requests received via WebSocket frames.

Link copied to clipboard
class RpcSendService(loggerFactory: Logger.Factory, protoBuf: ProtoBuf, session: RpcWebSocketSession)

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

Link copied to clipboard
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.