RpcReceiveService

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

Service responsible for handling RPC requests received via WebSocket frames.

The service processes RPC requests, interacts with actors for the requested operations, and returns appropriate responses. Uses a registry to manage actor instances and ensure proper delegation of requests to the corresponding actors.

Parameters

loggerFactory

Factory for creating logger instances used for logging activities.

protoBuf

Serializer/deserializer for encoding and decoding RPC requests and responses.

registry

Registry for managing actor instances and resolving actor addresses to their objects.

Constructors

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

Initializes the service with the necessary dependencies for processing requests.

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
fun receive(session: WebSocketSession, frame: Frame)

Handles incoming WebSocket frames and processes RPC requests.