Majabigwaduce
API
Generated with
Majabigwaduce/com.phasmid.majabigwaduce/com.phasmid.majabigwaduce.cluster/ClusterWorker

ClusterWorker

com.phasmid.majabigwaduce.cluster.ClusterWorker
object ClusterWorker

A ClusterWorker offers reducers to the Masters of a cluster. Start one (with ClusterWorker.start) on every node which should run reducers -- including, if you like, the node which runs the Master. It registers itself with the Receptionist, so that a ClusterWorkerPool can find it.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply(): Behavior[WorkerCommand]
def start(system: ActorSystem[_]): ActorRef[WorkerCommand]

Starts a ClusterWorker in system.

Starts a ClusterWorker in system.

Value parameters

system

a cluster member, with pekko.actor.allow-java-serialization = on.

Attributes

Returns

the worker.

Concrete fields

val key: ServiceKey[WorkerCommand]

The key under which workers register with the Receptionist.

The key under which workers register with the Receptionist.

Attributes

Generated with