public final class PersistenceMultiDcSettings
extends java.lang.Object
| Constructor and Description |
|---|
PersistenceMultiDcSettings(scala.collection.immutable.Seq<java.lang.String> allDcs,
java.lang.String journalPluginId,
java.lang.String replicatedEventsQueryJournalPluginId,
boolean useSpeculativeReplication,
boolean useCrossReadingReplication,
scala.concurrent.duration.FiniteDuration replicationRestartMinBackoff,
scala.concurrent.duration.FiniteDuration replicationRestartMaxBackoff,
int snapshotAfter,
scala.concurrent.duration.Duration autoPassivateAfter,
HotStandbySettings hotStandbySettings,
ReplicatedEntityLoggingSettings loggingSettings) |
| Modifier and Type | Method and Description |
|---|---|
scala.collection.immutable.Seq<java.lang.String> |
allDcs() |
static PersistenceMultiDcSettings |
apply(akka.actor.ActorSystem system)
Scala API
|
static PersistenceMultiDcSettings |
apply(com.typesafe.config.Config config)
Scala API
|
scala.concurrent.duration.Duration |
autoPassivateAfter() |
static PersistenceMultiDcSettings |
create(akka.actor.ActorSystem system)
Java API
|
static PersistenceMultiDcSettings |
create(com.typesafe.config.Config config)
Java API
|
static java.lang.String |
DefaultReplicatedEventsQueryJournalPluginId()
Use this identifier when constructing a Persistence Query stream to consume events of Replicated Entities
|
java.util.List<java.lang.String> |
getAllDcs() |
java.util.List<java.lang.String> |
getOtherDcs(java.lang.String selfDc) |
HotStandbySettings |
hotStandbySettings() |
java.lang.String |
journalPluginId() |
ReplicatedEntityLoggingSettings |
loggingSettings() |
scala.collection.immutable.Seq<java.lang.String> |
otherDcs(java.lang.String selfDc) |
java.lang.String |
replicatedEventsQueryJournalPluginId() |
scala.concurrent.duration.FiniteDuration |
replicationRestartMaxBackoff() |
scala.concurrent.duration.FiniteDuration |
replicationRestartMinBackoff() |
int |
snapshotAfter() |
java.lang.String |
toString() |
boolean |
useCrossReadingReplication() |
boolean |
useSpeculativeReplication() |
PersistenceMultiDcSettings |
withAllDcs(scala.collection.immutable.Seq<java.lang.String> allDcs) |
PersistenceMultiDcSettings |
withAutoPassivateAfter(scala.concurrent.duration.Duration newSetting) |
PersistenceMultiDcSettings |
withCrossReadingReplication(boolean newUseCrossReadingRelication) |
PersistenceMultiDcSettings |
withHotStandbySettings(HotStandbySettings newSettings) |
PersistenceMultiDcSettings |
withJournalPluginId(java.lang.String journalPluginId) |
PersistenceMultiDcSettings |
withLoggingSettings(ReplicatedEntityLoggingSettings newSettings) |
PersistenceMultiDcSettings |
withReplicatedEventsQueryJournalPluginId(java.lang.String replicatedEventsQueryJournalPluginId) |
PersistenceMultiDcSettings |
withReplicationRestartBackoff(scala.concurrent.duration.FiniteDuration min,
scala.concurrent.duration.FiniteDuration max) |
PersistenceMultiDcSettings |
withSnapshotAfter(int newSnapshotAfter) |
PersistenceMultiDcSettings |
withUseSpeculativeReplication(boolean newUseSpeculativeReplication) |
public PersistenceMultiDcSettings(scala.collection.immutable.Seq<java.lang.String> allDcs,
java.lang.String journalPluginId,
java.lang.String replicatedEventsQueryJournalPluginId,
boolean useSpeculativeReplication,
boolean useCrossReadingReplication,
scala.concurrent.duration.FiniteDuration replicationRestartMinBackoff,
scala.concurrent.duration.FiniteDuration replicationRestartMaxBackoff,
int snapshotAfter,
scala.concurrent.duration.Duration autoPassivateAfter,
HotStandbySettings hotStandbySettings,
ReplicatedEntityLoggingSettings loggingSettings)
public static java.lang.String DefaultReplicatedEventsQueryJournalPluginId()
The value is "cassandra-query-journal-multi-dc" and corresponds
to the absolute path to the read journal configuration entry.
public static PersistenceMultiDcSettings create(akka.actor.ActorSystem system)
public static PersistenceMultiDcSettings create(com.typesafe.config.Config config)
public static PersistenceMultiDcSettings apply(akka.actor.ActorSystem system)
public static PersistenceMultiDcSettings apply(com.typesafe.config.Config config)
public scala.collection.immutable.Seq<java.lang.String> allDcs()
public java.lang.String journalPluginId()
public java.lang.String replicatedEventsQueryJournalPluginId()
public boolean useSpeculativeReplication()
public boolean useCrossReadingReplication()
public scala.concurrent.duration.FiniteDuration replicationRestartMinBackoff()
public scala.concurrent.duration.FiniteDuration replicationRestartMaxBackoff()
public int snapshotAfter()
public scala.concurrent.duration.Duration autoPassivateAfter()
public HotStandbySettings hotStandbySettings()
public ReplicatedEntityLoggingSettings loggingSettings()
public PersistenceMultiDcSettings withAllDcs(scala.collection.immutable.Seq<java.lang.String> allDcs)
public PersistenceMultiDcSettings withJournalPluginId(java.lang.String journalPluginId)
public PersistenceMultiDcSettings withReplicatedEventsQueryJournalPluginId(java.lang.String replicatedEventsQueryJournalPluginId)
public PersistenceMultiDcSettings withUseSpeculativeReplication(boolean newUseSpeculativeReplication)
public PersistenceMultiDcSettings withCrossReadingReplication(boolean newUseCrossReadingRelication)
public PersistenceMultiDcSettings withReplicationRestartBackoff(scala.concurrent.duration.FiniteDuration min, scala.concurrent.duration.FiniteDuration max)
public PersistenceMultiDcSettings withSnapshotAfter(int newSnapshotAfter)
public PersistenceMultiDcSettings withHotStandbySettings(HotStandbySettings newSettings)
public PersistenceMultiDcSettings withAutoPassivateAfter(scala.concurrent.duration.Duration newSetting)
public PersistenceMultiDcSettings withLoggingSettings(ReplicatedEntityLoggingSettings newSettings)
public scala.collection.immutable.Seq<java.lang.String> otherDcs(java.lang.String selfDc)
public java.util.List<java.lang.String> getAllDcs()
public java.util.List<java.lang.String> getOtherDcs(java.lang.String selfDc)
public java.lang.String toString()
toString in class java.lang.Object