akka.contrib.pattern
Class ClusterSharding.Settings$

java.lang.Object
  akka.contrib.pattern.ClusterSharding.Settings$

Enclosing class:

ClusterSharding

public class ClusterSharding.Settings$
extends java.lang.Object

INTERNAL API

Constructor Summary

ClusterSharding.Settings$()

Method Summary

int	BufferSize()
com.typesafe.config.Config	config()
scala.concurrent.duration.FiniteDuration	CoordinatorFailureBackoff()
java.lang.String	GuardianName()
scala.concurrent.duration.FiniteDuration	HandOffTimeout()
boolean	HasNecessaryClusterRole()
int	LeastShardAllocationMaxSimultaneousRebalance()
int	LeastShardAllocationRebalanceThreshold()
scala.concurrent.duration.FiniteDuration	RebalanceInterval()
scala.concurrent.duration.FiniteDuration	RetryInterval()
scala.Option<java.lang.String>	Role()
scala.concurrent.duration.FiniteDuration	SnapshotInterval()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterSharding.Settings$

public ClusterSharding.Settings$()

Method Detail

config

public com.typesafe.config.Config config()

Role

public scala.Option<java.lang.String> Role()

HasNecessaryClusterRole

public boolean HasNecessaryClusterRole()

GuardianName

public java.lang.String GuardianName()

CoordinatorFailureBackoff

public scala.concurrent.duration.FiniteDuration CoordinatorFailureBackoff()

RetryInterval

public scala.concurrent.duration.FiniteDuration RetryInterval()

BufferSize

public int BufferSize()

HandOffTimeout

public scala.concurrent.duration.FiniteDuration HandOffTimeout()

RebalanceInterval

public scala.concurrent.duration.FiniteDuration RebalanceInterval()

SnapshotInterval

public scala.concurrent.duration.FiniteDuration SnapshotInterval()

LeastShardAllocationRebalanceThreshold

public int LeastShardAllocationRebalanceThreshold()

LeastShardAllocationMaxSimultaneousRebalance

public int LeastShardAllocationMaxSimultaneousRebalance()