Package

akka

cluster

Permalink

package cluster

Content Hierarchy Learn more about scaladoc diagrams
Visibility
  1. Public
  2. All

Type Members

  1. class Cluster extends Extension

    Permalink

    This module is responsible cluster membership information.

    This module is responsible cluster membership information. Changes to the cluster information is retrieved through #subscribe. Commands to operate the cluster is available through methods in this class, such as #join, #down and #leave.

    Each cluster Member is identified by its akka.actor.Address, and the cluster address of this actor system is #selfAddress. A member also has a status; initially MemberStatus Joining followed by MemberStatus Up.

  2. trait ClusterMessage extends Serializable

    Permalink

    Base trait for all cluster messages.

    Base trait for all cluster messages. All ClusterMessage's are serializable.

  3. trait ClusterNodeMBean extends AnyRef

    Permalink

    Interface for the cluster JMX MBean.

  4. abstract class ClusterScope extends Scope

    Permalink
    Annotations
    @SerialVersionUID()
  5. final class ClusterSettings extends AnyRef

    Permalink
  6. class Member extends Serializable

    Permalink

    Represents the address, current status, and roles of a cluster member node.

    Represents the address, current status, and roles of a cluster member node.

    Note: hashCode and equals are solely based on the underlying Address, not its MemberStatus and roles.

    Annotations
    @SerialVersionUID()
  7. abstract class MemberStatus extends AnyRef

    Permalink

    Defines the current status of a cluster member node

    Defines the current status of a cluster member node

    Can be one of: Joining, Up, Leaving, Exiting and Down.

  8. final case class UniqueAddress(address: Address, uid: Int) extends Ordered[UniqueAddress] with Product with Serializable

    Permalink

    Member identifier consisting of address and random uid.

    Member identifier consisting of address and random uid. The uid is needed to be able to distinguish different incarnations of a member with same hostname and port.

    Annotations
    @SerialVersionUID()
  9. final case class VectorClock(versions: TreeMap[Node, Long] = ...) extends Product with Serializable

    Permalink

    Representation of a Vector-based clock (counting clock), inspired by Lamport logical clocks.

    Representation of a Vector-based clock (counting clock), inspired by Lamport logical clocks.

    Reference:
       1) Leslie Lamport (1978). "Time, clocks, and the ordering of events in a distributed system". Communications of the ACM 21 (7): 558-565.
       2) Friedemann Mattern (1988). "Virtual Time and Global States of Distributed Systems". Workshop on Parallel and Distributed Algorithms: pp. 215-226

    Based on code from the 'vlock' VectorClock library by Coda Hale.

    Annotations
    @SerialVersionUID()
  10. class JmxMetricsCollector extends MetricsCollector

    Permalink

    Loads JVM and system metrics through JMX monitoring beans.

    Loads JVM and system metrics through JMX monitoring beans.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

  11. final case class Metric extends MetricNumericConverter with Product with Serializable

    Permalink

    Metrics key/value.

    Metrics key/value.

    Equality of Metric is based on its name.

    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

  12. trait MetricsCollector extends Closeable

    Permalink

    Implementations of cluster system metrics extends this trait.

    Implementations of cluster system metrics extends this trait.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

  13. final case class NodeMetrics(address: Address, timestamp: Long, metrics: Set[Metric] = Set.empty[Metric]) extends Product with Serializable

    Permalink

    The snapshot of current sampled health metrics for any monitored process.

    The snapshot of current sampled health metrics for any monitored process. Collected and gossipped at regular intervals for dynamic cluster management strategies.

    Equality of NodeMetrics is based on its address.

    address

    akka.actor.Address of the node the metrics are gathered at

    timestamp

    the time of sampling, in milliseconds since midnight, January 1, 1970 UTC

    metrics

    the set of sampled akka.cluster.Metric

    Annotations
    @SerialVersionUID() @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

  14. class SigarMetricsCollector extends JmxMetricsCollector

    Permalink

    Loads metrics through Hyperic SIGAR and JMX monitoring beans.

    Loads metrics through Hyperic SIGAR and JMX monitoring beans. This loads wider and more accurate range of metrics compared to JmxMetricsCollector by using SIGAR's native OS library.

    The constructor will by design throw exception if org.hyperic.sigar.Sigar can't be loaded, due to missing classes or native libraries.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

Value Members

  1. object Cluster extends ExtensionId[Cluster] with ExtensionIdProvider

    Permalink

    Cluster Extension Id and factory for creating Cluster extension.

  2. object ClusterEvent

    Permalink

    Domain events published to the event bus.

    Domain events published to the event bus. Subscribe with:

    Cluster(system).subscribe(actorRef, classOf[ClusterDomainEvent])
  3. object ClusterScope extends ClusterScope with Product with Serializable

    Permalink

    Cluster aware scope of a akka.actor.Deploy

  4. object GossipEnvelope extends Serializable

    Permalink
  5. object Member extends Serializable

    Permalink

    Module with factory and ordering methods for Member instances.

  6. object MemberStatus

    Permalink
  7. package client

    Permalink
  8. package ddata

    Permalink
  9. package metrics

    Permalink
  10. package protobuf

    Permalink
  11. package pubsub

    Permalink
  12. package routing

    Permalink
  13. package sharding

    Permalink
  14. package singleton

    Permalink

Deprecated Value Members

  1. object Metric extends MetricNumericConverter with Serializable

    Permalink

    Factory for creating valid Metric instances.

    Factory for creating valid Metric instances.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

  2. object StandardMetrics

    Permalink

    Definitions of the built-in standard metrics.

    Definitions of the built-in standard metrics.

    The following extractors and data structures makes it easy to consume the akka.cluster.NodeMetrics in for example load balancers.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.4) Superseded by akka.cluster.metrics (in akka-cluster-metrics jar)

Ungrouped