- AbstractFastFailoverSupport - Class in akka.cluster.fastfailover
-
Java API: Support for implementing fast failover with an abstract actor.
- AbstractFastFailoverSupport() - Constructor for class akka.cluster.fastfailover.AbstractFastFailoverSupport
-
- AbstractGdprEncryption - Class in akka.persistence.gdpr.javadsl
-
- AbstractGdprEncryption(ExtendedActorSystem) - Constructor for class akka.persistence.gdpr.javadsl.AbstractGdprEncryption
-
- AbstractGdprEncryption - Class in akka.persistence.gdpr.scaladsl
-
- AbstractGdprEncryption(ExtendedActorSystem) - Constructor for class akka.persistence.gdpr.scaladsl.AbstractGdprEncryption
-
- AbstractGdprEncryption$ - Class in akka.persistence.gdpr.javadsl
-
- AbstractGdprEncryption$() - Constructor for class akka.persistence.gdpr.javadsl.AbstractGdprEncryption$
-
- AbstractGdprEncryption$ - Class in akka.persistence.gdpr.scaladsl
-
- AbstractGdprEncryption$() - Constructor for class akka.persistence.gdpr.scaladsl.AbstractGdprEncryption$
-
- acquire() - Method in class akka.lease.kubernetes.KubernetesLease
-
- acquire(Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.KubernetesLease
-
- Acquire(Function1<Option<Throwable>, BoxedUnit>) - Constructor for class akka.lease.kubernetes.LeaseActor.Acquire
-
- Acquire$() - Constructor for class akka.lease.kubernetes.LeaseActor.Acquire$
-
- acquireDelay() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
-
- acquireDelay() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable
-
- acquireDelay() - Method in interface com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseDecision
-
- AcquireLease$() - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLease$
-
- AcquireLeaseAndDownIndirectlyConnected(FiniteDuration) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
-
- AcquireLeaseAndDownIndirectlyConnected$() - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected$
-
- AcquireLeaseAndDownUnreachable(FiniteDuration) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable
-
- AcquireLeaseAndDownUnreachable$() - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable$
-
- acquireLeaseDelayForMinority() - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- AcquireLeaseResult(boolean) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult
-
- AcquireLeaseResult$() - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult$
-
- actOnDecision(SplitBrainResolver.Decision) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- actorContext() - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- actorContext() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.EventTriggerContext
-
- actorContext() - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.EventTriggerContext
-
- actorOf(Props) - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Create new actor as child of this actor and give it an automatically
generated name (currently similar to base64-encoded integer count,
reversed and with “$” prepended, may change in the future).
- actorOf(Props, String) - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Create new actor as child of this actor with the given name, which must
not be null, empty or start with “$”.
- actorOf(Props) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Create new actor as child of this actor and give it an automatically
generated name (currently similar to base64-encoded integer count,
reversed and with “$” prepended, may change in the future).
- actorOf(Props, String) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Create new actor as child of this actor with the given name, which must
not be null, empty or start with “$”.
- actorOf(Props) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- actorOf(Props, String) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- actorSelection(String) - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Construct an ActorSelection from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
- actorSelection(ActorPath) - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Construct an ActorSelection from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
- actorSelection(String) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Construct an ActorSelection from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
- actorSelection(ActorPath) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Construct an ActorSelection from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
- actorSelection(String) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- actorSelection(ActorPath) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- add(A) - Method in class akka.persistence.multidc.crdt.ORSet
-
Adds an element to the set
- add(Member) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- Add_VALUE - Static variable in enum akka.persistence.multidc.serialization.Crdts.ORSetDeltaOp
-
Add = 0;
- addAll(Set<A>) - Method in class akka.persistence.multidc.crdt.ORSet
-
Java API: Add several elements to the set.
- addAll(Set<A>) - Method in class akka.persistence.multidc.crdt.ORSet
-
Scala API: Add several elements to the set.
- addAllDots(Iterable<? extends Crdts.VersionVector>) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addAllEntries(Iterable<? extends Crdts.ORSetDeltaGroup.Entry>) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addAllEntries(Iterable<? extends Crdts.VersionVector.Entry>) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addAllEventsWritten(Iterable<? extends ReplicatedEvents.Notification.EventsWritten>) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addAllIntElements(Iterable<? extends Integer>) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- addAllLastOriginSeqNrPerDc(Iterable<? extends ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr>) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addAllLongElements(Iterable<? extends Long>) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- addAllOtherElements(Iterable<? extends WrappedPayload.Wrapped>) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addAllStringElements(Iterable<String>) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- AddDeltaOp(ORSet<A>) - Constructor for class akka.persistence.multidc.crdt.ORSet.AddDeltaOp
-
- AddDeltaOp$() - Constructor for class akka.persistence.multidc.crdt.ORSet.AddDeltaOp$
-
- addDots(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addDots(int, Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addDots(Crdts.VersionVector.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addDots(int, Crdts.VersionVector.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addDotsBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addDotsBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- addEntries(Crdts.ORSetDeltaGroup.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addEntries(int, Crdts.ORSetDeltaGroup.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addEntries(Crdts.ORSetDeltaGroup.Entry.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addEntries(int, Crdts.ORSetDeltaGroup.Entry.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addEntries(Crdts.VersionVector.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addEntries(int, Crdts.VersionVector.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addEntries(Crdts.VersionVector.Entry.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addEntries(int, Crdts.VersionVector.Entry.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addEntriesBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addEntriesBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- addEntriesBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addEntriesBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- addErrorFilter(String, Function1<ReplicatedEventEnvelope, Option<Throwable>>) - Method in class akka.persistence.multidc.testkit.InterruptableCassandraReplicatedEventQuery
-
- addErrorFilter(String, int, Function1<ReplicatedEventEnvelope, Option<Throwable>>) - Method in class akka.persistence.multidc.testkit.InterruptableCassandraReplicatedEventQuery
-
- addErrorFilter(ActorSystem, String, Function1<ReplicatedEventEnvelope, Option<Throwable>>) - Method in class akka.persistence.multidc.testkit.PersistenceMultiDcTestKit$
-
- addErrorFilter(ActorSystem, String, Function1<ReplicatedEventEnvelope, Option<Throwable>>) - Static method in class akka.persistence.multidc.testkit.PersistenceMultiDcTestKit
-
- addEventsWritten(ReplicatedEvents.Notification.EventsWritten) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addEventsWritten(int, ReplicatedEvents.Notification.EventsWritten) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addEventsWritten(ReplicatedEvents.Notification.EventsWritten.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addEventsWritten(int, ReplicatedEvents.Notification.EventsWritten.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addEventsWrittenBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addEventsWrittenBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- addIntElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- additionalRandomPublishDelay() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- addJoining(Member) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- addLastOriginSeqNrPerDc(ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addLastOriginSeqNrPerDc(int, ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addLastOriginSeqNrPerDc(ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addLastOriginSeqNrPerDc(int, ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addLastOriginSeqNrPerDcBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addLastOriginSeqNrPerDcBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- addLongElements(long) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- addOtherElements(WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addOtherElements(int, WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addOtherElements(WrappedPayload.Wrapped.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addOtherElements(int, WrappedPayload.Wrapped.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addOtherElementsBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addOtherElementsBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- addReachable(Member) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- address() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- address() - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- address(String) - Method in class akka.persistence.multidc.testkit.ContactPoints
-
- address() - Method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- addressDefaultClusterId() - Method in class akka.persistence.multidc.testkit.ContactPoints
-
- addressPromise() - Method in class akka.persistence.multidc.testkit.ContactPoints
-
- addStringElements(String) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- addStringElementsBytes(ByteString) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- addUnreachable(Member) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- addUp(Member) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- addWeaklyUp(Member) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- After$() - Constructor for class akka.persistence.multidc.crdt.VersionVector.After$
-
- afterCallback() - Method in class akka.persistence.multidc.internal.EffectImpl
-
INTERNAL API
- afterCallback() - Method in class akka.persistence.multidc.internal.Passivate
-
- afterCallback() - Method in class akka.persistence.multidc.internal.PersistAll
-
- afterCallback() - Method in class akka.persistence.multidc.internal.PersistNothing
-
- afterCallback() - Method in class akka.persistence.multidc.internal.PersistOne
-
- afterCallback() - Method in class akka.persistence.multidc.internal.StopEffect
-
- afterCallback() - Method in class akka.persistence.multidc.internal.UnhandledCommand
-
- AfterInstance() - Method in class akka.persistence.multidc.crdt.VersionVector$
-
Java API: The VersionVector.After instance
- AfterInstance() - Static method in class akka.persistence.multidc.crdt.VersionVector
-
Java API: The VersionVector.After instance
- aggregateTag() - Method in interface com.example.hello.impl.HelloEvent
-
- akka.cluster.fastfailover - package akka.cluster.fastfailover
-
- akka.cluster.fastfailover.serialization - package akka.cluster.fastfailover.serialization
-
- akka.dispatch.affinity - package akka.dispatch.affinity
-
- akka.lease.kubernetes - package akka.lease.kubernetes
-
- akka.lease.kubernetes.internal - package akka.lease.kubernetes.internal
-
- akka.persistence.gdpr - package akka.persistence.gdpr
-
- akka.persistence.gdpr.internal - package akka.persistence.gdpr.internal
-
- akka.persistence.gdpr.jackson - package akka.persistence.gdpr.jackson
-
- akka.persistence.gdpr.jackson.internal - package akka.persistence.gdpr.jackson.internal
-
- akka.persistence.gdpr.javadsl - package akka.persistence.gdpr.javadsl
-
- akka.persistence.gdpr.playjson - package akka.persistence.gdpr.playjson
-
- akka.persistence.gdpr.scaladsl - package akka.persistence.gdpr.scaladsl
-
- akka.persistence.gdpr.serialization - package akka.persistence.gdpr.serialization
-
- akka.persistence.gdpr.testkit - package akka.persistence.gdpr.testkit
-
- akka.persistence.multidc - package akka.persistence.multidc
-
- akka.persistence.multidc.crdt - package akka.persistence.multidc.crdt
-
- akka.persistence.multidc.internal - package akka.persistence.multidc.internal
-
- akka.persistence.multidc.javadsl - package akka.persistence.multidc.javadsl
-
- akka.persistence.multidc.scaladsl - package akka.persistence.multidc.scaladsl
-
- akka.persistence.multidc.serialization - package akka.persistence.multidc.serialization
-
- akka.persistence.multidc.testkit - package akka.persistence.multidc.testkit
-
- akka.persistence.update - package akka.persistence.update
-
- akka.persistence.update.cassandra - package akka.persistence.update.cassandra
-
- akka.persistence.update.cassandra.javadsl - package akka.persistence.update.cassandra.javadsl
-
- akka.persistence.update.cassandra.scaladsl - package akka.persistence.update.cassandra.scaladsl
-
- akka.persistence.update.javadsl - package akka.persistence.update.javadsl
-
- akka.persistence.update.jdbc - package akka.persistence.update.jdbc
-
- akka.persistence.update.jdbc.javadsl - package akka.persistence.update.jdbc.javadsl
-
- akka.persistence.update.jdbc.scaladsl - package akka.persistence.update.jdbc.scaladsl
-
- akka.persistence.update.scaladsl - package akka.persistence.update.scaladsl
-
- allDcs() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
All data centers
- allDcs() - Method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
- allMembersInDC() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- allStrategyNames() - Method in class com.lightbend.akka.sbr.SplitBrainResolverSettings$
-
- allStrategyNames() - Static method in class com.lightbend.akka.sbr.SplitBrainResolverSettings
-
- AlwaysIncreasingClock - Class in akka.persistence.multidc.internal
-
Always increasing wall clock time.
- AlwaysIncreasingClock() - Constructor for class akka.persistence.multidc.internal.AlwaysIncreasingClock
-
- AlwaysIncreasingClock() - Method in class akka.persistence.multidc.WallClock$
-
Always increasing time source.
- andThen(Consumer<State>) - Method in class akka.persistence.multidc.internal.EffectImpl
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.EffectImpl
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.Passivate
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistAll
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistNothing
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistOne
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.StopEffect
-
- andThen(Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.UnhandledCommand
-
- andThen(Consumer<State>) - Method in class akka.persistence.multidc.javadsl.Effect
-
Execute the given side effect callback after events, if any, are persisted.
- andThen(Function1<State, BoxedUnit>) - Method in interface akka.persistence.multidc.scaladsl.Effect
-
Execute the given side effect callback after events, if any, are persisted.
- AnnotatedStandardMXBean - Class in com.lightbend.akka.diagnostics.mbean
-
INTERNAL API
Copied from http://actimem.com/java/jmx-annotations/ which source code is
licensed under the Apache License, Version 2.0.
- AnnotatedStandardMXBean(T, Class<T>) - Constructor for class com.lightbend.akka.diagnostics.mbean.AnnotatedStandardMXBean
-
- apiCaPath() - Method in class akka.lease.kubernetes.KubernetesSettings
-
- ApiCompileTest - Class in akka.persistence.multidc.javadsl
-
- ApiCompileTest() - Constructor for class akka.persistence.multidc.javadsl.ApiCompileTest
-
- apiServerHost() - Method in class akka.lease.kubernetes.KubernetesSettings
-
- apiServerPort() - Method in class akka.lease.kubernetes.KubernetesSettings
-
- apiServerRequestTimeout() - Method in class akka.lease.kubernetes.KubernetesSettings
-
- apiTokenPath() - Method in class akka.lease.kubernetes.KubernetesSettings
-
- apiVersion() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- applicationConfig(Config, Config) - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
Extract the application specific configuration, i.e.
- apply(ActorSystem) - Static method in class akka.cluster.fastfailover.FastFailover
-
- apply(String, int, Object) - Method in class akka.cluster.fastfailover.FastFailover.Attempt$
-
- apply(int) - Method in class akka.cluster.fastfailover.FastFailover.Heartbeat$
-
- apply(int, akka.actor.Status$Status) - Method in class akka.cluster.fastfailover.FastFailover.Result$
-
- apply(FastFailover.Attempt, ActorRef, akka.actor.Status$Status, long) - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult$
-
- apply(Object, ActorRef) - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward$
-
- apply(ActorSystem) - Method in class akka.cluster.fastfailover.FastFailoverSettings$
-
Create settings from the default configuration
akka.cluster.fast-failover.
- apply(Config) - Method in class akka.cluster.fastfailover.FastFailoverSettings$
-
Create settings from a configuration with the same layout as
the default configuration akka.cluster.fast-failover.
- apply(ActorSystem) - Static method in class akka.cluster.fastfailover.FastFailoverSettings
-
Create settings from the default configuration
akka.cluster.fast-failover.
- apply(Config) - Static method in class akka.cluster.fastfailover.FastFailoverSettings
-
Create settings from a configuration with the same layout as
the default configuration akka.cluster.fast-failover.
- apply(Metadata, Spec, String, String) - Method in class akka.lease.kubernetes.internal.LeaseCustomResource$
-
- apply(Metadata, Spec, String, String) - Static method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- apply(String, Option<String>) - Method in class akka.lease.kubernetes.internal.Metadata$
-
- apply(String, Option<String>) - Static method in class akka.lease.kubernetes.internal.Metadata
-
- apply(String, long) - Method in class akka.lease.kubernetes.internal.Spec$
-
- apply(String, long) - Static method in class akka.lease.kubernetes.internal.Spec
-
- apply(ActorSystem, TimeoutSettings) - Method in class akka.lease.kubernetes.KubernetesSettings$
-
- apply(Config, TimeoutSettings) - Method in class akka.lease.kubernetes.KubernetesSettings$
-
- apply(ActorSystem, TimeoutSettings) - Static method in class akka.lease.kubernetes.KubernetesSettings
-
- apply(Config, TimeoutSettings) - Static method in class akka.lease.kubernetes.KubernetesSettings
-
- apply(Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.LeaseActor.Acquire$
-
- apply(String, Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.LeaseActor.GrantedVersion$
-
- apply(String) - Method in class akka.lease.kubernetes.LeaseActor.InvalidRequest$
-
- apply(String) - Method in class akka.lease.kubernetes.LeaseActor.LeaseCleared$
-
- apply(ActorRef, String, Function1<Option<Throwable>, BoxedUnit>, long) - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress$
-
- apply(ActorRef, Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.LeaseActor.PendingReadData$
-
- apply() - Method in class akka.lease.kubernetes.LeaseActor.Release$
-
- apply(Option<String>, String, long) - Method in class akka.lease.kubernetes.LeaseResource$
-
- apply(Option<String>, String, long) - Static method in class akka.lease.kubernetes.LeaseResource
-
- apply(ActorSystem) - Method in class akka.persistence.gdpr.GdprSettings$
-
- apply(Config) - Method in class akka.persistence.gdpr.GdprSettings$
-
- apply(ActorSystem) - Static method in class akka.persistence.gdpr.GdprSettings
-
- apply(Config) - Static method in class akka.persistence.gdpr.GdprSettings
-
- apply(ActorSystem) - Static method in class akka.persistence.gdpr.javadsl.GdprEncryption
-
- apply(ActorSystem, String) - Method in class akka.persistence.gdpr.JcaSettings$
-
- apply(Config) - Method in class akka.persistence.gdpr.JcaSettings$
-
- apply(ActorSystem, String) - Static method in class akka.persistence.gdpr.JcaSettings
-
- apply(Config) - Static method in class akka.persistence.gdpr.JcaSettings
-
- apply(String, T) - Method in class akka.persistence.gdpr.WithDataSubjectId$
-
Scala API: factory method for WithDataSubjectId including payload
that need to be encrypted for GDPR.
- apply(String, Option<T>) - Method in class akka.persistence.gdpr.WithDataSubjectId$
-
Representation of data that need to be encrypted for GDPR when stored.
- apply(String, T) - Static method in class akka.persistence.gdpr.WithDataSubjectId
-
Scala API: factory method for WithDataSubjectId including payload
that need to be encrypted for GDPR.
- apply(String, Option<T>) - Static method in class akka.persistence.gdpr.WithDataSubjectId
-
Representation of data that need to be encrypted for GDPR when stored.
- apply(BigInt) - Method in class akka.persistence.multidc.crdt.Counter$
-
- apply(BigInt) - Static method in class akka.persistence.multidc.crdt.Counter
-
- apply(BigInt) - Method in class akka.persistence.multidc.crdt.Counter.Updated$
-
- apply(long, String) - Method in class akka.persistence.multidc.crdt.LwwTime$
-
- apply(long, String) - Static method in class akka.persistence.multidc.crdt.LwwTime
-
- apply(TreeMap<String, Object>) - Method in class akka.persistence.multidc.crdt.ManyVersionVector$
-
- apply(TreeMap<String, Object>) - Static method in class akka.persistence.multidc.crdt.ManyVersionVector
-
- apply(String, long) - Method in class akka.persistence.multidc.crdt.OneVersionVector$
-
- apply(String, long) - Static method in class akka.persistence.multidc.crdt.OneVersionVector
-
- apply(String) - Method in class akka.persistence.multidc.crdt.ORSet$
-
- apply(ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp$
-
- apply(String) - Static method in class akka.persistence.multidc.crdt.ORSet
-
- apply(IndexedSeq<ORSet.DeltaOp>) - Method in class akka.persistence.multidc.crdt.ORSet.DeltaGroup$
-
- apply(ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp$
-
- apply(ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp$
-
- apply() - Method in class akka.persistence.multidc.crdt.VersionVector$
-
- apply(TreeMap<String, Object>) - Method in class akka.persistence.multidc.crdt.VersionVector$
-
- apply(String, long) - Method in class akka.persistence.multidc.crdt.VersionVector$
-
- apply(List<Tuple2<String, Object>>) - Method in class akka.persistence.multidc.crdt.VersionVector$
-
INTERNAL API
- apply() - Static method in class akka.persistence.multidc.crdt.VersionVector
-
- apply(TreeMap<String, Object>) - Static method in class akka.persistence.multidc.crdt.VersionVector
-
- apply(String, long) - Static method in class akka.persistence.multidc.crdt.VersionVector
-
- apply(List<Tuple2<String, Object>>) - Static method in class akka.persistence.multidc.crdt.VersionVector
-
INTERNAL API
- apply(Config) - Method in class akka.persistence.multidc.HotStandbySettings$
-
- apply(Config) - Static method in class akka.persistence.multidc.HotStandbySettings
-
- apply(String, long, ReplicatedEvent<Object>) - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope$
-
- apply(String, long, ReplicatedEvent<Object>) - Static method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- apply(String, boolean) - Method in class akka.persistence.multidc.internal.EventTaggingContextImpl$
-
- apply(String, boolean) - Static method in class akka.persistence.multidc.internal.EventTaggingContextImpl
-
- apply(String, boolean, ReplicatedActorContextImpl) - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl$
-
- apply(String, boolean, ReplicatedActorContextImpl) - Static method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- apply(String, long, ReplicatedEvent<Object>, long, String) - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope$
-
- apply(String, long, ReplicatedEvent<Object>, long, String) - Static method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- apply(OptionVal<ActorRef>, Set<String>) - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache$
-
- apply(ActorSystem) - Static method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton
-
- apply(FiniteDuration, FiniteDuration, int, int, FiniteDuration, FiniteDuration, Option<String>, Option<String>, String, CassandraCompactionStrategy, long, long, ConsistencyLevel, ConsistencyLevel, int, int, int) - Method in class akka.persistence.multidc.internal.NotificationSettings$
-
- apply(FiniteDuration, FiniteDuration, int, int, FiniteDuration, FiniteDuration, Option<String>, Option<String>, String, CassandraCompactionStrategy, long, long, ConsistencyLevel, ConsistencyLevel, int, int, int) - Static method in class akka.persistence.multidc.internal.NotificationSettings
-
- apply(UUID) - Method in class akka.persistence.multidc.internal.NotificationTimeBucket$
-
- apply(long) - Method in class akka.persistence.multidc.internal.NotificationTimeBucket$
-
- apply(UUID) - Static method in class akka.persistence.multidc.internal.NotificationTimeBucket
-
- apply(long) - Static method in class akka.persistence.multidc.internal.NotificationTimeBucket
-
- apply(String, String, long, long, OptionVal<String>) - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten$
-
- apply(Vector<NotificationWriter.EventsWritten>) - Method in class akka.persistence.multidc.internal.NotificationWriter.Notification$
-
- apply(Seq<AtomicWrite>) - Method in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents$
-
- apply(Command) - Method in class akka.persistence.multidc.internal.Passivate$
-
- apply(Command) - Static method in class akka.persistence.multidc.internal.Passivate
-
- apply(Seq<Event>, Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistAll$
-
- apply(Seq<Event>, Function1<State, BoxedUnit>) - Static method in class akka.persistence.multidc.internal.PersistAll
-
- apply(Event, Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistOne$
-
- apply(Event, Function1<State, BoxedUnit>) - Static method in class akka.persistence.multidc.internal.PersistOne
-
- apply(long, String, String, VersionVector, OptionVal<String>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData$
-
- apply(String, long, ReplicatedEvent<Event>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl$
-
- apply(String, String, String, long, long, VersionVector, OptionVal<String>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl$
-
- apply(ActorSystem) - Static method in class akka.persistence.multidc.internal.TheMaterializer
-
- apply(ReplicatedEntity.CommandContext, State, Command) - Method in interface akka.persistence.multidc.javadsl.CommandToEffect
-
- apply(ReplicatedEntity.CommandContext, State, Signal) - Method in interface akka.persistence.multidc.javadsl.SignalHandler
-
- apply(ActorSystem) - Method in class akka.persistence.multidc.PersistenceMultiDcSettings$
-
Scala API
- apply(Config) - Method in class akka.persistence.multidc.PersistenceMultiDcSettings$
-
Scala API
- apply(ActorSystem) - Static method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
Scala API
- apply(Config) - Static method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
Scala API
- apply(ReplicatedEntityActor<?, ?, ?>, ActorSystem) - Method in class akka.persistence.multidc.ReplicatedEntityLoggingAdapter$
-
Special LoggingAdapter which adds the enclosing replicated entity persistenceId to each log statement.
- apply(ReplicatedEntityActor<?, ?, ?>, ActorSystem) - Static method in class akka.persistence.multidc.ReplicatedEntityLoggingAdapter
-
Special LoggingAdapter which adds the enclosing replicated entity persistenceId to each log statement.
- apply(Config) - Method in class akka.persistence.multidc.ReplicatedEntityLoggingSettings$
-
- apply(Config) - Static method in class akka.persistence.multidc.ReplicatedEntityLoggingSettings
-
- apply(S, Map<String, Object>, VersionVector) - Method in class akka.persistence.multidc.ReplicatedEntitySnapshot$
-
- apply(S, Map<String, Object>, VersionVector) - Static method in class akka.persistence.multidc.ReplicatedEntitySnapshot
-
- apply(Function3<ReplicatedEntity.CommandContext, State, Command, Effect<Event, State>>) - Method in class akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandHandlerFactories
-
- apply(ActorSystem) - Static method in class akka.persistence.multidc.testkit.ContactPoints
-
- apply(Function0<ReplicatedEntity<C, E, S>>, ActorSystem, String, Set<String>, Option<String>) - Method in class akka.persistence.multidc.testkit.Simulator$
-
- apply(Function0<ReplicatedEntity<C, E, S>>, ActorSystem, String, Set<String>, Option<String>) - Static method in class akka.persistence.multidc.testkit.Simulator
-
- apply(ActorSystem) - Static method in class akka.persistence.update.javadsl.JournalUpdater
-
- apply(Object, String) - Method in class akka.persistence.update.JournaledEventImpl$
-
- apply(Object, String) - Static method in class akka.persistence.update.JournaledEventImpl
-
- apply(ActorSystem) - Static method in class akka.persistence.update.scaladsl.JournalUpdater
-
- apply(String, String, Seq<String>, Seq<String>) - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning$
-
- apply(Seq<ConfigChecker.ConfigWarning>) - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ValidationResults$
-
- apply(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.DiagnosticsExtension
-
- apply(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
- apply(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.ManagementRoutes
-
- apply(Thread, Thread.State, StackTraceElement[]) - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus$
-
- apply(Thread, Thread.State, StackTraceElement[]) - Static method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- apply(String) - Method in class com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException$
-
- apply(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings$
-
- apply(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Static method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings
-
- apply(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl$
-
- apply(boolean, Option<String>) - Method in class com.lightbend.akka.sbr.KeepOldestSettings$
-
- apply(boolean, Option<String>) - Static method in class com.lightbend.akka.sbr.KeepOldestSettings
-
- apply(Address, int) - Method in class com.lightbend.akka.sbr.KeepRefereeSettings$
-
- apply(Address, int) - Static method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- apply(String, FiniteDuration, Option<String>) - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings$
-
- apply(String, FiniteDuration, Option<String>) - Static method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- apply(FiniteDuration) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected$
-
- apply(FiniteDuration) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable$
-
- apply(boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult$
-
- apply(long, long, long) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats$
-
- apply(Set<UniqueAddress>) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved$
-
- apply(Deadline) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed$
-
- apply(boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseResult$
-
- apply(int, Option<String>) - Method in class com.lightbend.akka.sbr.StaticQuorumSettings$
-
- apply(int, Option<String>) - Static method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- apply$default$1() - Method in class akka.lease.kubernetes.LeaseActor.Acquire$
-
- apply$default$2() - Method in class akka.persistence.multidc.internal.PersistAll$
-
- apply$default$2() - Static method in class akka.persistence.multidc.internal.PersistAll
-
- apply$default$2() - Method in class akka.persistence.multidc.internal.PersistOne$
-
- apply$default$2() - Static method in class akka.persistence.multidc.internal.PersistOne
-
- apply$default$3() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource$
-
- apply$default$3() - Static method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- apply$default$4() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource$
-
- apply$default$4() - Static method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- apply$default$4() - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress$
-
- apply$default$5() - Method in class akka.persistence.multidc.testkit.Simulator$
-
- apply$default$5() - Static method in class akka.persistence.multidc.testkit.Simulator
-
- applyEvent(State, Event) - Method in interface akka.persistence.multidc.javadsl.EventHandler
-
Apply the event to the state.
- applyEventTrigger(S, ReplicatedEvent<E>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
- applyOperation(Counter.Updated) - Method in class akka.persistence.multidc.crdt.Counter
-
- applyOperation(Operation) - Method in interface akka.persistence.multidc.crdt.OpCrdt
-
- applyOperation(ORSet.DeltaOp) - Method in class akka.persistence.multidc.crdt.ORSet
-
- applyReplicatedEvent(S, ReplicatedEvent<E>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
Apply an event that was replicated from another DC to the given state.
- applySelfEvent(S, ReplicatedEvent<E>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
Apply an event that was persisted by this data center to the given state.
- aroundPreRestart(Throwable, Option<Object>) - Method in interface akka.cluster.fastfailover.FastFailoverSupport
-
- aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.cluster.fastfailover.FastFailoverSupport
-
- aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
INTERNAL API
- asyncWriteMessages(Seq<AtomicWrite>) - Method in class akka.persistence.multidc.internal.CassandraReplicatedEventJournal
-
- AtomicDeltaOp() - Constructor for class akka.persistence.multidc.crdt.ORSet.AtomicDeltaOp
-
- Attempt(String, int, Object) - Constructor for class akka.cluster.fastfailover.FastFailover.Attempt
-
- attempt() - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- attempt() - Method in class akka.cluster.fastfailover.FastFailover.Heartbeat
-
- attempt() - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- attempt() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- Attempt$() - Constructor for class akka.cluster.fastfailover.FastFailover.Attempt$
-
- ATTEMPT_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- ATTEMPT_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- ATTEMPT_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- ATTEMPT_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- AttemptResult(FastFailover.Attempt, ActorRef, akka.actor.Status$Status, long) - Constructor for class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- AttemptResult$() - Constructor for class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult$
-
- attemptTimeout() - Method in class akka.cluster.fastfailover.FastFailoverSettings
-
- autoPassivateAfter() - Method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
- awaitPersistenceInit(ActorSystem, String, String) - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- awaitPersistenceInit(ActorSystem) - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- awaitPersistenceInit(ActorSystem, String, String) - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- awaitPersistenceInit(ActorSystem) - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- AwaitPersistenceInit(String, String) - Constructor for class akka.persistence.multidc.testkit.CassandraLifecycle.AwaitPersistenceInit
-
- awaitPersistenceInit$default$2() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- awaitPersistenceInit$default$2() - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- awaitPersistenceInit$default$3() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- awaitPersistenceInit$default$3() - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- cancel(Object) - Method in class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- cancelAll() - Method in class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailover.Fail$
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailover.Failover$
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailover.Heartbeat
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward
-
- canEqual(Object) - Method in class akka.cluster.fastfailover.FastFailoverOperation.Timeout$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- canEqual(Object) - Method in class akka.lease.kubernetes.internal.Metadata
-
- canEqual(Object) - Method in class akka.lease.kubernetes.internal.Spec
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.Acquire
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.Granted$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.GrantedVersion
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.Granting$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.Idle$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.InvalidRequest
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.LeaseAcquired$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.LeaseCleared
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.LeaseReleased$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.LeaseTaken$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.PendingRead$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.PendingReadData
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.ReadRequired$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.Release
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseActor.Releasing$
-
- canEqual(Object) - Method in class akka.lease.kubernetes.LeaseResource
-
- canEqual(Object) - Method in class akka.persistence.gdpr.WithDataSubjectId
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.Counter
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.Counter.Updated
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.LwwTime
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.ORSet.DeltaGroup
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.VersionVector.After$
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.VersionVector.Before$
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.VersionVector.Concurrent$
-
- canEqual(Object) - Method in class akka.persistence.multidc.crdt.VersionVector.Same$
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.EventTaggingContextImpl
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationHotStandby.Reset$
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationWriter.Notification
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationWriter.Tick$
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.Passivate$
-
- canEqual(Object) - Static method in class akka.persistence.multidc.internal.Passivate
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.PersistAll
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.PersistNothing$
-
- canEqual(Object) - Static method in class akka.persistence.multidc.internal.PersistNothing
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.PersistOne
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventAck$
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.StopEffect$
-
- canEqual(Object) - Static method in class akka.persistence.multidc.internal.StopEffect
-
- canEqual(Object) - Method in class akka.persistence.multidc.internal.UnhandledCommand$
-
- canEqual(Object) - Static method in class akka.persistence.multidc.internal.UnhandledCommand
-
- canEqual(Object) - Method in class akka.persistence.multidc.ReplicatedEntitySnapshot
-
- canEqual(Object) - Method in class akka.persistence.update.JournaledEventImpl
-
- canEqual(Object) - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- canEqual(Object) - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ValidationResults
-
- canEqual(Object) - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- canEqual(Object) - Method in exception com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException
-
- canEqual(Object) - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.KeepOldestSettings
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLease$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownAll$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownIndirectlyConnected$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownReachable$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownUnreachable$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.NoLease$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseResult
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReverseDownIndirectlyConnected$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Tick$
-
- canEqual(Object) - Method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- CassandraJournalTransformer - Class in akka.persistence.update.cassandra.javadsl
-
akka.persistence.update.javadsl.JournalTransformer implementation for Cassandra.
- CassandraJournalTransformer(CassandraJournalTransformer) - Constructor for class akka.persistence.update.cassandra.javadsl.CassandraJournalTransformer
-
- CassandraJournalTransformer - Class in akka.persistence.update.cassandra.scaladsl
-
akka.persistence.update.scaladsl.JournalTransformer implementation for Cassandra.
- CassandraJournalTransformer(ExtendedActorSystem, Config, String) - Constructor for class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- CassandraJournalTransformer$ - Class in akka.persistence.update.cassandra.javadsl
-
- CassandraJournalTransformer$() - Constructor for class akka.persistence.update.cassandra.javadsl.CassandraJournalTransformer$
-
- CassandraJournalTransformer$ - Class in akka.persistence.update.cassandra.scaladsl
-
- CassandraJournalTransformer$() - Constructor for class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer$
-
- CassandraJournalUpdaterProvider - Class in akka.persistence.update.cassandra
-
- CassandraJournalUpdaterProvider(ExtendedActorSystem, Config, String) - Constructor for class akka.persistence.update.cassandra.CassandraJournalUpdaterProvider
-
- CassandraLifecycle - Class in akka.persistence.multidc.testkit
-
- CassandraLifecycle() - Constructor for class akka.persistence.multidc.testkit.CassandraLifecycle
-
- CassandraLifecycle$ - Class in akka.persistence.multidc.testkit
-
- CassandraLifecycle$() - Constructor for class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- CassandraLifecycle.AwaitPersistenceInit - Class in akka.persistence.multidc.testkit
-
- CassandraReadJournalProvider - Class in akka.persistence.multidc.internal
-
INTERNAL API
- CassandraReadJournalProvider(ExtendedActorSystem, Config, String) - Constructor for class akka.persistence.multidc.internal.CassandraReadJournalProvider
-
- CassandraReplicatedEventJournal - Class in akka.persistence.multidc.internal
-
INTERNAL API: Akka Persistence journal plugin for replication of events across multiple data centers.
- CassandraReplicatedEventJournal(Config) - Constructor for class akka.persistence.multidc.internal.CassandraReplicatedEventJournal
-
- CassandraReplicatedEventQuery - Class in akka.persistence.multidc.internal
-
INTERNAL API
- CassandraReplicatedEventQuery(ExtendedActorSystem, Config, String) - Constructor for class akka.persistence.multidc.internal.CassandraReplicatedEventQuery
-
- CassandraReplicatedEventQuery$ - Class in akka.persistence.multidc.internal
-
INTERNAL API
- CassandraReplicatedEventQuery$() - Constructor for class akka.persistence.multidc.internal.CassandraReplicatedEventQuery$
-
- CassandraReplicatedStatements - Interface in akka.persistence.multidc.internal
-
- changeCount() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- check() - Method in class com.lightbend.akka.diagnostics.ConfigChecker
-
Run all checks.
- Check(Function0<BoxedUnit>) - Constructor for class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.Check
-
- checkerKey() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- checkExecutionContext(ExecutionContext, LoggingAdapter, StarvationDetectorSettings, Function0<Object>) - Method in class com.lightbend.akka.diagnostics.StarvationDetector$
-
Creates and runs a StarvationDetector thread for the given ExecutionContext.
- checkExecutionContext(ExecutionContext, LoggingAdapter, StarvationDetectorSettings, BooleanSupplier) - Method in class com.lightbend.akka.diagnostics.StarvationDetector$
-
JAVA API
- checkExecutionContext(ExecutionContext, LoggingAdapter, StarvationDetectorSettings, Function0<Object>) - Static method in class com.lightbend.akka.diagnostics.StarvationDetector
-
Creates and runs a StarvationDetector thread for the given ExecutionContext.
- checkExecutionContext(ExecutionContext, LoggingAdapter, StarvationDetectorSettings, BooleanSupplier) - Static method in class com.lightbend.akka.diagnostics.StarvationDetector
-
JAVA API
- checkInterval() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings
-
- checkInterval() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- checkIntervalNanos() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread
-
- checkLease() - Method in class akka.lease.kubernetes.KubernetesLease
-
- checkOnce() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread
-
- checkSystemDispatcher(ActorSystem) - Method in class com.lightbend.akka.diagnostics.StarvationDetector$
-
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
- checkSystemDispatcher(ActorSystem, StarvationDetectorSettings) - Method in class com.lightbend.akka.diagnostics.StarvationDetector$
-
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
- checkSystemDispatcher(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.StarvationDetector
-
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
- checkSystemDispatcher(ActorSystem, StarvationDetectorSettings) - Static method in class com.lightbend.akka.diagnostics.StarvationDetector
-
Creates and runs a StarvationDetector thread for the dispatcher of the system's main dispatcher, i.e.
- child(String) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Get the child with the given name if it exists.
- child(String) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- children() - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Returns all supervised children; this method returns a view (i.e.
- children() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- clear() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- clear() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- clear() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- clear() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- clear() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- clear() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- clear() - Method in class akka.persistence.multidc.crdt.ORSet
-
Removes all elements from the set, but keeps the history.
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- clear() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- clearAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required int32 attempt = 2;
- clearAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
required int32 attempt = 1;
- clearAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required int32 attempt = 1;
- clearAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required int32 attempt = 1;
- clearDataSubjectId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
required string dataSubjectId = 1;
- clearDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required string dc = 1;
- clearDelta() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
required bytes delta = 1;
- clearDots() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- clearEnclosed() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required bytes enclosed = 1;
- clearEnclosedMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required bytes enclosedMessage = 1;
- clearEntityId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required string entityId = 1;
- clearEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string entityId = 2;
- clearEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string entityId = 2;
- clearEntries() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- clearEntries() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- clearError() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required bytes error = 2;
- clearEvent() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- clearEventsWritten() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- clearFromSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional int64 fromSeqNr = 4;
- clearIntElements() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- clearKey() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required string key = 1;
- clearLastOriginSeqNrPerDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- clearLongElements() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- clearManifest() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional string manifest = 4;
- clearMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required bytes message = 3;
- clearMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required bytes message = 2;
- clearMessageManifest() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
optional bytes messageManifest = 4;
- clearMessageManifest() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
optional bytes messageManifest = 4;
- clearMetaData() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- clearOperation() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSetDeltaOp operation = 1;
- clearOriginDc() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required string originDc = 1;
- clearOriginDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string originDc = 3;
- clearOtherElements() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- clearPayload() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional bytes payload = 2;
- clearPersistenceId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string persistenceId = 1;
- clearReplicationDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required string replicationDc = 1;
- clearReplicationSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required int64 replicationSeqNr = 2;
- clearResponses() - Method in class akka.persistence.multidc.testkit.Simulator
-
- clearSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required int64 seqNr = 2;
- clearSerializerId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required int32 serializerId = 2;
- clearSerializerId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional int32 serializerId = 3;
- clearSerializerId() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required int32 serializerId = 2;
- clearShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional string shardingTypeName = 5;
- clearShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional string shardingTypeName = 5;
- clearState() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- clearStringElements() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- clearTimestamp() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required int64 timestamp = 1;
- clearToSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required int64 toSeqNr = 3;
- clearUnderlying() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- clearValue() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
required bytes value = 1;
- clearVersion() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required int64 version = 2;
- clearVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- clearVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- clearVvector() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- clone() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- clone() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- clone() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- clone() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- clone() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- clone() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- clone() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- cluster() - Method in class com.lightbend.akka.sbr.SplitBrainResolver
-
- clusterRole() - Method in class akka.persistence.multidc.HotStandbySettings
-
- clusterShardingProps(Class<Command>, String, Supplier<ReplicatedEntity<Command, Event, State>>, PersistenceMultiDcSettings) - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity$
-
The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
- clusterShardingProps(Class<Command>, String, Supplier<ReplicatedEntity<Command, Event, State>>, PersistenceMultiDcSettings) - Static method in class akka.persistence.multidc.javadsl.ReplicatedEntity
-
The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
- clusterShardingProps(String, Function0<ReplicatedEntity<Command, Event, State>>, PersistenceMultiDcSettings, ClassTag<Command>) - Method in class akka.persistence.multidc.scaladsl.ReplicatedEntity$
-
The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
- clusterShardingProps(String, Function0<ReplicatedEntity<Command, Event, State>>, PersistenceMultiDcSettings, ClassTag<Command>) - Static method in class akka.persistence.multidc.scaladsl.ReplicatedEntity
-
The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
- collectThreadDumps() - Method in interface com.lightbend.akka.diagnostics.DiagnosticsRecorder.DiagnosticsRecorderMBean
-
- collectThreadDumps(Integer) - Method in interface com.lightbend.akka.diagnostics.DiagnosticsRecorder.DiagnosticsRecorderMBean
-
- collectThreadDumps() - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder.DiagnosticsRecorderMBeanImpl
-
- collectThreadDumps(Integer) - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder.DiagnosticsRecorderMBeanImpl
-
- com.example.hello.api - package com.example.hello.api
-
- com.example.hello.impl - package com.example.hello.impl
-
- com.lightbend.akka.diagnostics - package com.lightbend.akka.diagnostics
-
- com.lightbend.akka.diagnostics.mbean - package com.lightbend.akka.diagnostics.mbean
-
- com.lightbend.akka.sbr - package com.lightbend.akka.sbr
-
- combine(Function1<State, BoxedUnit>, Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.EffectUtils$
-
- combine(Function1<State, BoxedUnit>, Function1<State, BoxedUnit>) - Static method in class akka.persistence.multidc.internal.EffectUtils
-
- command(Function<Command, Effect<Event, State>>) - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity.CommandHandlers$
-
Convenience for simple commands that don't need the state and context.
- command(Function1<Command, Effect<Event, State>>) - Method in class akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandHandlerFactories
-
Convenience for simple commands that don't need the state and context.
- CommandContextImpl - Interface in akka.persistence.multidc.internal
-
- commandHandler() - Method in class akka.persistence.multidc.internal.CommandHandlerImpl
-
- CommandHandler<Command,Event,State> - Class in akka.persistence.multidc.javadsl
-
Not for user extension.
- CommandHandler() - Constructor for class akka.persistence.multidc.javadsl.CommandHandler
-
- commandHandler() - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity
-
Abstract method that must be implemented by concrete subclass to define
the command handlers of the entity.
- CommandHandler() - Method in class akka.persistence.multidc.scaladsl.ReplicatedEntity
-
- commandHandler() - Method in class akka.persistence.multidc.scaladsl.ReplicatedEntity
-
Abstract method that must be implemented by concrete subclass to define
the command handlers of the entity.
- CommandHandler$() - Constructor for class akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandHandler$
-
- CommandHandlerBuilder<Command,Event,State> - Class in akka.persistence.multidc.javadsl
-
- CommandHandlerBuilder(Class<Command>) - Constructor for class akka.persistence.multidc.javadsl.CommandHandlerBuilder
-
- commandHandlerBuilder(Class<Command>) - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity
-
- CommandHandlerFactories() - Constructor for class akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandHandlerFactories
-
- CommandHandlerImpl<Command,Event,State> - Class in akka.persistence.multidc.internal
-
Command handlers and optional functions for other signals,
e.g.
- CommandHandlerImpl(Function3<CommandContextImpl, State, Command, EffectImpl<Event, State>>, Map<Class<?>, Function3<CommandContextImpl, State, Object, EffectImpl<Event, State>>>) - Constructor for class akka.persistence.multidc.internal.CommandHandlerImpl
-
- CommandHandlerImpl$ - Class in akka.persistence.multidc.internal
-
INTERNAL API
- CommandHandlerImpl$() - Constructor for class akka.persistence.multidc.internal.CommandHandlerImpl$
-
- CommandHandlers$() - Constructor for class akka.persistence.multidc.javadsl.ReplicatedEntity.CommandHandlers$
-
- CommandToEffect<Command,Event,State> - Interface in akka.persistence.multidc.javadsl
-
SAM for reacting on commands
- compactionStrategy() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- Comparator$() - Constructor for class akka.persistence.multidc.serialization.WrappedPayloadSupport.Comparator$
-
- compare(WrappedPayload.Wrapped, WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.WrappedPayloadSupport.Comparator$
-
- compareTo(VersionVector) - Method in class akka.persistence.multidc.crdt.VersionVector
-
Compare two version vectors.
- completeAddressDefaultClusterId(String) - Method in class akka.persistence.multidc.testkit.ContactPoints
-
- compress(MessageLite) - Method in class akka.persistence.multidc.serialization.WrappedPayloadSupport
-
- concurrent() - Method in class akka.persistence.multidc.ReplicatedEventContext
-
- Concurrent$() - Constructor for class akka.persistence.multidc.crdt.VersionVector.Concurrent$
-
- ConcurrentInstance() - Method in class akka.persistence.multidc.crdt.VersionVector$
-
Java API: The VersionVector.Concurrent instance
- ConcurrentInstance() - Static method in class akka.persistence.multidc.crdt.VersionVector
-
Java API: The VersionVector.Concurrent instance
- config() - Method in class akka.persistence.multidc.internal.CassandraReplicatedEventQuery
-
This must be overridden because it is used by the CassandraStatements
- config() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- config() - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- config() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- ConfigChecker - Class in com.lightbend.akka.diagnostics
-
The ConfigChecker will try to find potential configuration issues.
- ConfigChecker(ExtendedActorSystem, Config, Config) - Constructor for class com.lightbend.akka.diagnostics.ConfigChecker
-
- ConfigChecker(ExtendedActorSystem) - Constructor for class com.lightbend.akka.diagnostics.ConfigChecker
-
- ConfigChecker$ - Class in com.lightbend.akka.diagnostics
-
- ConfigChecker$() - Constructor for class com.lightbend.akka.diagnostics.ConfigChecker$
-
- ConfigChecker.ConfigWarning - Class in com.lightbend.akka.diagnostics
-
- ConfigChecker.ConfigWarning$ - Class in com.lightbend.akka.diagnostics
-
- ConfigChecker.ValidationResults - Class in com.lightbend.akka.diagnostics
-
- ConfigChecker.ValidationResults$ - Class in com.lightbend.akka.diagnostics
-
- configPath() - Method in class akka.lease.kubernetes.KubernetesLease$
-
- configPath() - Static method in class akka.lease.kubernetes.KubernetesLease
-
- configure() - Method in class com.example.hello.impl.HelloModule
-
- ConfigWarning(String, String, Seq<String>, Seq<String>) - Constructor for class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- ConfigWarning$() - Constructor for class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning$
-
- configWarningFormat() - Method in class com.lightbend.akka.diagnostics.JsonFormats$
-
- configWarningFormat() - Static method in class com.lightbend.akka.diagnostics.JsonFormats
-
- ContactPoints - Class in akka.persistence.multidc.testkit
-
- ContactPoints(ExtendedActorSystem) - Constructor for class akka.persistence.multidc.testkit.ContactPoints
-
- ContactPoints$ - Class in akka.persistence.multidc.testkit
-
- ContactPoints$() - Constructor for class akka.persistence.multidc.testkit.ContactPoints$
-
- contains(String) - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
INTERNAL API
- contains(String) - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
INTERNAL API
- contains(A) - Method in class akka.persistence.multidc.crdt.ORSet
-
- contains(String) - Method in class akka.persistence.multidc.crdt.VersionVector
-
INTERNAL API
- coordinator() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- copy(String, int, Object) - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- copy(int) - Method in class akka.cluster.fastfailover.FastFailover.Heartbeat
-
- copy(int, akka.actor.Status$Status) - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- copy(FastFailover.Attempt, ActorRef, akka.actor.Status$Status, long) - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- copy(Object, ActorRef) - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward
-
- copy(Metadata, Spec, String, String) - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- copy(String, Option<String>) - Method in class akka.lease.kubernetes.internal.Metadata
-
- copy(String, long) - Method in class akka.lease.kubernetes.internal.Spec
-
- copy(Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.LeaseActor.Acquire
-
- copy(String, Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.LeaseActor.GrantedVersion
-
- copy(String) - Method in class akka.lease.kubernetes.LeaseActor.InvalidRequest
-
- copy(String) - Method in class akka.lease.kubernetes.LeaseActor.LeaseCleared
-
- copy(ActorRef, String, Function1<Option<Throwable>, BoxedUnit>, long) - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- copy(ActorRef, Function1<Option<Throwable>, BoxedUnit>) - Method in class akka.lease.kubernetes.LeaseActor.PendingReadData
-
- copy() - Method in class akka.lease.kubernetes.LeaseActor.Release
-
- copy(Option<String>, String, long) - Method in class akka.lease.kubernetes.LeaseResource
-
- copy(String, Option<T>) - Method in class akka.persistence.gdpr.WithDataSubjectId
-
- copy(BigInt) - Method in class akka.persistence.multidc.crdt.Counter
-
- copy(BigInt) - Method in class akka.persistence.multidc.crdt.Counter.Updated
-
- copy(long, String) - Method in class akka.persistence.multidc.crdt.LwwTime
-
- copy(TreeMap<String, Object>) - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
- copy(String, long) - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
- copy(ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp
-
- copy(IndexedSeq<ORSet.DeltaOp>) - Method in class akka.persistence.multidc.crdt.ORSet.DeltaGroup
-
- copy(ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp
-
- copy(ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp
-
- copy(String, long, ReplicatedEvent<Object>) - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- copy(String, boolean) - Method in class akka.persistence.multidc.internal.EventTaggingContextImpl
-
- copy(String, boolean, ReplicatedActorContextImpl) - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- copy(String, long, ReplicatedEvent<Object>, long, String) - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- copy(OptionVal<ActorRef>, Set<String>) - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache
-
- copy(FiniteDuration, FiniteDuration, int, int, FiniteDuration, FiniteDuration, Option<String>, Option<String>, String, CassandraCompactionStrategy, long, long, ConsistencyLevel, ConsistencyLevel, int, int, int) - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy(String, String, long, long, OptionVal<String>) - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- copy(Vector<NotificationWriter.EventsWritten>) - Method in class akka.persistence.multidc.internal.NotificationWriter.Notification
-
- copy(Seq<AtomicWrite>) - Method in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents
-
- copy(Seq<Event>, Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistAll
-
- copy(Event, Function1<State, BoxedUnit>) - Method in class akka.persistence.multidc.internal.PersistOne
-
- copy(long, String, String, VersionVector, OptionVal<String>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- copy(String, long, ReplicatedEvent<Event>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- copy(String, String, String, long, long, VersionVector, OptionVal<String>) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy(S, Map<String, Object>, VersionVector) - Method in class akka.persistence.multidc.ReplicatedEntitySnapshot
-
- copy(Object, String) - Method in class akka.persistence.update.JournaledEventImpl
-
- copy(String, String, Seq<String>, Seq<String>) - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- copy(Seq<ConfigChecker.ConfigWarning>) - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ValidationResults
-
- copy(Thread, Thread.State, StackTraceElement[]) - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- copy(String) - Method in exception com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException
-
- copy(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- copy(boolean, Option<String>) - Method in class com.lightbend.akka.sbr.KeepOldestSettings
-
- copy(Address, int) - Method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- copy(String, FiniteDuration, Option<String>) - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- copy(FiniteDuration) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
-
- copy(FiniteDuration) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable
-
- copy(boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult
-
- copy(long, long, long) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- copy(Set<UniqueAddress>) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved
-
- copy(Deadline) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed
-
- copy(boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseResult
-
- copy(int, Option<String>) - Method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- copy$default$1() - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- copy$default$1() - Method in class akka.cluster.fastfailover.FastFailover.Heartbeat
-
- copy$default$1() - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- copy$default$1() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- copy$default$1() - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward
-
- copy$default$1() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- copy$default$1() - Method in class akka.lease.kubernetes.internal.Metadata
-
- copy$default$1() - Method in class akka.lease.kubernetes.internal.Spec
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseActor.Acquire
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseActor.GrantedVersion
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseActor.InvalidRequest
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseActor.LeaseCleared
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseActor.PendingReadData
-
- copy$default$1() - Method in class akka.lease.kubernetes.LeaseResource
-
- copy$default$1() - Method in class akka.persistence.gdpr.WithDataSubjectId
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.Counter
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.Counter.Updated
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.LwwTime
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.ORSet.DeltaGroup
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp
-
- copy$default$1() - Method in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.EventTaggingContextImpl
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.NotificationWriter.Notification
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.PersistAll
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.PersistOne
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- copy$default$1() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$1() - Method in class akka.persistence.multidc.ReplicatedEntitySnapshot
-
- copy$default$1() - Method in class akka.persistence.update.JournaledEventImpl
-
- copy$default$1() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- copy$default$1() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ValidationResults
-
- copy$default$1() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- copy$default$1() - Method in exception com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException
-
- copy$default$1() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.KeepOldestSettings
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseResult
-
- copy$default$1() - Method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- copy$default$10() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$11() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$12() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$13() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$14() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$15() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$16() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$17() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$2() - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- copy$default$2() - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- copy$default$2() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- copy$default$2() - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward
-
- copy$default$2() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- copy$default$2() - Method in class akka.lease.kubernetes.internal.Metadata
-
- copy$default$2() - Method in class akka.lease.kubernetes.internal.Spec
-
- copy$default$2() - Method in class akka.lease.kubernetes.LeaseActor.GrantedVersion
-
- copy$default$2() - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- copy$default$2() - Method in class akka.lease.kubernetes.LeaseActor.PendingReadData
-
- copy$default$2() - Method in class akka.lease.kubernetes.LeaseResource
-
- copy$default$2() - Method in class akka.persistence.gdpr.WithDataSubjectId
-
- copy$default$2() - Method in class akka.persistence.multidc.crdt.LwwTime
-
- copy$default$2() - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.EventTaggingContextImpl
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.PersistAll
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.PersistOne
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- copy$default$2() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$2() - Method in class akka.persistence.update.JournaledEventImpl
-
- copy$default$2() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- copy$default$2() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- copy$default$2() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- copy$default$2() - Method in class com.lightbend.akka.sbr.KeepOldestSettings
-
- copy$default$2() - Method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- copy$default$2() - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- copy$default$2() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- copy$default$2() - Method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- copy$default$3() - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- copy$default$3() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- copy$default$3() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- copy$default$3() - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- copy$default$3() - Method in class akka.lease.kubernetes.LeaseResource
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- copy$default$3() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$3() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- copy$default$3() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- copy$default$3() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- copy$default$3() - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- copy$default$3() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- copy$default$4() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- copy$default$4() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- copy$default$4() - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- copy$default$4() - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- copy$default$4() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$4() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- copy$default$4() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- copy$default$4() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$4() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- copy$default$4() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- copy$default$5() - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- copy$default$5() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$5() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- copy$default$5() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- copy$default$5() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$6() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$6() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$7() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$7() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- copy$default$8() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- copy$default$9() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- count() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- Counter - Class in akka.persistence.multidc.crdt
-
- Counter(BigInt) - Constructor for class akka.persistence.multidc.crdt.Counter
-
- Counter$ - Class in akka.persistence.multidc.crdt
-
- Counter$() - Constructor for class akka.persistence.multidc.crdt.Counter$
-
- Counter.Updated - Class in akka.persistence.multidc.crdt
-
- Counter.Updated$ - Class in akka.persistence.multidc.crdt
-
- counterFromBinary(byte[]) - Method in class akka.persistence.multidc.serialization.CrdtSerializer
-
- counterToProtoByteArray(Counter) - Method in class akka.persistence.multidc.serialization.CrdtSerializer
-
- counterUpdatedFromBinary(byte[]) - Method in class akka.persistence.multidc.serialization.CrdtSerializer
-
- counterUpdatedToProtoBufByteArray(Counter.Updated) - Method in class akka.persistence.multidc.serialization.CrdtSerializer
-
- Crdts - Class in akka.persistence.multidc.serialization
-
- Crdts.Counter - Class in akka.persistence.multidc.serialization
-
Protobuf type Counter
- Crdts.Counter.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type Counter
- Crdts.CounterOrBuilder - Interface in akka.persistence.multidc.serialization
-
- Crdts.CounterUpdate - Class in akka.persistence.multidc.serialization
-
Protobuf type CounterUpdate
- Crdts.CounterUpdate.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type CounterUpdate
- Crdts.CounterUpdateOrBuilder - Interface in akka.persistence.multidc.serialization
-
- Crdts.ORSet - Class in akka.persistence.multidc.serialization
-
Protobuf type ORSet
- Crdts.ORSet.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type ORSet
- Crdts.ORSetDeltaGroup - Class in akka.persistence.multidc.serialization
-
Protobuf type ORSetDeltaGroup
- Crdts.ORSetDeltaGroup.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type ORSetDeltaGroup
- Crdts.ORSetDeltaGroup.Entry - Class in akka.persistence.multidc.serialization
-
Protobuf type ORSetDeltaGroup.Entry
- Crdts.ORSetDeltaGroup.Entry.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type ORSetDeltaGroup.Entry
- Crdts.ORSetDeltaGroup.EntryOrBuilder - Interface in akka.persistence.multidc.serialization
-
- Crdts.ORSetDeltaGroupOrBuilder - Interface in akka.persistence.multidc.serialization
-
- Crdts.ORSetDeltaOp - Enum in akka.persistence.multidc.serialization
-
Protobuf enum ORSetDeltaOp
- Crdts.ORSetOrBuilder - Interface in akka.persistence.multidc.serialization
-
- Crdts.VersionVector - Class in akka.persistence.multidc.serialization
-
Protobuf type VersionVector
- Crdts.VersionVector.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type VersionVector
- Crdts.VersionVector.Entry - Class in akka.persistence.multidc.serialization
-
Protobuf type VersionVector.Entry
- Crdts.VersionVector.Entry.Builder - Class in akka.persistence.multidc.serialization
-
Protobuf type VersionVector.Entry
- Crdts.VersionVector.EntryOrBuilder - Interface in akka.persistence.multidc.serialization
-
- Crdts.VersionVectorOrBuilder - Interface in akka.persistence.multidc.serialization
-
- CrdtSerializer - Class in akka.persistence.multidc.serialization
-
INTERNAL API
- CrdtSerializer(ExtendedActorSystem) - Constructor for class akka.persistence.multidc.serialization.CrdtSerializer
-
- create(ActorSystem) - Method in class akka.cluster.fastfailover.FastFailoverSettings$
-
Java API: Create settings from the default configuration
akka.cluster.fast-failover.
- create(Config) - Method in class akka.cluster.fastfailover.FastFailoverSettings$
-
Java API: Create settings from a configuration with the same layout as
the default configuration akka.cluster.fast-failover.
- create(ActorSystem) - Static method in class akka.cluster.fastfailover.FastFailoverSettings
-
Java API: Create settings from the default configuration
akka.cluster.fast-failover.
- create(Config) - Static method in class akka.cluster.fastfailover.FastFailoverSettings
-
Java API: Create settings from a configuration with the same layout as
the default configuration akka.cluster.fast-failover.
- create(ActorSystem) - Method in class akka.persistence.gdpr.GdprSettings$
-
- create(Config) - Method in class akka.persistence.gdpr.GdprSettings$
-
- create(ActorSystem) - Static method in class akka.persistence.gdpr.GdprSettings
-
- create(Config) - Static method in class akka.persistence.gdpr.GdprSettings
-
- create(ActorSystem, String) - Method in class akka.persistence.gdpr.JcaSettings$
-
- create(Config) - Method in class akka.persistence.gdpr.JcaSettings$
-
- create(ActorSystem, String) - Static method in class akka.persistence.gdpr.JcaSettings
-
- create(Config) - Static method in class akka.persistence.gdpr.JcaSettings
-
- create(String, T) - Method in class akka.persistence.gdpr.WithDataSubjectId$
-
Java API: factory method for WithDataSubjectId including payload
that need to be encrypted for GDPR.
- create(String, T) - Static method in class akka.persistence.gdpr.WithDataSubjectId
-
Java API: factory method for WithDataSubjectId including payload
that need to be encrypted for GDPR.
- create(String) - Method in class akka.persistence.multidc.crdt.ORSet$
-
Java API
- create(String) - Static method in class akka.persistence.multidc.crdt.ORSet
-
Java API
- create() - Method in class akka.persistence.multidc.crdt.VersionVector$
-
Java API
- create() - Static method in class akka.persistence.multidc.crdt.VersionVector
-
Java API
- create(CommandToEffect<Command, Event, State>) - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity.CommandHandlers$
-
- create(ActorSystem) - Method in class akka.persistence.multidc.PersistenceMultiDcSettings$
-
Java API
- create(Config) - Method in class akka.persistence.multidc.PersistenceMultiDcSettings$
-
Java API
- create(ActorSystem) - Static method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
Java API
- create(Config) - Static method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
Java API
- create(Supplier<ReplicatedEntity<C, E, S>>, ActorSystem, String, Set<String>, Optional<String>) - Method in class akka.persistence.multidc.testkit.Simulator$
-
Java API
- create(Supplier<ReplicatedEntity<C, E, S>>, ActorSystem, String, Set<String>, Optional<String>) - Static method in class akka.persistence.multidc.testkit.Simulator
-
Java API
- create(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings$
-
Java API
- create(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Static method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings
-
Java API
- create$default$5() - Method in class akka.persistence.multidc.testkit.Simulator$
-
- create$default$5() - Static method in class akka.persistence.multidc.testkit.Simulator
-
- createExtension(ExtendedActorSystem) - Method in class akka.cluster.fastfailover.FastFailover$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.cluster.fastfailover.FastFailover
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.gdpr.javadsl.GdprEncryption$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.persistence.gdpr.javadsl.GdprEncryption
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.gdpr.scaladsl.GdprEncryption$
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.multidc.internal.TheMaterializer$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.persistence.multidc.internal.TheMaterializer
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.multidc.testkit.ContactPoints$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.persistence.multidc.testkit.ContactPoints
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.update.javadsl.JournalUpdater$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.persistence.update.javadsl.JournalUpdater
-
- createExtension(ExtendedActorSystem) - Method in class akka.persistence.update.scaladsl.JournalUpdater$
-
- createExtension(ExtendedActorSystem) - Static method in class akka.persistence.update.scaladsl.JournalUpdater
-
- createExtension(ExtendedActorSystem) - Method in class com.lightbend.akka.diagnostics.DiagnosticsExtension$
-
- createExtension(ExtendedActorSystem) - Static method in class com.lightbend.akka.diagnostics.DiagnosticsExtension
-
- createExtension(ExtendedActorSystem) - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder$
-
- createExtension(ExtendedActorSystem) - Static method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
- createExtension(ExtendedActorSystem) - Method in class com.lightbend.akka.diagnostics.ManagementRoutes$
-
- createExtension(ExtendedActorSystem) - Static method in class com.lightbend.akka.diagnostics.ManagementRoutes
-
- createKeyspace() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- createNotificationKeyspace(String, String) - Method in interface akka.persistence.multidc.internal.CassandraReplicatedStatements
-
- createNotificationTable() - Method in interface akka.persistence.multidc.internal.CassandraReplicatedStatements
-
- createReplicatedEvent(EE, long) - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
- createShredded(Class<T>, String) - Method in class akka.persistence.gdpr.WithDataSubjectId$
-
Java API: factory method for WithDataSubjectId with payload
that is shredded
- createShredded(Class<T>, String) - Static method in class akka.persistence.gdpr.WithDataSubjectId
-
Java API: factory method for WithDataSubjectId with payload
that is shredded
- createTable() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- currentSystem() - Method in interface akka.persistence.gdpr.internal.GdprSerializerAccess
-
- currentTimeMillis() - Method in class akka.persistence.multidc.internal.AlwaysIncreasingClock
-
- currentTimeMillis() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
Called to create the timestamp when an event is persisted.
- currentTimeMillis() - Method in interface akka.persistence.multidc.WallClock
-
- gatherStartupInfo() - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
- gcGraceSeconds() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- gcmTlen() - Method in class akka.persistence.gdpr.GdprSettings
-
- GDPR - Class in akka.persistence.gdpr.serialization
-
- GDPR.WithDataSubjectId - Class in akka.persistence.gdpr.serialization
-
Protobuf type WithDataSubjectId
- GDPR.WithDataSubjectId.Builder - Class in akka.persistence.gdpr.serialization
-
Protobuf type WithDataSubjectId
- GDPR.WithDataSubjectIdOrBuilder - Interface in akka.persistence.gdpr.serialization
-
- gdprEncrypterConfigPath() - Method in class akka.persistence.gdpr.scaladsl.GdprEncryption$
-
- GdprEncryption - Class in akka.persistence.gdpr.javadsl
-
Extension point for plugging in encryption for GDPR.
- GdprEncryption() - Constructor for class akka.persistence.gdpr.javadsl.GdprEncryption
-
- GdprEncryption - Interface in akka.persistence.gdpr.scaladsl
-
Extension point for plugging in encryption for GDPR.
- GdprEncryption$ - Class in akka.persistence.gdpr.javadsl
-
- GdprEncryption$() - Constructor for class akka.persistence.gdpr.javadsl.GdprEncryption$
-
- GdprEncryption$ - Class in akka.persistence.gdpr.scaladsl
-
- GdprEncryption$() - Constructor for class akka.persistence.gdpr.scaladsl.GdprEncryption$
-
- GdprFormat - Class in akka.persistence.gdpr.playjson
-
- GdprFormat() - Constructor for class akka.persistence.gdpr.playjson.GdprFormat
-
- GdprFormat$ - Class in akka.persistence.gdpr.playjson
-
- GdprFormat$() - Constructor for class akka.persistence.gdpr.playjson.GdprFormat$
-
- GdprModule - Class in akka.persistence.gdpr.jackson
-
Complete module with support for all features.
- GdprModule() - Constructor for class akka.persistence.gdpr.jackson.GdprModule
-
- GdprModule$ - Class in akka.persistence.gdpr.jackson
-
- GdprModule$() - Constructor for class akka.persistence.gdpr.jackson.GdprModule$
-
- GdprSerializer - Class in akka.persistence.gdpr
-
- GdprSerializer(ExtendedActorSystem) - Constructor for class akka.persistence.gdpr.GdprSerializer
-
- gdprSerializer() - Method in interface akka.persistence.gdpr.internal.GdprSerializerAccess
-
- GdprSerializer$ - Class in akka.persistence.gdpr
-
- GdprSerializer$() - Constructor for class akka.persistence.gdpr.GdprSerializer$
-
- GdprSerializerAccess - Interface in akka.persistence.gdpr.internal
-
INTERNAL API
- GdprSerializerAccess$ - Class in akka.persistence.gdpr.internal
-
INTERNAL API
- GdprSerializerAccess$() - Constructor for class akka.persistence.gdpr.internal.GdprSerializerAccess$
-
- GdprSettings - Class in akka.persistence.gdpr
-
- GdprSettings(int, int) - Constructor for class akka.persistence.gdpr.GdprSettings
-
- gdprSettings() - Method in class akka.persistence.gdpr.scaladsl.AbstractGdprEncryption
-
- GdprSettings$ - Class in akka.persistence.gdpr
-
- GdprSettings$() - Constructor for class akka.persistence.gdpr.GdprSettings$
-
- get(ActorSystem) - Method in class akka.cluster.fastfailover.FastFailover$
-
- get(ActorSystem) - Static method in class akka.cluster.fastfailover.FastFailover
-
- get(ActorSystem) - Method in class akka.persistence.gdpr.javadsl.GdprEncryption$
-
- get(ActorSystem) - Static method in class akka.persistence.gdpr.javadsl.GdprEncryption
-
- get(ActorSystem) - Method in class akka.persistence.gdpr.scaladsl.GdprEncryption$
-
Java API
- get(ActorSystem) - Method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton$
-
- get(ActorSystem) - Static method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton
-
- get(ActorSystem) - Method in class akka.persistence.multidc.internal.TheMaterializer$
-
- get(ActorSystem) - Static method in class akka.persistence.multidc.internal.TheMaterializer
-
- get(ActorSystem) - Method in class akka.persistence.multidc.testkit.ContactPoints$
-
- get(ActorSystem) - Static method in class akka.persistence.multidc.testkit.ContactPoints
-
- get(ActorSystem) - Method in class akka.persistence.update.javadsl.JournalUpdater$
-
- get(ActorSystem) - Static method in class akka.persistence.update.javadsl.JournalUpdater
-
- get(ActorSystem) - Method in class akka.persistence.update.scaladsl.JournalUpdater$
-
- get(ActorSystem) - Static method in class akka.persistence.update.scaladsl.JournalUpdater
-
- get(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.DiagnosticsExtension
-
- get(ActorSystem) - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder$
-
- get(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
- get(ActorSystem) - Static method in class com.lightbend.akka.diagnostics.ManagementRoutes
-
- getAllDcs() - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity
-
All data centers
- getAllDcs() - Method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required int32 attempt = 2;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required int32 attempt = 2;
- getAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required int32 attempt = 2;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
required int32 attempt = 1;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
required int32 attempt = 1;
- getAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.HeartbeatOrBuilder
-
required int32 attempt = 1;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required int32 attempt = 1;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
required int32 attempt = 1;
- getAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultFailureOrBuilder
-
required int32 attempt = 1;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required int32 attempt = 1;
- getAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
required int32 attempt = 1;
- getAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultSuccessOrBuilder
-
required int32 attempt = 1;
- getChildren() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Returns all supervised children; this method returns a view (i.e.
- getChildren() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getDataSubjectId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
required string dataSubjectId = 1;
- getDataSubjectId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
required string dataSubjectId = 1;
- getDataSubjectId() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
required string dataSubjectId = 1;
- getDataSubjectIdBytes() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
required string dataSubjectId = 1;
- getDataSubjectIdBytes() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
required string dataSubjectId = 1;
- getDataSubjectIdBytes() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
required string dataSubjectId = 1;
- getDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required string dc = 1;
- getDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
required string dc = 1;
- getDc() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNrOrBuilder
-
required string dc = 1;
- getDcBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required string dc = 1;
- getDcBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
required string dc = 1;
- getDcBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNrOrBuilder
-
required string dc = 1;
- getDefaultInstance() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- getDefaultInstance() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- getDefaultInstance() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- getDefaultInstance() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- getDefaultInstance() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- getDefaultInstance() - Static method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.Counter
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- getDefaultInstance() - Static method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- getDefaultInstanceForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- getDefaultInstanceForType() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.Counter
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- getDefaultInstanceForType() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- getDelta() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
required bytes delta = 1;
- getDelta() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
required bytes delta = 1;
- getDelta() - Method in interface akka.persistence.multidc.serialization.Crdts.CounterUpdateOrBuilder
-
required bytes delta = 1;
- getDescription(MBeanInfo) - Method in class com.lightbend.akka.diagnostics.mbean.AnnotatedStandardMXBean
-
- getDescription(MBeanAttributeInfo) - Method in class com.lightbend.akka.diagnostics.mbean.AnnotatedStandardMXBean
-
Returns the description of an Attribute
- getDescription(MBeanOperationInfo) - Method in class com.lightbend.akka.diagnostics.mbean.AnnotatedStandardMXBean
-
Returns the description of an operation
- getDescription(MBeanOperationInfo, MBeanParameterInfo, int) - Method in class com.lightbend.akka.diagnostics.mbean.AnnotatedStandardMXBean
-
Returns the description of a parameter
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- getDescriptor() - Static method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- getDescriptor() - Static method in class akka.persistence.gdpr.serialization.GDPR
-
- getDescriptor() - Static method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- getDescriptor() - Static method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.Counter
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
- getDescriptor() - Static method in enum akka.persistence.multidc.serialization.Crdts.ORSetDeltaOp
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.WrappedPayload
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- getDescriptor() - Static method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- getDescriptorForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- getDescriptorForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- getDescriptorForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- getDescriptorForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- getDescriptorForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- getDescriptorForType() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- getDescriptorForType() - Method in enum akka.persistence.multidc.serialization.Crdts.ORSetDeltaOp
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- getDescriptorForType() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- getDispatcher() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Returns the dispatcher (MessageDispatcher) that is used for this Actor.
- getDispatcher() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getDots(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDots(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .VersionVector dots = 3;
- getDots(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .VersionVector dots = 3;
- getDotsBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDotsBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDotsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDotsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .VersionVector dots = 3;
- getDotsCount() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .VersionVector dots = 3;
- getDotsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDotsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .VersionVector dots = 3;
- getDotsList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .VersionVector dots = 3;
- getDotsOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDotsOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .VersionVector dots = 3;
- getDotsOrBuilder(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .VersionVector dots = 3;
- getDotsOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- getDotsOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .VersionVector dots = 3;
- getDotsOrBuilderList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .VersionVector dots = 3;
- getElements() - Method in class akka.persistence.multidc.crdt.ORSet
-
Java API
- getEnclosed() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required bytes enclosed = 1;
- getEnclosed() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
required bytes enclosed = 1;
- getEnclosed() - Method in interface akka.persistence.multidc.serialization.WrappedPayload.WrappedOrBuilder
-
required bytes enclosed = 1;
- getEnclosedMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required bytes enclosedMessage = 1;
- getEnclosedMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
required bytes enclosedMessage = 1;
- getEnclosedMessage() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.PayloadOrBuilder
-
required bytes enclosedMessage = 1;
- getEntityId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required string entityId = 1;
- getEntityId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required string entityId = 1;
- getEntityId() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required string entityId = 1;
- getEntityId() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
The id of the current entity
- getEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string entityId = 2;
- getEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required string entityId = 2;
- getEntityId() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required string entityId = 2;
- getEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string entityId = 2;
- getEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required string entityId = 2;
- getEntityId() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required string entityId = 2;
- getEntityIdBytes() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required string entityId = 1;
- getEntityIdBytes() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required string entityId = 1;
- getEntityIdBytes() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required string entityId = 1;
- getEntityIdBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string entityId = 2;
- getEntityIdBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required string entityId = 2;
- getEntityIdBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required string entityId = 2;
- getEntityIdBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string entityId = 2;
- getEntityIdBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required string entityId = 2;
- getEntityIdBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required string entityId = 2;
- getEntries(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntries(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntries(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroupOrBuilder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntries(int) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntries(int) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
repeated .VersionVector.Entry entries = 1;
- getEntries(int) - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVectorOrBuilder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesCount() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroupOrBuilder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesCount() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesCount() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
repeated .VersionVector.Entry entries = 1;
- getEntriesCount() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVectorOrBuilder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroupOrBuilder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesList() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesList() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
repeated .VersionVector.Entry entries = 1;
- getEntriesList() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVectorOrBuilder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroupOrBuilder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
repeated .VersionVector.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVectorOrBuilder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesOrBuilderList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroupOrBuilder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- getEntriesOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- getEntriesOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
repeated .VersionVector.Entry entries = 1;
- getEntriesOrBuilderList() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVectorOrBuilder
-
repeated .VersionVector.Entry entries = 1;
- getError() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required bytes error = 2;
- getError() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
required bytes error = 2;
- getError() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultFailureOrBuilder
-
required bytes error = 2;
- getEvent() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- getEvent() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
optional .Wrapped event = 4;
- getEvent() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
optional .Wrapped event = 4;
- getEventBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- getEventOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- getEventOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
optional .Wrapped event = 4;
- getEventOrBuilder() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
optional .Wrapped event = 4;
- getEvents() - Method in class akka.persistence.multidc.testkit.Simulator
-
- getEventsWritten(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWritten(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWritten(int) - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.NotificationOrBuilder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenBuilderList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenCount() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenCount() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenCount() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.NotificationOrBuilder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenList() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.NotificationOrBuilder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenOrBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenOrBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenOrBuilder(int) - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.NotificationOrBuilder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenOrBuilderList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenOrBuilderList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getEventsWrittenOrBuilderList() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.NotificationOrBuilder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- getFromSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional int64 fromSeqNr = 4;
- getFromSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
optional int64 fromSeqNr = 4;
- getFromSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
optional int64 fromSeqNr = 4;
- getIntElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- getIntElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated sint32 intElements = 5 [packed = true];
- getIntElements(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated sint32 intElements = 5 [packed = true];
- getIntElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- getIntElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated sint32 intElements = 5 [packed = true];
- getIntElementsCount() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated sint32 intElements = 5 [packed = true];
- getIntElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- getIntElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated sint32 intElements = 5 [packed = true];
- getIntElementsList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated sint32 intElements = 5 [packed = true];
- getJournalUpdaterFor(Class<T>, String) - Method in class akka.persistence.update.javadsl.JournalUpdater
-
- getJournalUpdaterFor(Class<T>, String) - Method in class akka.persistence.update.scaladsl.JournalUpdater
-
INTERNAL API: used by javadsl extension
- getKey(String) - Method in interface akka.persistence.gdpr.javadsl.KeyManagement
-
Retrieve the key identified by dataSubjectId, returning None if the key has been shredded.
- getKey(String) - Method in class akka.persistence.gdpr.JCAKeyManagement
-
- getKey(String) - Method in class akka.persistence.gdpr.scaladsl.DelegatingKeyManagement
-
- getKey(String) - Method in interface akka.persistence.gdpr.scaladsl.KeyManagement
-
Retrieve the key identified by dataSubjectId, returning None if the key has been shredded.
- getKey() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required string key = 1;
- getKey() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
required string key = 1;
- getKey() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVector.EntryOrBuilder
-
required string key = 1;
- getKeyBytes() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required string key = 1;
- getKeyBytes() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
required string key = 1;
- getKeyBytes() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVector.EntryOrBuilder
-
required string key = 1;
- getLastOriginSeqNrPerDc(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDc(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDc(int) - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcBuilderList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcCount() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcCount() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcCount() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcList() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcOrBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcOrBuilder(int) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcOrBuilder(int) - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcOrBuilderList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcOrBuilderList() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLastOriginSeqNrPerDcOrBuilderList() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- getLongElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- getLongElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated sint64 longElements = 6 [packed = true];
- getLongElements(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated sint64 longElements = 6 [packed = true];
- getLongElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- getLongElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated sint64 longElements = 6 [packed = true];
- getLongElementsCount() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated sint64 longElements = 6 [packed = true];
- getLongElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- getLongElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated sint64 longElements = 6 [packed = true];
- getLongElementsList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated sint64 longElements = 6 [packed = true];
- getManifest() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional string manifest = 4;
- getManifest() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional string manifest = 4;
- getManifest() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional string manifest = 4;
- getManifestBytes() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional string manifest = 4;
- getManifestBytes() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional string manifest = 4;
- getManifestBytes() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional string manifest = 4;
- getMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required bytes message = 3;
- getMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required bytes message = 3;
- getMessage() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required bytes message = 3;
- getMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required bytes message = 2;
- getMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
required bytes message = 2;
- getMessage() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultSuccessOrBuilder
-
required bytes message = 2;
- getMessageManifest() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
optional bytes messageManifest = 4;
- getMessageManifest() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
optional bytes messageManifest = 4;
- getMessageManifest() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.PayloadOrBuilder
-
optional bytes messageManifest = 4;
- getMessageManifest() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
optional bytes messageManifest = 4;
- getMessageManifest() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
optional bytes messageManifest = 4;
- getMessageManifest() - Method in interface akka.persistence.multidc.serialization.WrappedPayload.WrappedOrBuilder
-
optional bytes messageManifest = 4;
- getMetaData() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- getMetaData() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required .ReplicatedEventMetaData metaData = 3;
- getMetaData() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required .ReplicatedEventMetaData metaData = 3;
- getMetaDataBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- getMetaDataOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- getMetaDataOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required .ReplicatedEventMetaData metaData = 3;
- getMetaDataOrBuilder() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required .ReplicatedEventMetaData metaData = 3;
- getModuleName() - Method in class akka.persistence.gdpr.jackson.GdprModule
-
- getNumber() - Method in enum akka.persistence.multidc.serialization.Crdts.ORSetDeltaOp
-
- getOperation() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSetDeltaOp operation = 1;
- getOperation() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
required .ORSetDeltaOp operation = 1;
- getOperation() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.EntryOrBuilder
-
required .ORSetDeltaOp operation = 1;
- getOrCreateKey(String) - Method in interface akka.persistence.gdpr.javadsl.KeyManagement
-
Create a [SecretKey] if it doesn't exist already.
- getOrCreateKey(String) - Method in class akka.persistence.gdpr.JCAKeyManagement
-
- getOrCreateKey(String) - Method in class akka.persistence.gdpr.scaladsl.DelegatingKeyManagement
-
- getOrCreateKey(String) - Method in interface akka.persistence.gdpr.scaladsl.KeyManagement
-
Create a SecretKey if it doesn't exist already.
- getOriginDc() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required string originDc = 1;
- getOriginDc() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
required string originDc = 1;
- getOriginDc() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
required string originDc = 1;
- getOriginDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string originDc = 3;
- getOriginDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required string originDc = 3;
- getOriginDc() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required string originDc = 3;
- getOriginDcBytes() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required string originDc = 1;
- getOriginDcBytes() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
required string originDc = 1;
- getOriginDcBytes() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
required string originDc = 1;
- getOriginDcBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string originDc = 3;
- getOriginDcBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required string originDc = 3;
- getOriginDcBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required string originDc = 3;
- getOtherDcs() - Method in class akka.persistence.multidc.javadsl.ReplicatedEntity
-
Other data centers, allDcs without selfDc
- getOtherDcs(String) - Method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
- getOtherElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .Wrapped otherElements = 7;
- getOtherElements(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .Wrapped otherElements = 7;
- getOtherElementsCount() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .Wrapped otherElements = 7;
- getOtherElementsList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsOrBuilder(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .Wrapped otherElements = 7;
- getOtherElementsOrBuilder(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- getOtherElementsOrBuilderList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated .Wrapped otherElements = 7;
- getOtherElementsOrBuilderList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated .Wrapped otherElements = 7;
- getParameterName(MBeanOperationInfo, MBeanParameterInfo, int) - Method in class com.lightbend.akka.diagnostics.mbean.AnnotatedStandardMXBean
-
Returns the name of a parameter
- getParent() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Returns the supervising parent ActorRef.
- getParent() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getParserForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- getParserForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- getParserForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- getParserForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- getParserForType() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- getParserForType() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.Counter
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- getParserForType() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- getPayload() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional bytes payload = 2;
- getPayload() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional bytes payload = 2;
- getPayload() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional bytes payload = 2;
- getPayload() - Method in class akka.persistence.gdpr.WithDataSubjectId
-
Java API: Get the payload, unless it has been shredded.
- getPersistenceId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string persistenceId = 1;
- getPersistenceId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required string persistenceId = 1;
- getPersistenceId() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required string persistenceId = 1;
- getPersistenceIdBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string persistenceId = 1;
- getPersistenceIdBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required string persistenceId = 1;
- getPersistenceIdBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required string persistenceId = 1;
- getReceiveTimeout() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Gets the current receive timeout.
- getReceiveTimeout() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getReplicationDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required string replicationDc = 1;
- getReplicationDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required string replicationDc = 1;
- getReplicationDc() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required string replicationDc = 1;
- getReplicationDcBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required string replicationDc = 1;
- getReplicationDcBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required string replicationDc = 1;
- getReplicationDcBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required string replicationDc = 1;
- getReplicationSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required int64 replicationSeqNr = 2;
- getReplicationSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required int64 replicationSeqNr = 2;
- getReplicationSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required int64 replicationSeqNr = 2;
- getReportFileLocation() - Method in interface com.lightbend.akka.diagnostics.DiagnosticsRecorder.DiagnosticsRecorderMBean
-
- getReportFileLocation() - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder.DiagnosticsRecorderMBeanImpl
-
- getResponses() - Method in class akka.persistence.multidc.testkit.Simulator
-
Java API
- getSelf() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
The 'self' field holds the ActorRef for this actor.
- getSelf() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Commands can be sent with the ReplicatedEntity itself with this ActorRef, or it can be passed
in reply messages.
- getSelf() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getSelfDc() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
Java API: Name of the data-center in which this entity is running
- getSelfMessages() - Method in class akka.persistence.multidc.testkit.Simulator
-
Java API
- getSender() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Replies can be sent with this sender() ActorRef an ActorRef that is passed in
the command.
- getSender() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required int64 seqNr = 2;
- getSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
required int64 seqNr = 2;
- getSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNrOrBuilder
-
required int64 seqNr = 2;
- getSerializedSize() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- getSerializedSize() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- getSerializedSize() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- getSerializedSize() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- getSerializedSize() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- getSerializedSize() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.Counter
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- getSerializedSize() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- getSerializerId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required int32 serializerId = 2;
- getSerializerId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
required int32 serializerId = 2;
- getSerializerId() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.PayloadOrBuilder
-
required int32 serializerId = 2;
- getSerializerId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional int32 serializerId = 3;
- getSerializerId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional int32 serializerId = 3;
- getSerializerId() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional int32 serializerId = 3;
- getSerializerId() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required int32 serializerId = 2;
- getSerializerId() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
required int32 serializerId = 2;
- getSerializerId() - Method in interface akka.persistence.multidc.serialization.WrappedPayload.WrappedOrBuilder
-
required int32 serializerId = 2;
- getShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional string shardingTypeName = 5;
- getShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
optional string shardingTypeName = 5;
- getShardingTypeName() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
optional string shardingTypeName = 5;
- getShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional string shardingTypeName = 5;
- getShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
optional string shardingTypeName = 5;
- getShardingTypeName() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
optional string shardingTypeName = 5;
- getShardingTypeNameBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional string shardingTypeName = 5;
- getShardingTypeNameBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
optional string shardingTypeName = 5;
- getShardingTypeNameBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
optional string shardingTypeName = 5;
- getShardingTypeNameBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional string shardingTypeName = 5;
- getShardingTypeNameBytes() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
optional string shardingTypeName = 5;
- getShardingTypeNameBytes() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
optional string shardingTypeName = 5;
- getState() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- getState() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
required .Wrapped state = 1;
- getState() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
required .Wrapped state = 1;
- getStateBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- getStateOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- getStateOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
required .Wrapped state = 1;
- getStateOrBuilder() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
required .Wrapped state = 1;
- getStringElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- getStringElements(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated string stringElements = 4;
- getStringElements(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated string stringElements = 4;
- getStringElementsBytes(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- getStringElementsBytes(int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated string stringElements = 4;
- getStringElementsBytes(int) - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated string stringElements = 4;
- getStringElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- getStringElementsCount() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated string stringElements = 4;
- getStringElementsCount() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated string stringElements = 4;
- getStringElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- getStringElementsList() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
repeated string stringElements = 4;
- getStringElementsList() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
repeated string stringElements = 4;
- getSystem() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
The system that the actor belongs to.
- getSystem() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getTimers() - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Start and cancel timers via the enclosed TimerScheduler.
- getTimers() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- getTimestamp() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required int64 timestamp = 1;
- getTimestamp() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required int64 timestamp = 1;
- getTimestamp() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required int64 timestamp = 1;
- getToSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required int64 toSeqNr = 3;
- getToSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required int64 toSeqNr = 3;
- getToSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required int64 toSeqNr = 3;
- getTypeId() - Static method in class akka.persistence.gdpr.jackson.GdprModule
-
- getUnderlying() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- getUnderlying() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
required .ORSet underlying = 2;
- getUnderlying() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.EntryOrBuilder
-
required .ORSet underlying = 2;
- getUnderlyingBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- getUnderlyingOrBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- getUnderlyingOrBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
required .ORSet underlying = 2;
- getUnderlyingOrBuilder() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.EntryOrBuilder
-
required .ORSet underlying = 2;
- getUnknownFields() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- getUnknownFields() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
- getUnknownFields() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- getUnknownFields() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
- getUnknownFields() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- getUnknownFields() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.Counter
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- getUnknownFields() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- getValue() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
required bytes value = 1;
- getValue() - Method in class akka.persistence.multidc.serialization.Crdts.Counter
-
required bytes value = 1;
- getValue() - Method in interface akka.persistence.multidc.serialization.Crdts.CounterOrBuilder
-
required bytes value = 1;
- getValueDescriptor() - Method in enum akka.persistence.multidc.serialization.Crdts.ORSetDeltaOp
-
- getVersion() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required int64 version = 2;
- getVersion() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
required int64 version = 2;
- getVersion() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVector.EntryOrBuilder
-
required int64 version = 2;
- getVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- getVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
optional .VersionVector version = 3;
- getVersion() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
optional .VersionVector version = 3;
- getVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- getVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
optional .VersionVector version = 4;
- getVersion() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
optional .VersionVector version = 4;
- getVersionBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- getVersionBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- getVersionOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- getVersionOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
optional .VersionVector version = 3;
- getVersionOrBuilder() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
optional .VersionVector version = 3;
- getVersionOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- getVersionOrBuilder() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
optional .VersionVector version = 4;
- getVersionOrBuilder() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
optional .VersionVector version = 4;
- getVvector() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- getVvector() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
required .VersionVector vvector = 2;
- getVvector() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
required .VersionVector vvector = 2;
- getVvectorBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- getVvectorOrBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- getVvectorOrBuilder() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
required .VersionVector vvector = 2;
- getVvectorOrBuilder() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
required .VersionVector vvector = 2;
- Granted$() - Constructor for class akka.lease.kubernetes.LeaseActor.Granted$
-
- GrantedVersion(String, Function1<Option<Throwable>, BoxedUnit>) - Constructor for class akka.lease.kubernetes.LeaseActor.GrantedVersion
-
- GrantedVersion$() - Constructor for class akka.lease.kubernetes.LeaseActor.GrantedVersion$
-
- Granting$() - Constructor for class akka.lease.kubernetes.LeaseActor.Granting$
-
- GreetingMessage - Class in com.example.hello.api
-
- GreetingMessage(String) - Constructor for class com.example.hello.api.GreetingMessage
-
- handleFastFailover() - Method in class akka.cluster.fastfailover.FastFailoverHelper
-
Partial function to handle fast failover messages.
- handleFastFailoverReceive() - Method in class akka.cluster.fastfailover.FastFailoverHelper
-
Java API: AbstractActor receive, for composition within AbstractActor support.
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required int32 attempt = 2;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required int32 attempt = 2;
- hasAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required int32 attempt = 2;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
required int32 attempt = 1;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat
-
required int32 attempt = 1;
- hasAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.HeartbeatOrBuilder
-
required int32 attempt = 1;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required int32 attempt = 1;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
required int32 attempt = 1;
- hasAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultFailureOrBuilder
-
required int32 attempt = 1;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required int32 attempt = 1;
- hasAttempt() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
required int32 attempt = 1;
- hasAttempt() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultSuccessOrBuilder
-
required int32 attempt = 1;
- hasDataSubjectId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
required string dataSubjectId = 1;
- hasDataSubjectId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
required string dataSubjectId = 1;
- hasDataSubjectId() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
required string dataSubjectId = 1;
- hasDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required string dc = 1;
- hasDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
required string dc = 1;
- hasDc() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNrOrBuilder
-
required string dc = 1;
- hasDelta() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
required bytes delta = 1;
- hasDelta() - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate
-
required bytes delta = 1;
- hasDelta() - Method in interface akka.persistence.multidc.serialization.Crdts.CounterUpdateOrBuilder
-
required bytes delta = 1;
- hasEnclosed() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required bytes enclosed = 1;
- hasEnclosed() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
required bytes enclosed = 1;
- hasEnclosed() - Method in interface akka.persistence.multidc.serialization.WrappedPayload.WrappedOrBuilder
-
required bytes enclosed = 1;
- hasEnclosedMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required bytes enclosedMessage = 1;
- hasEnclosedMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
required bytes enclosedMessage = 1;
- hasEnclosedMessage() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.PayloadOrBuilder
-
required bytes enclosedMessage = 1;
- hasEntityId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required string entityId = 1;
- hasEntityId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required string entityId = 1;
- hasEntityId() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required string entityId = 1;
- hasEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string entityId = 2;
- hasEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required string entityId = 2;
- hasEntityId() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required string entityId = 2;
- hasEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string entityId = 2;
- hasEntityId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required string entityId = 2;
- hasEntityId() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required string entityId = 2;
- hasError() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required bytes error = 2;
- hasError() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure
-
required bytes error = 2;
- hasError() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultFailureOrBuilder
-
required bytes error = 2;
- hasEvent() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- hasEvent() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
optional .Wrapped event = 4;
- hasEvent() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
optional .Wrapped event = 4;
- hasFromSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional int64 fromSeqNr = 4;
- hasFromSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
optional int64 fromSeqNr = 4;
- hasFromSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
optional int64 fromSeqNr = 4;
- hashCode() - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailover.Fail$
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailover.Failover$
-
- hashCode() - Static method in class akka.cluster.fastfailover.FastFailover
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailover.Heartbeat
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward
-
- hashCode() - Method in class akka.cluster.fastfailover.FastFailoverOperation.Timeout$
-
- hashCode() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- hashCode() - Method in class akka.lease.kubernetes.internal.Metadata
-
- hashCode() - Method in class akka.lease.kubernetes.internal.Spec
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.Acquire
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.Granted$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.GrantedVersion
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.Granting$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.Idle$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.InvalidRequest
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.LeaseAcquired$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.LeaseCleared
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.LeaseReleased$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.LeaseTaken$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.OperationInProgress
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.PendingRead$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.PendingReadData
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.ReadRequired$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.Release
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseActor.Releasing$
-
- hashCode() - Method in class akka.lease.kubernetes.LeaseResource
-
- hashCode() - Static method in class akka.persistence.gdpr.javadsl.GdprEncryption
-
- hashCode() - Method in class akka.persistence.gdpr.WithDataSubjectId
-
- hashCode() - Method in class akka.persistence.multidc.crdt.Counter
-
- hashCode() - Method in class akka.persistence.multidc.crdt.Counter.Updated
-
- hashCode() - Method in class akka.persistence.multidc.crdt.LwwTime
-
- hashCode() - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
- hashCode() - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
- hashCode() - Method in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp
-
- hashCode() - Method in class akka.persistence.multidc.crdt.ORSet.DeltaGroup
-
- hashCode() - Method in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp
-
- hashCode() - Method in class akka.persistence.multidc.crdt.ORSet
-
- hashCode() - Method in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp
-
- hashCode() - Method in class akka.persistence.multidc.crdt.VersionVector.After$
-
- hashCode() - Method in class akka.persistence.multidc.crdt.VersionVector.Before$
-
- hashCode() - Method in class akka.persistence.multidc.crdt.VersionVector.Concurrent$
-
- hashCode() - Method in class akka.persistence.multidc.crdt.VersionVector.Same$
-
- hashCode() - Method in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope
-
- hashCode() - Method in class akka.persistence.multidc.internal.EventTaggingContextImpl
-
- hashCode() - Method in class akka.persistence.multidc.internal.EventTriggerContextImpl
-
- hashCode() - Method in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationHotStandby.Reset$
-
- hashCode() - Static method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationTimeBucket
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationWriter.Notification
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationWriter.Tick$
-
- hashCode() - Method in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents
-
- hashCode() - Method in class akka.persistence.multidc.internal.Passivate$
-
- hashCode() - Static method in class akka.persistence.multidc.internal.Passivate
-
- hashCode() - Method in class akka.persistence.multidc.internal.PersistAll
-
- hashCode() - Method in class akka.persistence.multidc.internal.PersistNothing$
-
- hashCode() - Static method in class akka.persistence.multidc.internal.PersistNothing
-
- hashCode() - Method in class akka.persistence.multidc.internal.PersistOne
-
- hashCode() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventAck$
-
- hashCode() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- hashCode() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- hashCode() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- hashCode() - Method in class akka.persistence.multidc.internal.StopEffect$
-
- hashCode() - Static method in class akka.persistence.multidc.internal.StopEffect
-
- hashCode() - Static method in class akka.persistence.multidc.internal.TheMaterializer
-
- hashCode() - Method in class akka.persistence.multidc.internal.UnhandledCommand$
-
- hashCode() - Static method in class akka.persistence.multidc.internal.UnhandledCommand
-
- hashCode() - Method in class akka.persistence.multidc.ReplicatedEntitySnapshot
-
- hashCode() - Method in class akka.persistence.multidc.ReplicatedEvent
-
- hashCode() - Static method in class akka.persistence.multidc.testkit.ContactPoints
-
- hashCode() - Static method in class akka.persistence.update.javadsl.JournalUpdater
-
- hashCode() - Method in class akka.persistence.update.JournaledEventImpl
-
- hashCode() - Static method in class akka.persistence.update.scaladsl.JournalUpdater
-
- hashCode() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- hashCode() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ValidationResults
-
- hashCode() - Static method in class com.lightbend.akka.diagnostics.DiagnosticsExtension
-
- hashCode() - Static method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
- hashCode() - Static method in class com.lightbend.akka.diagnostics.ManagementRoutes
-
- hashCode() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- hashCode() - Method in exception com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException
-
- hashCode() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- hashCode() - Method in class com.lightbend.akka.sbr.KeepOldestSettings
-
- hashCode() - Method in class com.lightbend.akka.sbr.KeepRefereeSettings
-
- hashCode() - Method in class com.lightbend.akka.sbr.LeaseMajoritySettings
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLease$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownAll$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownIndirectlyConnected$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownReachable$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.DownUnreachable$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.NoLease$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseResult
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.ReverseDownIndirectlyConnected$
-
- hashCode() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Tick$
-
- hashCode() - Method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- hasIndirectlyConnected() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- hasKey() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required string key = 1;
- hasKey() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
required string key = 1;
- hasKey() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVector.EntryOrBuilder
-
required string key = 1;
- hasManifest() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional string manifest = 4;
- hasManifest() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional string manifest = 4;
- hasManifest() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional string manifest = 4;
- hasMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required bytes message = 3;
- hasMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
required bytes message = 3;
- hasMessage() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.AttemptOrBuilder
-
required bytes message = 3;
- hasMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required bytes message = 2;
- hasMessage() - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
required bytes message = 2;
- hasMessage() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.ResultSuccessOrBuilder
-
required bytes message = 2;
- hasMessageManifest() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
optional bytes messageManifest = 4;
- hasMessageManifest() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
optional bytes messageManifest = 4;
- hasMessageManifest() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.PayloadOrBuilder
-
optional bytes messageManifest = 4;
- hasMessageManifest() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
optional bytes messageManifest = 4;
- hasMessageManifest() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
optional bytes messageManifest = 4;
- hasMessageManifest() - Method in interface akka.persistence.multidc.serialization.WrappedPayload.WrappedOrBuilder
-
optional bytes messageManifest = 4;
- hasMetaData() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- hasMetaData() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required .ReplicatedEventMetaData metaData = 3;
- hasMetaData() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required .ReplicatedEventMetaData metaData = 3;
- hasOperation() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSetDeltaOp operation = 1;
- hasOperation() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
required .ORSetDeltaOp operation = 1;
- hasOperation() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.EntryOrBuilder
-
required .ORSetDeltaOp operation = 1;
- hasOriginDc() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required string originDc = 1;
- hasOriginDc() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
required string originDc = 1;
- hasOriginDc() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
required string originDc = 1;
- hasOriginDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string originDc = 3;
- hasOriginDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required string originDc = 3;
- hasOriginDc() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required string originDc = 3;
- hasPayload() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional bytes payload = 2;
- hasPayload() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional bytes payload = 2;
- hasPayload() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional bytes payload = 2;
- hasPersistenceId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string persistenceId = 1;
- hasPersistenceId() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required string persistenceId = 1;
- hasPersistenceId() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required string persistenceId = 1;
- hasReplicationDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required string replicationDc = 1;
- hasReplicationDc() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required string replicationDc = 1;
- hasReplicationDc() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required string replicationDc = 1;
- hasReplicationSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required int64 replicationSeqNr = 2;
- hasReplicationSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
required int64 replicationSeqNr = 2;
- hasReplicationSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEventOrBuilder
-
required int64 replicationSeqNr = 2;
- hasSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required int64 seqNr = 2;
- hasSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
required int64 seqNr = 2;
- hasSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNrOrBuilder
-
required int64 seqNr = 2;
- hasSerializerId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required int32 serializerId = 2;
- hasSerializerId() - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
required int32 serializerId = 2;
- hasSerializerId() - Method in interface akka.cluster.fastfailover.serialization.FastFailover.PayloadOrBuilder
-
required int32 serializerId = 2;
- hasSerializerId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional int32 serializerId = 3;
- hasSerializerId() - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
optional int32 serializerId = 3;
- hasSerializerId() - Method in interface akka.persistence.gdpr.serialization.GDPR.WithDataSubjectIdOrBuilder
-
optional int32 serializerId = 3;
- hasSerializerId() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required int32 serializerId = 2;
- hasSerializerId() - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
required int32 serializerId = 2;
- hasSerializerId() - Method in interface akka.persistence.multidc.serialization.WrappedPayload.WrappedOrBuilder
-
required int32 serializerId = 2;
- hasShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional string shardingTypeName = 5;
- hasShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
optional string shardingTypeName = 5;
- hasShardingTypeName() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
optional string shardingTypeName = 5;
- hasShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional string shardingTypeName = 5;
- hasShardingTypeName() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
optional string shardingTypeName = 5;
- hasShardingTypeName() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
optional string shardingTypeName = 5;
- hasState() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- hasState() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
required .Wrapped state = 1;
- hasState() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
required .Wrapped state = 1;
- hasTimestamp() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required int64 timestamp = 1;
- hasTimestamp() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
required int64 timestamp = 1;
- hasTimestamp() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
required int64 timestamp = 1;
- hasToSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required int64 toSeqNr = 3;
- hasToSeqNr() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
required int64 toSeqNr = 3;
- hasToSeqNr() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWrittenOrBuilder
-
required int64 toSeqNr = 3;
- hasUnderlying() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- hasUnderlying() - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry
-
required .ORSet underlying = 2;
- hasUnderlying() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.EntryOrBuilder
-
required .ORSet underlying = 2;
- hasValue() - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
required bytes value = 1;
- hasValue() - Method in class akka.persistence.multidc.serialization.Crdts.Counter
-
required bytes value = 1;
- hasValue() - Method in interface akka.persistence.multidc.serialization.Crdts.CounterOrBuilder
-
required bytes value = 1;
- hasVersion() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required int64 version = 2;
- hasVersion() - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry
-
required int64 version = 2;
- hasVersion() - Method in interface akka.persistence.multidc.serialization.Crdts.VersionVector.EntryOrBuilder
-
required int64 version = 2;
- hasVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- hasVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
optional .VersionVector version = 3;
- hasVersion() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshotOrBuilder
-
optional .VersionVector version = 3;
- hasVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- hasVersion() - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
optional .VersionVector version = 4;
- hasVersion() - Method in interface akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaDataOrBuilder
-
optional .VersionVector version = 4;
- hasVvector() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- hasVvector() - Method in class akka.persistence.multidc.serialization.Crdts.ORSet
-
required .VersionVector vvector = 2;
- hasVvector() - Method in interface akka.persistence.multidc.serialization.Crdts.ORSetOrBuilder
-
required .VersionVector vvector = 2;
- Heartbeat(int) - Constructor for class akka.cluster.fastfailover.FastFailover.Heartbeat
-
- Heartbeat$() - Constructor for class akka.cluster.fastfailover.FastFailover.Heartbeat$
-
- heartbeatInterval() - Method in class akka.cluster.fastfailover.FastFailoverSettings
-
- heartbeatTimeout() - Method in class akka.cluster.fastfailover.FastFailoverSettings
-
- hello(String) - Method in interface com.example.hello.api.HelloService
-
Example:
curl http://localhost:9000/api/hello/a1
- hello(String) - Method in class com.example.hello.impl.HelloServiceImpl
-
- HelloCommand - Interface in com.example.hello.impl
-
This interface defines all the commands that the HelloEntity supports.
- HelloCommand.Hello - Class in com.example.hello.impl
-
A command to say hello to someone using the current greeting message.
- HelloCommand.UseGreetingMessage - Class in com.example.hello.impl
-
A command to switch the greeting message.
- HelloEntity - Class in com.example.hello.impl
-
This is an event sourced entity.
- HelloEntity() - Constructor for class com.example.hello.impl.HelloEntity
-
- HelloEvent - Interface in com.example.hello.impl
-
This interface defines all the events that the HelloEntity supports.
- HelloEvent.GreetingMessageChanged - Class in com.example.hello.impl
-
An event that represents a change in greeting message.
- HelloModule - Class in com.example.hello.impl
-
The module that binds the HelloService so that it can be served.
- HelloModule() - Constructor for class com.example.hello.impl.HelloModule
-
- HelloService - Interface in com.example.hello.api
-
The hello service interface.
- HelloServiceImpl - Class in com.example.hello.impl
-
Implementation of the HelloService.
- HelloServiceImpl(PersistentEntityRegistry) - Constructor for class com.example.hello.impl.HelloServiceImpl
-
- HelloState - Class in com.example.hello.impl
-
- HelloState(String, WithDataSubjectId<String>) - Constructor for class com.example.hello.impl.HelloState
-
- helper() - Method in interface akka.cluster.fastfailover.FastFailoverSupport
-
- helperId() - Method in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult
-
- holdingLease() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult
-
- hotStandbyInterval() - Method in class akka.persistence.multidc.HotStandbySettings
-
- HotStandbySettings - Class in akka.persistence.multidc
-
- HotStandbySettings(boolean, FiniteDuration, FiniteDuration, Option<String>) - Constructor for class akka.persistence.multidc.HotStandbySettings
-
- hotStandbySettings() - Method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
- HotStandbySettings$ - Class in akka.persistence.multidc
-
- HotStandbySettings$() - Constructor for class akka.persistence.multidc.HotStandbySettings$
-
- main(String[]) - Method in class com.lightbend.akka.diagnostics.ConfigChecker$
-
Main method to run the ConfigChecker as a java program.
- main(String[]) - Static method in class com.lightbend.akka.diagnostics.ConfigChecker
-
Main method to run the ConfigChecker as a java program.
- ManagementRoutes - Class in com.lightbend.akka.diagnostics
-
Provides management routes for the diagnostics extensions plus a few additional endpoints
when Akka Management is used together with Akka Diagnostics.
- ManagementRoutes() - Constructor for class com.lightbend.akka.diagnostics.ManagementRoutes
-
- ManagementRoutes$ - Class in com.lightbend.akka.diagnostics
-
INTERNAL API
- ManagementRoutes$() - Constructor for class com.lightbend.akka.diagnostics.ManagementRoutes$
-
- manifest(Object) - Method in class akka.cluster.fastfailover.FastFailoverSerializer
-
- manifest(Object) - Method in class akka.persistence.gdpr.GdprSerializer
-
- manifest(Object) - Method in class akka.persistence.multidc.serialization.CrdtSerializer
-
- manifest(Object) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- MANIFEST_FIELD_NUMBER - Static variable in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- ManyVersionVector - Class in akka.persistence.multidc.crdt
-
INTERNAL API
- ManyVersionVector(TreeMap<String, Object>) - Constructor for class akka.persistence.multidc.crdt.ManyVersionVector
-
- ManyVersionVector$ - Class in akka.persistence.multidc.crdt
-
- ManyVersionVector$() - Constructor for class akka.persistence.multidc.crdt.ManyVersionVector$
-
- mapEvent(PersistentRepr) - Method in class akka.persistence.multidc.internal.CassandraReplicatedEventQuery
-
INTERNAL API: Internal hook for amending the event payload.
- match(Class<P>, FI.Apply<P, FastFailover.FailureDirective>) - Static method in class akka.cluster.fastfailover.FailureStrategyBuilder
-
Return a new PFBuilder with a case statement added.
- match(Class<P>, FI.TypedPredicate<P>, FI.Apply<P, FastFailover.FailureDirective>) - Static method in class akka.cluster.fastfailover.FailureStrategyBuilder
-
Return a new PFBuilder with a case statement added.
- matchAny(FI.Apply<Throwable, FastFailover.FailureDirective>) - Static method in class akka.cluster.fastfailover.FailureStrategyBuilder
-
Return a new PFBuilder with a case statement added.
- matchAny(CommandHandler<Command, Event, State>) - Method in class akka.persistence.multidc.javadsl.ByStateCommandHandlerBuilder
-
Match any state
- matchAny(CommandToEffect<Command, Event, State>) - Method in class akka.persistence.multidc.javadsl.CommandHandlerBuilder
-
Match any command
- matchAny(BiFunction<State, Event, State>) - Method in class akka.persistence.multidc.javadsl.EventHandlerBuilder
-
Match any event
- matchCommand(FI.TypedPredicate<Command>, CommandToEffect<Command, Event, State>) - Method in class akka.persistence.multidc.javadsl.CommandHandlerBuilder
-
Match any command which the given predicate returns true for
- matchCommand(Class<C>, CommandToEffect<C, Event, State>) - Method in class akka.persistence.multidc.javadsl.CommandHandlerBuilder
-
Match any command which is an instance or a subtype of commandClass
- matchCommand(Class<C>, FI.TypedPredicate<C>, CommandToEffect<C, Event, State>) - Method in class akka.persistence.multidc.javadsl.CommandHandlerBuilder
-
Match any command which is an instance or a subtype of commandClass and which the given predicate returns true for.
- matchEvent(Class<E>, BiFunction<State, E, State>) - Method in class akka.persistence.multidc.javadsl.EventHandlerBuilder
-
Match any event which is an instance of E or a subtype of E
- matchExact(S, CommandHandler<Command, Event, S>) - Method in class akka.persistence.multidc.javadsl.ByStateCommandHandlerBuilder
-
Match states that are equal to the given state instance
- matchExactCommand(C, CommandToEffect<C, Event, State>) - Method in class akka.persistence.multidc.javadsl.CommandHandlerBuilder
-
Match any command which equals exactly
- matchState(FI.TypedPredicate<State>, CommandHandler<Command, Event, State>) - Method in class akka.persistence.multidc.javadsl.ByStateCommandHandlerBuilder
-
Match any state that the predicate returns true for.
- matchState(Class<S>, CommandHandler<Command, Event, S>) - Method in class akka.persistence.multidc.javadsl.ByStateCommandHandlerBuilder
-
Match any state which is an instance of S or a subtype of S
- matchState(Class<S>, FI.TypedPredicate<S>, CommandHandler<Command, Event, S>) - Method in class akka.persistence.multidc.javadsl.ByStateCommandHandlerBuilder
-
Match any state which is an instance of S or a subtype of S and for which the predicate returns true
- materializer() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- maxBacktrackingBuckets() - Method in class akka.persistence.multidc.internal.NotificationSettings
-
- maxDelayWarningThreshold() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings
-
- maxDelayWarningThreshold() - Method in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- maxFailovers() - Method in class akka.cluster.fastfailover.FastFailoverSettings
-
- mbeanName() - Method in class com.lightbend.akka.diagnostics.DiagnosticsRecorder
-
- members() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
All members in self DC, but doesn't contain Joining, WeaklyUp, Down and Exiting.
- members(boolean, boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
All members in self DC, but doesn't contain Joining, WeaklyUp, Down and Exiting.
- membersWithRole() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- membersWithRole(boolean, boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- merge(VersionVector) - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
- merge(VersionVector) - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
- merge(ORSet.DeltaOp) - Method in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp
-
- merge(ORSet.DeltaOp) - Method in class akka.persistence.multidc.crdt.ORSet.DeltaGroup
-
- merge(ORSet.DeltaOp) - Method in interface akka.persistence.multidc.crdt.ORSet.DeltaOp
-
- merge(ORSet.DeltaOp) - Method in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp
-
- merge(ORSet.DeltaOp) - Method in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp
-
- merge(VersionVector) - Method in class akka.persistence.multidc.crdt.VersionVector
-
- mergeCommonKeys(Set<A>, ORSet<A>, ORSet<A>) - Method in class akka.persistence.multidc.crdt.ORSet$
-
INTERNAL API
- mergeCommonKeys(Set<A>, ORSet<A>, ORSet<A>) - Static method in class akka.persistence.multidc.crdt.ORSet
-
INTERNAL API
- mergeDisjointKeys(Set<A>, Map<A, VersionVector>, VersionVector, Map<A, VersionVector>) - Method in class akka.persistence.multidc.crdt.ORSet$
-
INTERNAL API
- mergeDisjointKeys(Set<A>, Map<A, VersionVector>, VersionVector, Map<A, VersionVector>) - Static method in class akka.persistence.multidc.crdt.ORSet
-
INTERNAL API
- mergeEvent(WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- mergeFrom(Message) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- mergeFrom(FastFailover.Attempt) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
- mergeFrom(Message) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- mergeFrom(FastFailover.Heartbeat) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
- mergeFrom(Message) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- mergeFrom(FastFailover.Payload) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
- mergeFrom(Message) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- mergeFrom(FastFailover.ResultFailure) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
- mergeFrom(Message) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- mergeFrom(FastFailover.ResultSuccess) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- mergeFrom(GDPR.WithDataSubjectId) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- mergeFrom(Crdts.Counter) - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- mergeFrom(Crdts.CounterUpdate) - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- mergeFrom(Crdts.ORSet) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- mergeFrom(Crdts.ORSetDeltaGroup) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- mergeFrom(Crdts.ORSetDeltaGroup.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- mergeFrom(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- mergeFrom(Crdts.VersionVector.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- mergeFrom(ReplicatedEvents.Notification) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- mergeFrom(ReplicatedEvents.Notification.EventsWritten) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- mergeFrom(ReplicatedEvents.ReplicatedEntitySnapshot) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- mergeFrom(ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- mergeFrom(ReplicatedEvents.ReplicatedEventMetaData) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- mergeFrom(ReplicatedEvents.SpeculativeReplicatedEvent) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
- mergeFrom(Message) - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- mergeFrom(WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
- mergeMetaData(ReplicatedEvents.ReplicatedEventMetaData) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- mergeState(WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- mergeUnderlying(Crdts.ORSet) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- mergeVersion(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- mergeVersion(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- mergeVvector(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- message - Variable in class com.example.hello.api.GreetingMessage
-
- message - Variable in class com.example.hello.impl.HelloCommand.UseGreetingMessage
-
- message - Variable in class com.example.hello.impl.HelloEvent.GreetingMessageChanged
-
- message - Variable in class com.example.hello.impl.HelloState
-
- message() - Method in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning
-
- MESSAGE_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.Attempt
-
- MESSAGE_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess
-
- MESSAGEMANIFEST_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- MESSAGEMANIFEST_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- messages() - Method in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents
-
- metadata() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- Metadata - Class in akka.lease.kubernetes.internal
-
INTERNAL API
- Metadata(String, Option<String>) - Constructor for class akka.lease.kubernetes.internal.Metadata
-
- Metadata$ - Class in akka.lease.kubernetes.internal
-
- Metadata$() - Constructor for class akka.lease.kubernetes.internal.Metadata$
-
- METADATA_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent
-
- metadataFormat() - Method in interface akka.lease.kubernetes.internal.KubernetesJsonSupport
-
- metaDataFromBinary(byte[]) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- metaDataFromProto(ReplicatedEvents.ReplicatedEventMetaData) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- metaDataToProto(ReplicatedEntityActor.ReplicatedEventMetaData) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailover$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailover.Attempt$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailover.Fail$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailover.Failover$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailover.Heartbeat$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailover.Result$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverActor$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverHelper$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverHelper.AttemptResult$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverHelper.Forward$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverOperation$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverOperation.Timeout$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverSerializer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.cluster.fastfailover.FastFailoverSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.dispatch.affinity.PoolTypeAccessor$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.internal.LeaseCustomResource$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.internal.Metadata$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.internal.Spec$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.KubernetesLease$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.KubernetesSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.Acquire$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.Granted$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.GrantedVersion$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.Granting$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.Idle$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.InvalidRequest$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.LeaseAcquired$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.LeaseCleared$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.LeaseReleased$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.LeaseTaken$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.OperationInProgress$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.PendingRead$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.PendingReadData$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.ReadRequired$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.Release$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseActor.Releasing$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.lease.kubernetes.LeaseResource$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.GdprSerializer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.GdprSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.internal.GdprSerializerAccess$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.jackson.GdprModule$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.jackson.internal.DataSubjectIdDeserializerResolver$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.jackson.internal.DataSubjectIdSerializerResolver$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.jackson.internal.JacksonModule$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.jackson.internal.VersionExtractor$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.javadsl.AbstractGdprEncryption$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.javadsl.GdprEncryption$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.JcaSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.playjson.GdprFormat$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.scaladsl.AbstractGdprEncryption$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.scaladsl.GdprEncryption$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.gdpr.WithDataSubjectId$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.Counter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.Counter.Updated$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.LwwTime$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.ManyVersionVector$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.OneVersionVector$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.ORSet$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.ORSet.AddDeltaOp$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.ORSet.DeltaGroup$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.ORSet.FullStateDeltaOp$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.ORSet.RemoveDeltaOp$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.VersionVector$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.VersionVector.After$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.VersionVector.Before$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.VersionVector.Concurrent$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.VersionVector.Same$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.crdt.VersionVector.Timestamp$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.HotStandbySettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.CassandraReplicatedEventQuery$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.CommandHandlerImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.DirectlyReplicatedEventEnvelope$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.EffectUtils$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.EventTaggingContextImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.EventTriggerContextImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.IndirectlyReplicatedEventEnvelope$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationHotStandby$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationHotStandby.Reset$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationHotStandbySingleton$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationReader$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationTimeBucket$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationWriter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationWriter.Notification$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationWriter.Tick$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.NotificationWriter.WroteEvents$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.Passivate$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.PersistAll$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.PersistNothing$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.PersistOne$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.ReplicatedEntityActor$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventAck$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.StopEffect$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.TheMaterializer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.internal.UnhandledCommand$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.javadsl.EffectFactory$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.javadsl.ReplicatedEntity$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.javadsl.ReplicatedEntity.CommandHandlers$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.PersistenceMultiDcSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.ReplicatedEntityLoggingAdapter$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.ReplicatedEntityLoggingSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.ReplicatedEntitySnapshot$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.scaladsl.Effect$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.scaladsl.ReplicatedEntity$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandHandler$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.serialization.WrappedPayloadSupport$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.serialization.WrappedPayloadSupport.Comparator$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.testkit.ContactPoints$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.testkit.PersistenceMultiDcTestKit$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.testkit.SimulatedContext$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.testkit.Simulator$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.multidc.WallClock$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.cassandra.javadsl.CassandraJournalTransformer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.javadsl.JournalUpdater$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.jdbc.javadsl.JdbcJournalTransformer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.jdbc.scaladsl.JdbcJournalTransformer$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.JournaledEventImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class akka.persistence.update.scaladsl.JournalUpdater$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.ConfigChecker$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.ConfigChecker.ConfigWarning$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.ConfigChecker.ValidationResults$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.DiagnosticsExtension$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.DiagnosticsRecorder$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.JsonFormats$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.ManagementRoutes$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.StarvationDetector$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.StarvationDetectorSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.KeepOldestSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.KeepRefereeSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.LeaseMajoritySettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLease$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseAndDownUnreachable$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.AcquireLeaseResult$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.DownAll$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.DownIndirectlyConnected$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.DownReachable$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.DownUnreachable$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReachabilityChangedStats$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.NoLease$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReleaseLeaseResult$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.ReverseDownIndirectlyConnected$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolver.Tick$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.SplitBrainResolverSettings$
-
Static reference to the singleton instance of this Scala object.
- MODULE$ - Static variable in class com.lightbend.akka.sbr.StaticQuorumSettings$
-
Static reference to the singleton instance of this Scala object.
- msg() - Method in class akka.cluster.fastfailover.FastFailover.Attempt
-
- msg() - Method in class akka.cluster.fastfailover.FastFailover.Result
-
- msg() - Method in class akka.cluster.fastfailover.FastFailoverHelper.Forward
-
- msg() - Method in exception com.lightbend.akka.diagnostics.StarvationDetector.UnsupportedDispatcherException
-
- multiDcConfig() - Method in class akka.persistence.multidc.internal.CassandraReplicatedEventJournal
-
- multiDcConfig() - Method in class akka.persistence.multidc.internal.CassandraReplicatedEventQuery
-
- multiDcConfig() - Method in interface akka.persistence.multidc.internal.CassandraReplicatedStatements
-
- MultiDcConfig - Class in akka.persistence.multidc.internal
-
- MultiDcConfig(Config) - Constructor for class akka.persistence.multidc.internal.MultiDcConfig
-
- MultiNodeSessionProvider - Class in akka.persistence.multidc.testkit
-
- MultiNodeSessionProvider(ActorSystem, Config) - Constructor for class akka.persistence.multidc.testkit.MultiNodeSessionProvider
-
- mutateMemberInfo(boolean, Function0<BoxedUnit>) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
Helper to wrap updates to strategy info with, so that stable-after timer is reset and information is logged about state change
- mutateResponsibilityInfo(Function0<BoxedUnit>) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
Helper to wrap updates to `leader` and `selfMemberAdded` to log changes in responsibility status
- Same$() - Constructor for class akka.persistence.multidc.crdt.VersionVector.Same$
-
- SameInstance() - Method in class akka.persistence.multidc.crdt.VersionVector$
-
Java API: The VersionVector.Same instance
- SameInstance() - Static method in class akka.persistence.multidc.crdt.VersionVector
-
Java API: The VersionVector.Same instance
- saveSnapshotWithReplicationState() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
- scaladslReadJournal() - Method in class akka.persistence.multidc.internal.CassandraReadJournalProvider
-
- scaladslReadJournal() - Method in class akka.persistence.multidc.testkit.InterruptableCassandraReadJournalProvider
-
- scaladslUpdateJournal() - Method in class akka.persistence.update.cassandra.CassandraJournalUpdaterProvider
-
- scaladslUpdateJournal() - Method in class akka.persistence.update.jdbc.JdbcJournalUpdaterProvider
-
- scaladslUpdateJournal() - Method in interface akka.persistence.update.UpdaterPluginProvider
-
- secure() - Method in class akka.lease.kubernetes.KubernetesSettings
-
- secureRandom() - Method in class akka.persistence.gdpr.javadsl.AbstractGdprEncryption
-
The SecureRandom that is used for the initialization vectors of the encryption.
- secureRandom() - Method in class akka.persistence.gdpr.scaladsl.AbstractGdprEncryption
-
The SecureRandom that is used for the initialization vectors of the encryption.
- seenBy() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- seenChanged(Set<Address>) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- seenEntityIds() - Method in class akka.persistence.multidc.internal.NotificationHotStandby.RegionCache
-
- self() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
The 'self' field holds the ActorRef for this actor.
- self() - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Commands can be sent with the ReplicatedEntity itself with this ActorRef, or it can be passed
in reply messages.
- self() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- selfDc() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
Name of the data-center in which this entity is running
- selfDc() - Method in class com.lightbend.akka.sbr.SplitBrainResolver
-
- selfDc() - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- selfDc() - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- SelfEventContext - Class in akka.persistence.multidc
-
Additional information about an event.
- SelfEventContext(long, long, boolean) - Constructor for class akka.persistence.multidc.SelfEventContext
-
- selfEventHandler(SelfEventContext, State, Event) - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
Apply the event that was persisted by this data center to the given state.
- selfMemberAdded() - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- selfMemberAdded_$eq(boolean) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- selfMessages() - Method in class akka.persistence.multidc.testkit.Simulator
-
- selfUniqueAddress() - Method in class com.lightbend.akka.sbr.SplitBrainResolver
-
- selfUniqueAddress() - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- sender() - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Replies can be sent with this sender() ActorRef an ActorRef that is passed in the command.
- sender() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- SEQNR_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr
-
- sequenceNr() - Method in interface akka.persistence.multidc.EventContext
-
The sequence number of the event.
- sequenceNr() - Method in class akka.persistence.multidc.ReplicatedEventContext
-
- sequenceNr() - Method in class akka.persistence.multidc.SelfEventContext
-
- serialization() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- serialize(WithDataSubjectId<?>, JsonGenerator, SerializerProvider) - Method in class akka.persistence.gdpr.jackson.internal.DataSubjectIdSerializer
-
- SerializerId() - Method in class akka.persistence.gdpr.GdprSerializer$
-
INTERNAL API
- SerializerId() - Static method in class akka.persistence.gdpr.GdprSerializer
-
INTERNAL API
- SERIALIZERID_FIELD_NUMBER - Static variable in class akka.cluster.fastfailover.serialization.FastFailover.Payload
-
- SERIALIZERID_FIELD_NUMBER - Static variable in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId
-
- SERIALIZERID_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped
-
- session() - Method in class akka.persistence.multidc.internal.CassandraReplicatedEventQuery
-
Data Access Object for arbitrary queries or updates.
- session() - Method in interface akka.persistence.multidc.internal.ReplicatedEventQuery
-
Data Access Object for arbitrary queries or updates.
- session() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- setAttempt(int) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required int32 attempt = 2;
- setAttempt(int) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Heartbeat.Builder
-
required int32 attempt = 1;
- setAttempt(int) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required int32 attempt = 1;
- setAttempt(int) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required int32 attempt = 1;
- setDataSubjectId(String) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
required string dataSubjectId = 1;
- setDataSubjectIdBytes(ByteString) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
required string dataSubjectId = 1;
- setDc(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required string dc = 1;
- setDcBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required string dc = 1;
- setDelta(ByteString) - Method in class akka.persistence.multidc.serialization.Crdts.CounterUpdate.Builder
-
required bytes delta = 1;
- setDots(int, Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- setDots(int, Crdts.VersionVector.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .VersionVector dots = 3;
- setEnclosed(ByteString) - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required bytes enclosed = 1;
- setEnclosedMessage(ByteString) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required bytes enclosedMessage = 1;
- setEntityId(String) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required string entityId = 1;
- setEntityId(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string entityId = 2;
- setEntityId(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string entityId = 2;
- setEntityIdBytes(ByteString) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required string entityId = 1;
- setEntityIdBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string entityId = 2;
- setEntityIdBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string entityId = 2;
- setEntries(int, Crdts.ORSetDeltaGroup.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- setEntries(int, Crdts.ORSetDeltaGroup.Entry.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Builder
-
repeated .ORSetDeltaGroup.Entry entries = 1;
- setEntries(int, Crdts.VersionVector.Entry) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- setEntries(int, Crdts.VersionVector.Entry.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Builder
-
repeated .VersionVector.Entry entries = 1;
- setError(ByteString) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultFailure.Builder
-
required bytes error = 2;
- setEvent(WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- setEvent(WrappedPayload.Wrapped.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
optional .Wrapped event = 4;
- setEventsWritten(int, ReplicatedEvents.Notification.EventsWritten) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- setEventsWritten(int, ReplicatedEvents.Notification.EventsWritten.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.Builder
-
repeated .Notification.EventsWritten eventsWritten = 1;
- setFromSeqNr(long) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional int64 fromSeqNr = 4;
- setIntElements(int, int) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint32 intElements = 5 [packed = true];
- setKey(String) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required string key = 1;
- setKeyBytes(ByteString) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required string key = 1;
- setLastOriginSeqNrPerDc(int, ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- setLastOriginSeqNrPerDc(int, ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
repeated .ReplicatedEntitySnapshot.DCSeqNr lastOriginSeqNrPerDc = 2;
- setLongElements(int, long) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated sint64 longElements = 6 [packed = true];
- setManifest(String) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional string manifest = 4;
- setManifestBytes(ByteString) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional string manifest = 4;
- setMessage(ByteString) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Attempt.Builder
-
required bytes message = 3;
- setMessage(ByteString) - Method in class akka.cluster.fastfailover.serialization.FastFailover.ResultSuccess.Builder
-
required bytes message = 2;
- setMessageManifest(ByteString) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
optional bytes messageManifest = 4;
- setMessageManifest(ByteString) - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
optional bytes messageManifest = 4;
- setMetaData(ReplicatedEvents.ReplicatedEventMetaData) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- setMetaData(ReplicatedEvents.ReplicatedEventMetaData.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required .ReplicatedEventMetaData metaData = 3;
- setOperation(Crdts.ORSetDeltaOp) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSetDeltaOp operation = 1;
- setOriginDc(String) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required string originDc = 1;
- setOriginDc(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string originDc = 3;
- setOriginDcBytes(ByteString) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required string originDc = 1;
- setOriginDcBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required string originDc = 3;
- setOtherElements(int, WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- setOtherElements(int, WrappedPayload.Wrapped.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated .Wrapped otherElements = 7;
- setPayload(ByteString) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional bytes payload = 2;
- setPersistenceId(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string persistenceId = 1;
- setPersistenceIdBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required string persistenceId = 1;
- setReachability(Reachability) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- setReceiveTimeout(Duration) - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Defines the inactivity timeout after which the sending of a akka.actor.ReceiveTimeout message is triggered.
- setReceiveTimeout(Duration) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Defines the inactivity timeout after which the sending of a akka.actor.ReceiveTimeout message is triggered.
- setReceiveTimeout(Duration) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- setReplicationDc(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required string replicationDc = 1;
- setReplicationDcBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required string replicationDc = 1;
- setReplicationSeqNr(long) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.SpeculativeReplicatedEvent.Builder
-
required int64 replicationSeqNr = 2;
- setSeenBy(Set<Address>) - Method in class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- setSeqNr(long) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.DCSeqNr.Builder
-
required int64 seqNr = 2;
- setSerializerId(int) - Method in class akka.cluster.fastfailover.serialization.FastFailover.Payload.Builder
-
required int32 serializerId = 2;
- setSerializerId(int) - Method in class akka.persistence.gdpr.serialization.GDPR.WithDataSubjectId.Builder
-
optional int32 serializerId = 3;
- setSerializerId(int) - Method in class akka.persistence.multidc.serialization.WrappedPayload.Wrapped.Builder
-
required int32 serializerId = 2;
- setShardingTypeName(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional string shardingTypeName = 5;
- setShardingTypeName(String) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional string shardingTypeName = 5;
- setShardingTypeNameBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
optional string shardingTypeName = 5;
- setShardingTypeNameBytes(ByteString) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional string shardingTypeName = 5;
- setState(WrappedPayload.Wrapped) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- setState(WrappedPayload.Wrapped.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
required .Wrapped state = 1;
- setStringElements(int, String) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
repeated string stringElements = 4;
- setTimestamp(long) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
required int64 timestamp = 1;
- settings() - Method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton
-
- setToSeqNr(long) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten.Builder
-
required int64 toSeqNr = 3;
- setUnderlying(Crdts.ORSet) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- setUnderlying(Crdts.ORSet.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSetDeltaGroup.Entry.Builder
-
required .ORSet underlying = 2;
- setupModule(Module.SetupContext) - Static method in class akka.persistence.gdpr.jackson.GdprModule
-
- setupModule(Module.SetupContext) - Method in interface akka.persistence.gdpr.jackson.internal.JacksonModule
-
- setValue(ByteString) - Method in class akka.persistence.multidc.serialization.Crdts.Counter.Builder
-
required bytes value = 1;
- setVersion(long) - Method in class akka.persistence.multidc.serialization.Crdts.VersionVector.Entry.Builder
-
required int64 version = 2;
- setVersion(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- setVersion(Crdts.VersionVector.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot.Builder
-
optional .VersionVector version = 3;
- setVersion(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- setVersion(Crdts.VersionVector.Builder) - Method in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData.Builder
-
optional .VersionVector version = 4;
- setVvector(Crdts.VersionVector) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- setVvector(Crdts.VersionVector.Builder) - Method in class akka.persistence.multidc.serialization.Crdts.ORSet.Builder
-
required .VersionVector vvector = 2;
- shardingTypeName() - Method in class akka.persistence.multidc.internal.NotificationWriter.EventsWritten
-
- shardingTypeName() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.ReplicatedEventMetaData
-
- shardingTypeName() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- shardingTypeName() - Method in class akka.persistence.multidc.ReplicatedEvent
-
INTERNAL API
- SHARDINGTYPENAME_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.ReplicatedEvents.Notification.EventsWritten
-
- SHARDINGTYPENAME_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEventMetaData
-
- shouldHoldUntilNoOperation(Object) - Method in class akka.cluster.fastfailover.FastFailoverHelper
-
Any message that this returns true for will be held by the fast failover support as long as there is an
outstanding fast failover message to process.
- shouldHoldUntilNoOperation(Object) - Method in interface akka.cluster.fastfailover.FastFailoverSupport
-
Any message that this returns true for will be held by the fast failover support as long as there is an
outstanding fast failover message to process.
- shred(String) - Method in class akka.persistence.gdpr.javadsl.AbstractGdprEncryption
-
- shred(String) - Method in class akka.persistence.gdpr.javadsl.DelegatingGdprEncryption
-
- shred(String) - Method in class akka.persistence.gdpr.javadsl.GdprEncryption
-
Remove the key identified by dataSubjectId.
- shred(String) - Method in interface akka.persistence.gdpr.javadsl.KeyManagement
-
Remove the key identified by dataSubjectId permanently.
- shred(String) - Method in class akka.persistence.gdpr.JCAKeyManagement
-
- shred(String) - Method in class akka.persistence.gdpr.scaladsl.AbstractGdprEncryption
-
- shred(String) - Method in class akka.persistence.gdpr.scaladsl.DelegatingGdprEncryption
-
- shred(String) - Method in class akka.persistence.gdpr.scaladsl.DelegatingKeyManagement
-
- shred(String) - Method in interface akka.persistence.gdpr.scaladsl.GdprEncryption
-
Remove the key identified by dataSubjectId from [KeyManagement].
- shred(String) - Method in interface akka.persistence.gdpr.scaladsl.KeyManagement
-
Remove the key identified by dataSubjectId permanently.
- shredded(String) - Method in class akka.persistence.gdpr.WithDataSubjectId$
-
Scala API: factory method for WithDataSubjectId with payload
that is shredded
- shredded(String) - Static method in class akka.persistence.gdpr.WithDataSubjectId
-
Scala API: factory method for WithDataSubjectId with payload
that is shredded
- signalHandler(State, Class<?>) - Method in class akka.persistence.multidc.internal.ByStateCommandHandlerImpl
-
- signalHandler(State, Class<?>) - Method in class akka.persistence.multidc.internal.CommandHandlerImpl
-
- SignalHandler<Signal,Event,State> - Interface in akka.persistence.multidc.javadsl
-
SAM for reacting on signals
- SignalHandlerBuilder<Command,Event,State> - Interface in akka.persistence.multidc.javadsl
-
Not intended for user extension.
- signalHandlers() - Method in interface akka.persistence.multidc.javadsl.SignalHandlerBuilder
-
- signalHandlers_$eq(Map<Class<?>, SignalHandler<Object, Event, State>>) - Method in interface akka.persistence.multidc.javadsl.SignalHandlerBuilder
-
- SimulatedContext - Class in akka.persistence.multidc.testkit
-
INTERNAL API
- SimulatedContext(ActorRef, ActorRef, ActorRef, TimerScheduler, ActorSystem, Option<String>) - Constructor for class akka.persistence.multidc.testkit.SimulatedContext
-
- SimulatedContext$ - Class in akka.persistence.multidc.testkit
-
- SimulatedContext$() - Constructor for class akka.persistence.multidc.testkit.SimulatedContext$
-
- SimulatedTimerScheduler - Class in akka.persistence.multidc.testkit
-
- SimulatedTimerScheduler() - Constructor for class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- Simulator<Command,Event,State> - Class in akka.persistence.multidc.testkit
-
- Simulator(Function0<InternalReplicatedEntity<Command, Event, State>>, ActorSystem, String, Set<String>, Option<String>) - Constructor for class akka.persistence.multidc.testkit.Simulator
-
- Simulator$ - Class in akka.persistence.multidc.testkit
-
- Simulator$() - Constructor for class akka.persistence.multidc.testkit.Simulator$
-
- size() - Method in class akka.persistence.multidc.crdt.ManyVersionVector
-
INTERNAL API
- size() - Method in class akka.persistence.multidc.crdt.OneVersionVector
-
INTERNAL API
- size() - Method in class akka.persistence.multidc.crdt.ORSet
-
- size() - Method in class akka.persistence.multidc.crdt.VersionVector
-
INTERNAL API
- size() - Method in class com.lightbend.akka.sbr.StaticQuorumSettings
-
- snapshot() - Method in class akka.persistence.multidc.testkit.Simulator
-
- snapshotAfter() - Method in class akka.persistence.multidc.PersistenceMultiDcSettings
-
- snapshotConfig() - Method in class akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer
-
- snapshotMigration(Object) - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
When migrating from PersistentActor to Replicated entity this method is
called to be able to convert old snapshots to the new State if needed.
- snapshotPluginId() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle.AwaitPersistenceInit
-
- spec() - Method in class akka.lease.kubernetes.internal.LeaseCustomResource
-
- Spec - Class in akka.lease.kubernetes.internal
-
INTERNAL API
- Spec(String, long) - Constructor for class akka.lease.kubernetes.internal.Spec
-
- Spec$ - Class in akka.lease.kubernetes.internal
-
- Spec$() - Constructor for class akka.lease.kubernetes.internal.Spec$
-
- specFormat() - Method in interface akka.lease.kubernetes.internal.KubernetesJsonSupport
-
- specificWithDataSubjectIdFormat() - Method in class akka.persistence.gdpr.playjson.GdprFormat$
-
GdprFormat.withDataSubjectIdFormat can be used for top level WithDataSubjectId, but for nested
WithDataSubjectId you must define a more specifific type with GdprFormat.specificWithDataSubjectIdFormat.
- specificWithDataSubjectIdFormat() - Static method in class akka.persistence.gdpr.playjson.GdprFormat
-
GdprFormat.withDataSubjectIdFormat can be used for top level WithDataSubjectId, but for nested
WithDataSubjectId you must define a more specifific type with GdprFormat.specificWithDataSubjectIdFormat.
- SpeculativeReplicatedEvent - Interface in akka.persistence.multidc
-
When this message type must be handled in the sharding entity and shard id extractors.
- speculativeReplicatedEventAckToProtoByteArray(ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- speculativeReplicatedEventFromBinary(byte[]) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- SpeculativeReplicatedEventImpl(String, long, ReplicatedEvent<Event>) - Constructor for class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl
-
- SpeculativeReplicatedEventImpl$() - Constructor for class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventImpl$
-
- SpeculativeReplicatedEventLightImpl(String, String, String, long, long, VersionVector, OptionVal<String>) - Constructor for class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl
-
- SpeculativeReplicatedEventLightImpl$() - Constructor for class akka.persistence.multidc.internal.ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl$
-
- SpeculativeReplicatedEventManifest() - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- speculativeReplicatedEventToProtoByteArray(ReplicatedEntityActor.SpeculativeReplicatedEventImpl<?>) - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- SplitBrainResolver - Class in com.lightbend.akka.sbr
-
INTERNAL API
- SplitBrainResolver(FiniteDuration, SplitBrainResolver.Strategy) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver
-
- SplitBrainResolver$ - Class in com.lightbend.akka.sbr
-
INTERNAL API
- SplitBrainResolver$() - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver$
-
- SplitBrainResolver.AcquireLease$ - Class in com.lightbend.akka.sbr
-
For delayed acquire of the lease.
- SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.AcquireLeaseAndDownIndirectlyConnected$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.AcquireLeaseAndDownUnreachable - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.AcquireLeaseAndDownUnreachable$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.AcquireLeaseDecision - Interface in com.lightbend.akka.sbr
-
- SplitBrainResolver.AcquireLeaseResult - Class in com.lightbend.akka.sbr
-
Response (result) of the acquire lease request.
- SplitBrainResolver.AcquireLeaseResult$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.Decision - Interface in com.lightbend.akka.sbr
-
- SplitBrainResolver.DownAll$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.DownAllNodes - Class in com.lightbend.akka.sbr
-
Down all nodes unconditionally.
- SplitBrainResolver.DownIndirectlyConnected$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.DownReachable$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.DownUnreachable$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.KeepMajority - Class in com.lightbend.akka.sbr
-
Down the unreachable nodes if the current node is in the majority part based the last known
membership information.
- SplitBrainResolver.KeepOldest - Class in com.lightbend.akka.sbr
-
Down the part that does not contain the oldest member (current singleton).
- SplitBrainResolver.KeepReferee - Class in com.lightbend.akka.sbr
-
Down the part that does not contain the given referee node.
- SplitBrainResolver.LeaseMajority - Class in com.lightbend.akka.sbr
-
Keep the part that can acquire the lease, and down the other part.
- SplitBrainResolver.ReachabilityChangedStats - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReachabilityChangedStats$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition - Interface in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition$.NoLease$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition$.WhenMembersRemoved$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseCondition$.WhenTimeElapsed$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReleaseLeaseResult - Class in com.lightbend.akka.sbr
-
Response (result) of the release lease request.
- SplitBrainResolver.ReleaseLeaseResult$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.ReverseDownIndirectlyConnected$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.StaticQuorum - Class in com.lightbend.akka.sbr
-
Down the unreachable nodes if the number of remaining nodes are greater than or equal to the
given quorumSize.
- SplitBrainResolver.Strategy - Class in com.lightbend.akka.sbr
-
- SplitBrainResolver.Tick$ - Class in com.lightbend.akka.sbr
-
- SplitBrainResolverBase - Class in com.lightbend.akka.sbr
-
INTERNAL API
- SplitBrainResolverBase(FiniteDuration, SplitBrainResolver.Strategy) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- SplitBrainResolverProvider - Class in com.lightbend.akka.sbr
-
- SplitBrainResolverProvider(ActorSystem) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolverProvider
-
- SplitBrainResolverSettings - Class in com.lightbend.akka.sbr
-
Internal API
- SplitBrainResolverSettings(Config) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolverSettings
-
- SplitBrainResolverSettings$ - Class in com.lightbend.akka.sbr
-
Internal API
- SplitBrainResolverSettings$() - Constructor for class com.lightbend.akka.sbr.SplitBrainResolverSettings$
-
- stableDeadline() - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- stableDeadline_$eq(Deadline) - Method in class com.lightbend.akka.sbr.SplitBrainResolverBase
-
- stackTrace() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- start(String, FastFailoverSettings, IndexedSeq<Routee>, PartialFunction<Object, Tuple2<String, Object>>, PartialFunction<Throwable, FastFailover.FailureDirective>) - Method in class akka.cluster.fastfailover.FastFailover
-
Start a fast failover actor.
- start(String, FastFailoverSettings, Iterable<Routee>, FastFailover.MessageExtractor, PartialFunction<Throwable, FastFailover.FailureDirective>) - Method in class akka.cluster.fastfailover.FastFailover
-
Java API: Start a fast failover actor.
- startCassandra(String, String) - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- startCassandra(String, int, String, String) - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- startCassandra(String, String) - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- startCassandra(String, int, String, String) - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- startCassandra$default$4() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- startCassandra$default$4() - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- startPeriodicTimer(Object, Object, FiniteDuration) - Method in class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- startSingleTimer(Object, Object, FiniteDuration) - Method in class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- startTimerAtFixedRate(Object, Object, FiniteDuration) - Method in class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- startTimerWithFixedDelay(Object, Object, FiniteDuration) - Method in class akka.persistence.multidc.testkit.SimulatedTimerScheduler
-
- startTimestamp() - Method in class akka.persistence.multidc.internal.NotificationTimeBucket
-
- StarvationDetector - Class in com.lightbend.akka.diagnostics
-
- StarvationDetector() - Constructor for class com.lightbend.akka.diagnostics.StarvationDetector
-
- StarvationDetector$ - Class in com.lightbend.akka.diagnostics
-
- StarvationDetector$() - Constructor for class com.lightbend.akka.diagnostics.StarvationDetector$
-
- StarvationDetector.StarvationDetectorThread - Class in com.lightbend.akka.diagnostics
-
INTERNAL API
- StarvationDetector.StarvationDetectorThread.Check - Class in com.lightbend.akka.diagnostics
-
- StarvationDetector.StarvationDetectorThread.ThreadStatus - Class in com.lightbend.akka.diagnostics
-
- StarvationDetector.StarvationDetectorThread.ThreadStatus$ - Class in com.lightbend.akka.diagnostics
-
- StarvationDetector.UnsupportedDispatcherException - Exception in com.lightbend.akka.diagnostics
-
- StarvationDetector.UnsupportedDispatcherException$ - Class in com.lightbend.akka.diagnostics
-
- StarvationDetectorSettings - Class in com.lightbend.akka.diagnostics
-
- StarvationDetectorSettings() - Constructor for class com.lightbend.akka.diagnostics.StarvationDetectorSettings
-
- StarvationDetectorSettings$ - Class in com.lightbend.akka.diagnostics
-
- StarvationDetectorSettings$() - Constructor for class com.lightbend.akka.diagnostics.StarvationDetectorSettings$
-
- StarvationDetectorSettings.StarvationDetectorSettingsImpl - Class in com.lightbend.akka.diagnostics
-
INTERNAL API
- StarvationDetectorSettings.StarvationDetectorSettingsImpl$ - Class in com.lightbend.akka.diagnostics
-
- StarvationDetectorSettingsImpl(FiniteDuration, FiniteDuration, FiniteDuration, FiniteDuration) - Constructor for class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl
-
- StarvationDetectorSettingsImpl$() - Constructor for class com.lightbend.akka.diagnostics.StarvationDetectorSettings.StarvationDetectorSettingsImpl$
-
- StarvationDetectorThread(ExecutionContext, LoggingAdapter, StarvationDetectorSettings, Function0<Object>) - Constructor for class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread
-
- state() - Method in class akka.persistence.multidc.ReplicatedEntitySnapshot
-
- state() - Method in class akka.persistence.multidc.testkit.Simulator
-
- state() - Method in class com.lightbend.akka.diagnostics.StarvationDetector.StarvationDetectorThread.ThreadStatus
-
- STATE_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.ReplicatedEvents.ReplicatedEntitySnapshot
-
- StaticQuorum(String, int, Option<String>) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.StaticQuorum
-
- StaticQuorumName() - Method in class com.lightbend.akka.sbr.SplitBrainResolverSettings$
-
- StaticQuorumName() - Static method in class com.lightbend.akka.sbr.SplitBrainResolverSettings
-
- staticQuorumSettings() - Method in class com.lightbend.akka.sbr.SplitBrainResolverSettings
-
- StaticQuorumSettings - Class in com.lightbend.akka.sbr
-
Internal API
- StaticQuorumSettings(int, Option<String>) - Constructor for class com.lightbend.akka.sbr.StaticQuorumSettings
-
- StaticQuorumSettings$ - Class in com.lightbend.akka.sbr
-
- StaticQuorumSettings$() - Constructor for class com.lightbend.akka.sbr.StaticQuorumSettings$
-
- stop() - Method in class akka.persistence.multidc.javadsl.EffectFactories
-
Stops the replicated entity after handling the current command.
- stop() - Static method in class akka.persistence.multidc.javadsl.EffectFactory
-
- stop(ActorRef) - Method in interface akka.persistence.multidc.javadsl.ReplicatedEntity.ActorContext
-
Stop the actor pointed to by the given ActorRef; this is
an asynchronous operation, i.e.
- stop() - Method in class akka.persistence.multidc.scaladsl.EffectFactories
-
Stops the replicated entity after handling the current command.
- stop(ActorRef) - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
Stop the actor pointed to by the given ActorRef; this is
an asynchronous operation, i.e.
- stop(ActorRef) - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- stopCassandra() - Method in class akka.persistence.multidc.testkit.CassandraLifecycle$
-
- stopCassandra() - Static method in class akka.persistence.multidc.testkit.CassandraLifecycle
-
- StopEffect<Event,State> - Class in akka.persistence.multidc.internal
-
INTERNAL API
- StopEffect(Function1<State, BoxedUnit>) - Constructor for class akka.persistence.multidc.internal.StopEffect
-
- StopEffect$ - Class in akka.persistence.multidc.internal
-
INTERNAL API
- StopEffect$() - Constructor for class akka.persistence.multidc.internal.StopEffect$
-
- stopped() - Method in class akka.persistence.multidc.testkit.Simulator
-
- Strategy(String) - Constructor for class com.lightbend.akka.sbr.SplitBrainResolver.Strategy
-
- STRINGELEMENTS_FIELD_NUMBER - Static variable in class akka.persistence.multidc.serialization.Crdts.ORSet
-
- subtractDots(VersionVector, VersionVector) - Method in class akka.persistence.multidc.crdt.ORSet$
-
INTERNAL API
Subtract the vvector from the dot.
- subtractDots(VersionVector, VersionVector) - Static method in class akka.persistence.multidc.crdt.ORSet
-
INTERNAL API
Subtract the vvector from the dot.
- super$aroundPreRestart(Throwable, Option<Object>) - Method in interface akka.cluster.fastfailover.FastFailoverSupport
-
- super$aroundReceive(PartialFunction<Object, BoxedUnit>, Object) - Method in interface akka.cluster.fastfailover.FastFailoverSupport
-
Drain the held messages buffer.
- super$executeCreateKeyspaceAndTables(Session, CassandraJournalConfig, ExecutionContext) - Method in interface akka.persistence.multidc.internal.CassandraReplicatedStatements
-
- supervisorStrategy() - Method in class akka.persistence.multidc.internal.InternalReplicatedEntity
-
User overridable definition the strategy to use for supervising
child actors.
- supervisorStrategy() - Method in class akka.persistence.multidc.internal.ReplicatedEntityActor
-
- system() - Method in class akka.cluster.fastfailover.FastFailoverSerializer
-
- system() - Method in class akka.persistence.gdpr.GdprSerializer
-
- system() - Method in class akka.persistence.multidc.internal.NotificationHotStandbySingleton
-
- system() - Method in interface akka.persistence.multidc.scaladsl.ReplicatedEntity.ActorContext
-
The system that the actor belongs to.
- system() - Method in class akka.persistence.multidc.serialization.CrdtSerializer
-
- system() - Method in class akka.persistence.multidc.serialization.ReplicatedEntitySerializer
-
- system() - Method in class akka.persistence.multidc.testkit.ContactPoints
-
- system() - Method in class akka.persistence.multidc.testkit.SimulatedContext
-
- system() - Method in class akka.persistence.multidc.testkit.Simulator
-