com.lightbend.lagom.projection

Class State

Object

com.lightbend.lagom.projection.State

All Implemented Interfaces:

ProjectionSerializable

public final class State
extends Object
implements ProjectionSerializable

The state of a projections registry is a collection of projections with extra data indicating the name of the projection, and details about its workers. Note that many projections may operate over the same journal. Each worker includes information about the particular tagName it is tracking. Note that multiple workers may track the same tagName because each worker is part of a different projection. Each worker also has a key which is unique across the whole cluster. Finally, the data related to a worker that's part of the State includes a requested status and an observed status for the worker.

param: projections list of available projections on the internal registry

Constructor Summary

Constructors

Constructor and Description
State(scala.collection.Seq<Projection> projections)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
static State	fromReplicatedData(scala.collection.immutable.Map<String,scala.collection.immutable.Set<com.lightbend.lagom.internal.projection.ProjectionRegistryActor.WorkerCoordinates>> nameIndex, scala.collection.immutable.Map<com.lightbend.lagom.internal.projection.ProjectionRegistryActor.WorkerCoordinates,Status> requestedStatusLocalCopy, scala.collection.immutable.Map<com.lightbend.lagom.internal.projection.ProjectionRegistryActor.WorkerCoordinates,Status> observedStatusLocalCopy, Status defaultRequested, Status defaultObserved)
List<Projection>	getProjections() Java API
int	hashCode()
scala.collection.Seq<Projection>	projections()
String	toString()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

State

public State(scala.collection.Seq<Projection> projections)

Method Detail

fromReplicatedData

public static State fromReplicatedData(scala.collection.immutable.Map<String,scala.collection.immutable.Set<com.lightbend.lagom.internal.projection.ProjectionRegistryActor.WorkerCoordinates>> nameIndex,
                                       scala.collection.immutable.Map<com.lightbend.lagom.internal.projection.ProjectionRegistryActor.WorkerCoordinates,Status> requestedStatusLocalCopy,
                                       scala.collection.immutable.Map<com.lightbend.lagom.internal.projection.ProjectionRegistryActor.WorkerCoordinates,Status> observedStatusLocalCopy,
                                       Status defaultRequested,
                                       Status defaultObserved)

projections

public scala.collection.Seq<Projection> projections()

getProjections

public List<Projection> getProjections()

Java API

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object