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

ClusterImpl

class ClusterImpl(nodes: List<ClusterNode>, val current: ClusterNode, val proxy: Boolean = false, val loggerFactory: Logger.Factory, val registry: ClusterActorRegistry, val routing: Routing.() -> Unit = {}, val serialization: SerializersModuleBuilder.() -> Unit = {}) : Cluster

Implementation of the Cluster interface for managing and orchestrating distributed systems.

This class is responsible for setting up the communication infrastructure, handling RPC, and managing lifecycle operations (startup, shutdown) across a cluster of nodes. It provides utilities for interacting with other nodes in the cluster, sending requests, and receiving responses in a structured manner.

Parameters

nodes

The list of ClusterNode instances representing all the nodes in the cluster.

current

The current node in the cluster, representing the local instance of this implementation.

proxy

Indicates whether the current node operates as a proxy; if true, it excludes the current node from the list of managed nodes.

loggerFactory

A factory for creating loggers used throughout the cluster implementation.

routing

A configuration block for setting up routing within the HTTP server.

serialization

A configuration block for customizing the serialization module.

Constructors

ClusterImpl

constructor(nodes: List<ClusterNode>, current: ClusterNode, proxy: Boolean = false, loggerFactory: Logger.Factory, registry: ClusterActorRegistry, routing: Routing.() -> Unit = {}, serialization: SerializersModuleBuilder.() -> Unit = {})

Creates a new instance of ClusterImpl with the specified parameters.