Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Akka.cluster Classes and Interfaces - 826 results found.
NameDescriptionTypePackageFramework
AbstractReplicatedDataJava API: Interface for implementing a ReplicatedData in Java.Classakka.cluster.ddataAkka
AbstractSerializationSupportClassakka.cluster.ddata.protobufAkka
AdaptiveLoadBalancingGroupA router group that performs load balancing of messages to cluster nodes based on cluster metric data.Classakka.cluster.metricsAkka
AdaptiveLoadBalancingGroupA router group that performs load balancing of messages to cluster nodes based on cluster metric data.Classakka.cluster.routingAkka
AdaptiveLoadBalancingGroup$Classakka.cluster.metricsAkka
AdaptiveLoadBalancingGroup$Classakka.cluster.routingAkka
AdaptiveLoadBalancingMetricsListener Subscribe to ClusterMetricsEvents and update routing logic depending on the events.Classakka.cluster.metricsAkka
AdaptiveLoadBalancingMetricsListenerClassakka.cluster.routingAkka
AdaptiveLoadBalancingPoolA router pool that performs load balancing of messages to cluster nodes based on cluster metric data.Classakka.cluster.metricsAkka
AdaptiveLoadBalancingPoolA router pool that performs load balancing of messages to cluster nodes based on cluster metric data.Classakka.cluster.routingAkka
AdaptiveLoadBalancingPool$Classakka.cluster.metricsAkka
AdaptiveLoadBalancingPool$Classakka.cluster.routingAkka
AdaptiveLoadBalancingRoutingLogicLoad balancing of messages to cluster nodes based on cluster metric data.Classakka.cluster.metricsAkka
AdaptiveLoadBalancingRoutingLogicLoad balancing of messages to cluster nodes based on cluster metric data.Classakka.cluster.routingAkka
AdaptiveLoadBalancingRoutingLogic$Classakka.cluster.metricsAkka
AdaptiveLoadBalancingRoutingLogic$Classakka.cluster.routingAkka
AutoDown An unreachable member will be downed by this actor if it remains unreachable for the specified duration and this actor is running on the leader node in theClassakka.clusterAkka
AutoDown$Classakka.clusterAkka
AutoDown .UnreachableTimeoutClassakka.cluster.AutoDownAkka
AutoDown .UnreachableTimeout$Classakka.cluster.AutoDownAkka
AutoDownBase The implementation is split into two classes AutoDown and AutoDownBase to be able to unit test the logic without running cluster.Classakka.clusterAkka
CapacityMetricsSelectorA MetricsSelector producing weights from remaining capacity.Classakka.cluster.metricsAkka
CapacityMetricsSelectorA MetricsSelector producing weights from remaining capacity.Classakka.cluster.routingAkka
ClusterThis module is responsible cluster membership information.Classakka.clusterAkka
Cluster$Cluster Extension Id and factory for creating Cluster extension.Classakka.clusterAkka
ClusterActorRefProvider The ClusterActorRefProvider will load the Cluster extension, i.Classakka.clusterAkka
ClusterClientThis actor is intended to be used on an external node that is not member of the cluster.Classakka.cluster.clientAkka
ClusterClient$Classakka.cluster.clientAkka
ClusterClient .Internal$Classakka.cluster.client.ClusterClientAkka
ClusterClient .PublishClassakka.cluster.client.ClusterClientAkka
ClusterClient .Publish$Classakka.cluster.client.ClusterClientAkka
ClusterClient .SendClassakka.cluster.client.ClusterClientAkka
ClusterClient .Send$Classakka.cluster.client.ClusterClientAkka
ClusterClient .SendToAllClassakka.cluster.client.ClusterClientAkka
ClusterClient .SendToAll$Classakka.cluster.client.ClusterClientAkka
ClusterClientMessagesClassakka.cluster.client.protobuf.msgAkka
ClusterClientMessages .ContactsProtobuf type ContactsSee Also:Serialized FormClassakka.cluster.client.protobuf.msg.ClusterClientMessagesAkka
ClusterClientMessages .Contacts .BuilderProtobuf type Contactsrepeated string contactPoints = 1;Classakka.cluster.client.protobuf.msg.ClusterClientMessages.ContactsAkka
ClusterClientMessages .ContactsOrBuilderInterfaceakka.cluster.client.protobuf.msg.ClusterClientMessagesAkka
ClusterClientMessageSerializerINTERNAL API: Serializer of ClusterClient messages.Classakka.cluster.client.protobufAkka
ClusterClientReceptionistExtension that starts ClusterReceptionist and accompanying DistributedPubSubMediator with settings defined in config section akka.Classakka.cluster.clientAkka
ClusterClientReceptionist$Classakka.cluster.clientAkka
ClusterClientSettingsparam: initialContacts Actor paths of the ClusterReceptionist actors on the servers (cluster nodes) that the client will try to contact initially.Classakka.cluster.clientAkka
ClusterClientSettings$Classakka.cluster.clientAkka
ClusterCoreDaemonClassakka.clusterAkka
ClusterCoreSupervisor ClusterCoreDaemon and ClusterDomainEventPublisher can't be restarted because the state would be obsolete.Classakka.clusterAkka
ClusterDaemon Supervisor managing the different Cluster daemons.Classakka.clusterAkka
ClusterDeployer Deployer of cluster aware routers.Classakka.clusterAkka
ClusterDomainEventPublisher Responsible for domain event subscriptions and publishing of domain events to event bus.Classakka.clusterAkka
ClusterEventDomain events published to the event bus.Classakka.clusterAkka
ClusterEvent$Domain events published to the event bus.Classakka.clusterAkka
ClusterEvent .ClusterMetricsChangedCurrent snapshot of cluster node metrics.Classakka.cluster.ClusterEventAkka
ClusterEvent .ClusterMetricsChanged$Classakka.cluster.ClusterEventAkka
ClusterEvent .ClusterShuttingDown$This event is published when the cluster node is shutting down, before the final ClusterEvent.Classakka.cluster.ClusterEventAkka
ClusterEvent .CurrentClusterStateCurrent snapshot state of the cluster.Classakka.cluster.ClusterEventAkka
ClusterEvent .CurrentClusterState$Classakka.cluster.ClusterEventAkka
ClusterEvent .CurrentInternalStatsClassakka.cluster.ClusterEventAkka
ClusterEvent .CurrentInternalStats$Classakka.cluster.ClusterEventAkka
ClusterEvent .InitialStateAsEvents$When using this subscription mode the events corresponding to the current state will be sent to the subscriber to mimic what you wouldClassakka.cluster.ClusterEventAkka
ClusterEvent .InitialStateAsSnapshot$When using this subscription mode a snapshot of ClusterEvent.Classakka.cluster.ClusterEventAkka
ClusterEvent .LeaderChangedLeader of the cluster members changed.Classakka.cluster.ClusterEventAkka
ClusterEvent .LeaderChanged$Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberEventMarker interface for membership events.Interfaceakka.cluster.ClusterEventAkka
ClusterEvent .MemberExitedMember status changed to MemberStatus.Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberExited$Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberJoinedMember status changed to Joining.Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberJoined$Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberLeftMember status changed to Leaving.Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberLeft$Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberRemovedMember completely removed from the cluster.Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberRemoved$Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberUpMember status changed to Up.Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberUp$Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberWeaklyUpMember status changed to WeaklyUp.Classakka.cluster.ClusterEventAkka
ClusterEvent .MemberWeaklyUp$Classakka.cluster.ClusterEventAkka
ClusterEvent .ReachabilityChangedClassakka.cluster.ClusterEventAkka
ClusterEvent .ReachabilityChanged$Classakka.cluster.ClusterEventAkka
ClusterEvent .ReachableMemberA member is considered as reachable by the failure detector after having been unreachable.Classakka.cluster.ClusterEventAkka
ClusterEvent .ReachableMember$Classakka.cluster.ClusterEventAkka
ClusterEvent .RoleLeaderChangedFirst member (leader) of the members within a role set changed.Classakka.cluster.ClusterEventAkka
ClusterEvent .RoleLeaderChanged$Classakka.cluster.ClusterEventAkka
ClusterEvent .SeenChanged The nodes that have seen current version of the Gossip.Classakka.cluster.ClusterEventAkka
ClusterEvent .SeenChanged$Classakka.cluster.ClusterEventAkka
ClusterEvent .SubscriptionInitialStateModeClassakka.cluster.ClusterEventAkka
ClusterEvent .UnreachableMemberA member is considered as unreachable by the failure detector.Classakka.cluster.ClusterEventAkka
ClusterEvent .UnreachableMember$Classakka.cluster.ClusterEventAkka
ClusterHeartbeatReceiver Receives Heartbeat messages and replies.Classakka.clusterAkka
ClusterHeartbeatSenderClassakka.clusterAkka
ClusterHeartbeatSender$Classakka.clusterAkka
ClusterHeartbeatSender .ExpectedFirstHeartbeatClassakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSender .ExpectedFirstHeartbeat$Classakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSender .HeartbeatSent at regular intervals for failure detection.Classakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSender .Heartbeat$Classakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSender .HeartbeatRspSent as reply to ClusterHeartbeatSender.Classakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSender .HeartbeatRsp$Classakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSender .HeartbeatTick$Classakka.cluster.ClusterHeartbeatSenderAkka
ClusterHeartbeatSenderState State of ClusterHeartbeatSender.Classakka.clusterAkka
ClusterHeartbeatSenderState$Classakka.clusterAkka
ClusterJmxClassakka.clusterAkka
ClusterMessagesClassakka.cluster.protobuf.msgAkka
ClusterMessages .AddressProtobuf type Address Defines a remote address.Classakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .Address .BuilderProtobuf type Address Defines a remote address.Classakka.cluster.protobuf.msg.ClusterMessages.AddressAkka
ClusterMessages .AddressOrBuilderrequired string hostname = 2;ByteStringgetHostnameBytes()Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .EmptyClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .Empty .BuilderConstructs the message based on the state of the Builder.Classakka.cluster.protobuf.msg.ClusterMessages.EmptyAkka
ClusterMessages .EmptyOrBuilderInterfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipProtobuf type GossipSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .Gossip .BuilderProtobuf type Gossiprepeated .Classakka.cluster.protobuf.msg.ClusterMessages.GossipAkka
ClusterMessages .GossipEnvelopeProtobuf type GossipEnvelopeSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipEnvelope .BuilderProtobuf type GossipEnvelopeConstructs the message based on the state of the Builder.Classakka.cluster.protobuf.msg.ClusterMessages.GossipEnvelopeAkka
ClusterMessages .GossipEnvelopeOrBuilderrequired .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipOrBuilderrepeated .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipOverviewProtobuf type GossipOverviewSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipOverview .BuilderProtobuf type GossipOverviewClassakka.cluster.protobuf.msg.ClusterMessages.GossipOverviewAkka
ClusterMessages .GossipOverviewOrBuilderrepeated .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipStatusProtobuf type GossipStatusSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .GossipStatus .BuilderProtobuf type GossipStatusrepeated string allHashes = 2;Classakka.cluster.protobuf.msg.ClusterMessages.GossipStatusAkka
ClusterMessages .GossipStatusOrBuilderInterfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .JoinClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .Join .Builderrepeated string roles = 2;ClusterMessages.Classakka.cluster.protobuf.msg.ClusterMessages.JoinAkka
ClusterMessages .JoinOrBuilderrequired .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .MemberProtobuf type MemberSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .Member .BuilderProtobuf type Memberrepeated int32 rolesIndexes = 4 [packed = true];Classakka.cluster.protobuf.msg.ClusterMessages.MemberAkka
ClusterMessages .MemberOrBuilderInterfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .MemberStatusClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .MetricsGossipProtobuf type MetricsGossipSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .MetricsGossip .BuilderProtobuf type MetricsGossiprepeated .Classakka.cluster.protobuf.msg.ClusterMessages.MetricsGossipAkka
ClusterMessages .MetricsGossipEnvelopeProtobuf type MetricsGossipEnvelope Metrics Gossip EnvelopeClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .MetricsGossipEnvelope .BuilderProtobuf type MetricsGossipEnvelope Metrics Gossip EnvelopeClassakka.cluster.protobuf.msg.ClusterMessages.MetricsGossipEnvelopeAkka
ClusterMessages .MetricsGossipEnvelopeOrBuilderrequired .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .MetricsGossipOrBuilderrepeated .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .NodeMetricsProtobuf type NodeMetricsSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .NodeMetrics .BuilderProtobuf type NodeMetricsrepeated .Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .EWMAProtobuf type NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .EWMA .BuilderProtobuf type NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetrics.EWMAAkka
ClusterMessages .NodeMetrics .EWMAOrBuilderrequired double alpha = 2;required double value = 1;Interfaceakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .MetricProtobuf type NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .Metric .BuilderProtobuf type NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetrics.MetricAkka
ClusterMessages .NodeMetrics .MetricOrBuilderoptional .Interfaceakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .NumberProtobuf type NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .Number .BuilderProtobuf type NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetrics.NumberAkka
ClusterMessages .NodeMetrics .NumberOrBuilderoptional bytes serialized = 4;ClusterMessages.Interfaceakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetrics .NumberTypeProtobuf enum NodeMetrics.Classakka.cluster.protobuf.msg.ClusterMessages.NodeMetricsAkka
ClusterMessages .NodeMetricsOrBuilderrequired int32 addressIndex = 1;ClusterMessages.Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .ObserverReachabilityProtobuf type ObserverReachabilitySee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .ObserverReachability .BuilderProtobuf type ObserverReachabilityClassakka.cluster.protobuf.msg.ClusterMessages.ObserverReachabilityAkka
ClusterMessages .ObserverReachabilityOrBuilderrequired int32 addressIndex = 1;ClusterMessages.Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .ReachabilityStatusProtobuf enum ReachabilityStatus Reachability statusClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .SubjectReachabilityProtobuf type SubjectReachabilitySee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .SubjectReachability .BuilderProtobuf type SubjectReachabilityConstructs the message based on the state of the Builder.Classakka.cluster.protobuf.msg.ClusterMessages.SubjectReachabilityAkka
ClusterMessages .SubjectReachabilityOrBuilderrequired int32 addressIndex = 1;ClusterMessages.Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .UniqueAddressProtobuf type UniqueAddress Defines a remote address with uid.Classakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .UniqueAddress .BuilderProtobuf type UniqueAddress Defines a remote address with uid.Classakka.cluster.protobuf.msg.ClusterMessages.UniqueAddressAkka
ClusterMessages .UniqueAddressOrBuilderrequired .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .VectorClockProtobuf type VectorClockSee Also:Serialized FormClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .VectorClock .BuilderProtobuf type VectorClockrepeated .Classakka.cluster.protobuf.msg.ClusterMessages.VectorClockAkka
ClusterMessages .VectorClock .VersionProtobuf type VectorClock.Classakka.cluster.protobuf.msg.ClusterMessages.VectorClockAkka
ClusterMessages .VectorClock .Version .BuilderProtobuf type VectorClock.Classakka.cluster.protobuf.msg.ClusterMessages.VectorClock.VersionAkka
ClusterMessages .VectorClock .VersionOrBuilderrequired int32 hashIndex = 1;required int64 timestamp = 2;Interfaceakka.cluster.protobuf.msg.ClusterMessages.VectorClockAkka
ClusterMessages .VectorClockOrBuilderoptional int64 timestamp = 1; the timestamp could be removed but left for test data compatibilityInterfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .WelcomeProtobuf type Welcome Welcome, reply to JoinClassakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessages .Welcome .BuilderProtobuf type Welcome Welcome, reply to JoinClassakka.cluster.protobuf.msg.ClusterMessages.WelcomeAkka
ClusterMessages .WelcomeOrBuilderrequired .Interfaceakka.cluster.protobuf.msg.ClusterMessagesAkka
ClusterMessageSerializerProtobuf serializer of cluster messages.Classakka.cluster.protobufAkka
ClusterMetricsChangedCurrent snapshot of cluster node metrics.Classakka.cluster.metricsAkka
ClusterMetricsChanged$Classakka.cluster.metricsAkka
ClusterMetricsCollector Cluster metrics is primarily for load-balancing of nodes.Classakka.clusterAkka
ClusterMetricsCollector Actor responsible for periodic data sampling in the node and publication to the cluster.Classakka.cluster.metricsAkka
ClusterMetricsExtensionCluster metrics extension.Classakka.cluster.metricsAkka
ClusterMetricsExtension$Cluster metrics extension provider.Classakka.cluster.metricsAkka
ClusterMetricsMessagesClassakka.cluster.metrics.protobuf.msgAkka
ClusterMetricsMessages .AddressProtobuf type Address Defines a remote address.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .Address .BuilderProtobuf type Address Defines a remote address.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.AddressAkka
ClusterMetricsMessages .AddressOrBuilderrequired string hostname = 2;ByteStringgetHostnameBytes()Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .MetricsGossipProtobuf type MetricsGossipSee Also:Serialized FormClassakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .MetricsGossip .BuilderProtobuf type MetricsGossiprepeated .Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.MetricsGossipAkka
ClusterMetricsMessages .MetricsGossipEnvelopeProtobuf type MetricsGossipEnvelope Metrics Gossip EnvelopeClassakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .MetricsGossipEnvelope .BuilderProtobuf type MetricsGossipEnvelope Metrics Gossip EnvelopeClassakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.MetricsGossipEnvelopeAkka
ClusterMetricsMessages .MetricsGossipEnvelopeOrBuilderrequired .Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .MetricsGossipOrBuilderrepeated .Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .NodeMetricsProtobuf type NodeMetricsSee Also:Serialized FormClassakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsMessages .NodeMetrics .BuilderProtobuf type NodeMetricsClassakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .EWMAProtobuf type NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .EWMA .BuilderProtobuf type NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics.EWMAAkka
ClusterMetricsMessages .NodeMetrics .EWMAOrBuilderrequired double alpha = 2;required double value = 1;Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .MetricProtobuf type NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .Metric .BuilderProtobuf type NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics.MetricAkka
ClusterMetricsMessages .NodeMetrics .MetricOrBuilderoptional .Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .NumberProtobuf type NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .Number .BuilderProtobuf type NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics.NumberAkka
ClusterMetricsMessages .NodeMetrics .NumberOrBuilderoptional bytes serialized = 4;ClusterMetricsMessages.Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetrics .NumberTypeProtobuf enum NodeMetrics.Classakka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetricsAkka
ClusterMetricsMessages .NodeMetricsOrBuilderrequired int32 addressIndex = 1;ClusterMetricsMessages.Interfaceakka.cluster.metrics.protobuf.msg.ClusterMetricsMessagesAkka
ClusterMetricsSettingsMetrics extension settings.Classakka.cluster.metricsAkka
ClusterMetricsSettings$Classakka.cluster.metricsAkka
ClusterMetricsStrategyDefault ClusterMetricsSupervisor strategy: A configurable OneForOneStrategy with restart-on-throwable decider.Classakka.cluster.metricsAkka
ClusterMetricsStrategy$Provide custom metrics strategy resources.Classakka.cluster.metricsAkka
ClusterMetricsSupervisor Actor providing customizable metrics collection supervision.Classakka.cluster.metricsAkka
ClusterNodeMBeanInterface for the cluster JMX MBean.Interfaceakka.clusterAkka
ClusterReadView Read view of cluster state, updated via subscription of cluster events published on the event bus.Classakka.clusterAkka
ClusterReceptionistClusterClient connects to this actor to retrieve.Classakka.cluster.clientAkka
ClusterReceptionist$Classakka.cluster.clientAkka
ClusterReceptionist .Internal$Classakka.cluster.client.ClusterReceptionistAkka
ClusterReceptionistSettingsparam: role Start the receptionist on members tagged with this role.Classakka.cluster.clientAkka
ClusterReceptionistSettings$Classakka.cluster.clientAkka
ClusterRemoteWatcher Specialization of RemoteWatcher that keeps track of cluster member nodes and is responsible for watchees on cluster nodes.Classakka.clusterAkka
ClusterRemoteWatcher$Classakka.clusterAkka
ClusterRouterActor The router actor, subscribes to cluster events and adjusts the routees.Interfaceakka.cluster.routingAkka
ClusterRouterConfigBaseCreate the actual router, responsible for routing messages to routees.Interfaceakka.cluster.routingAkka
ClusterRouterGroupRouterConfig implementation for deployment on cluster nodes.Classakka.cluster.routingAkka
ClusterRouterGroup$Classakka.cluster.routingAkka
ClusterRouterGroupActorClassakka.cluster.routingAkka
ClusterRouterGroupSettingsClassakka.cluster.routingAkka
ClusterRouterGroupSettings$Classakka.cluster.routingAkka
ClusterRouterPoolRouterConfig implementation for deployment on cluster nodes.Classakka.cluster.routingAkka
ClusterRouterPool$Classakka.cluster.routingAkka
ClusterRouterPoolActorClassakka.cluster.routingAkka
ClusterRouterPoolSettingsClassakka.cluster.routingAkka
ClusterRouterPoolSettings$Classakka.cluster.routingAkka
ClusterRouterSettingsBaseInterfaceakka.cluster.routingAkka
ClusterRouterSettingsBase$Classakka.cluster.routingAkka
ClusterScopeClassakka.clusterAkka
ClusterScope$Cluster aware scope of a DeploySee Also:Serialized FormClassakka.clusterAkka
ClusterSettingsClassakka.clusterAkka
ClusterShardingClassakka.cluster.shardingAkka
ClusterSharding$This extension provides sharding functionality of actors in a cluster.Classakka.cluster.shardingAkka
ClusterShardingGuardianINTERNAL API.Classakka.cluster.shardingAkka
ClusterShardingGuardian$Classakka.cluster.shardingAkka
ClusterShardingGuardian .StartClassakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .Start$Classakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .StartedClassakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .Started$Classakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .StartProxyClassakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .StartProxy$Classakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingMessagesClassakka.cluster.sharding.protobuf.msgAkka
ClusterShardingMessages .ActorRefMessageProtobuf type ActorRefMessageSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ActorRefMessage .BuilderProtobuf type ActorRefMessageConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessageAkka
ClusterShardingMessages .ActorRefMessageOrBuilderrequired string ref = 1;ByteStringgetRefBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .CoordinatorStateProtobuf type CoordinatorStateSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .CoordinatorState .BuilderProtobuf type CoordinatorStaterepeated string regionProxies = 3;Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateAkka
ClusterShardingMessages .CoordinatorState .ShardEntryProtobuf type CoordinatorState.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateAkka
ClusterShardingMessages .CoordinatorState .ShardEntry .BuilderProtobuf type CoordinatorState.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryAkka
ClusterShardingMessages .CoordinatorState .ShardEntryOrBuilderrequired string regionRef = 2;ByteStringgetRegionRefBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateAkka
ClusterShardingMessages .CoordinatorStateOrBuilderInterfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStartedProtobuf type EntityStartedSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStarted .BuilderProtobuf type EntityStartedConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStartedAkka
ClusterShardingMessages .EntityStartedOrBuilderrequired string entityId = 1;ByteStringgetEntityIdBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStateProtobuf type EntityStateSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityState .BuilderProtobuf type EntityStaterepeated string entities = 1;Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStateAkka
ClusterShardingMessages .EntityStateOrBuilderInterfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStoppedProtobuf type EntityStoppedSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStopped .BuilderProtobuf type EntityStoppedConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStoppedAkka
ClusterShardingMessages .EntityStoppedOrBuilderrequired string entityId = 1;ByteStringgetEntityIdBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHomeProtobuf type ShardHomeSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHome .BuilderProtobuf type ShardHomeConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAkka
ClusterShardingMessages .ShardHomeAllocatedProtobuf type ShardHomeAllocatedSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHomeAllocated .BuilderProtobuf type ShardHomeAllocatedConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedAkka
ClusterShardingMessages .ShardHomeAllocatedOrBuilderrequired string region = 2;ByteStringgetRegionBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHomeOrBuilderrequired string region = 2;ByteStringgetRegionBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardIdMessageProtobuf type ShardIdMessageSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardIdMessage .BuilderProtobuf type ShardIdMessageConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessageAkka
ClusterShardingMessages .ShardIdMessageOrBuilderrequired string shard = 1;ByteStringgetShardBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardStatsProtobuf type ShardStatsSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardStats .BuilderProtobuf type ShardStatsConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardStatsAkka
ClusterShardingMessages .ShardStatsOrBuilderrequired int32 entityCount = 2;java.Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessageSerializerINTERNAL API: Protobuf serializer of ClusterSharding messages.Classakka.cluster.sharding.protobufAkka
ClusterShardingSettingsparam: role specifies that this entity type requires cluster nodes with a specific role.Classakka.cluster.shardingAkka
ClusterShardingSettings$Classakka.cluster.shardingAkka
ClusterShardingSettings .TuningParametersClassakka.cluster.sharding.ClusterShardingSettingsAkka
ClusterSingletonManagerManages singleton actor instance among all cluster nodes or a group of nodes tagged with a specific role.Classakka.cluster.singletonAkka
ClusterSingletonManager$Classakka.cluster.singletonAkka
ClusterSingletonManager .Internal$Classakka.cluster.singleton.ClusterSingletonManagerAkka
ClusterSingletonManagerIsStuckThrown when a consistent state can't be determined within the defined retry limits.Classakka.cluster.singletonAkka
ClusterSingletonManagerSettingsparam: singletonName The actor name of the child singleton actor.Classakka.cluster.singletonAkka
ClusterSingletonManagerSettings$Classakka.cluster.singletonAkka
ClusterSingletonMessageSerializerINTERNAL API: Serializer of ClusterSingleton messages.Classakka.cluster.singleton.protobufAkka
ClusterSingletonProxyThe ClusterSingletonProxy works together with the ClusterSingletonManager to provide a distributed proxy to the singleton actor.Classakka.cluster.singletonAkka
ClusterSingletonProxy$Classakka.cluster.singletonAkka
ClusterSingletonProxySettingsparam: singletonName The actor name of the singleton actor that is started by the ClusterSingletonManager.Classakka.cluster.singletonAkka
ClusterSingletonProxySettings$Classakka.cluster.singletonAkka
ClusterUserActionClassakka.clusterAkka
ClusterUserAction$Classakka.clusterAkka
ClusterUserAction .DownCommand to mark node as temporary down.Classakka.cluster.ClusterUserActionAkka
ClusterUserAction .Down$Classakka.cluster.ClusterUserActionAkka
ClusterUserAction .JoinToCommand to initiate join another node (represented by address).Classakka.cluster.ClusterUserActionAkka
ClusterUserAction .JoinTo$Classakka.cluster.ClusterUserActionAkka
ClusterUserAction .LeaveCommand to leave the cluster.Classakka.cluster.ClusterUserActionAkka
ClusterUserAction .Leave$Classakka.cluster.ClusterUserActionAkka
CollectionControlMessageRuntime collection management commands.Classakka.cluster.metricsAkka
CollectionStartMessageCommand for ClusterMetricsSupervisor to start metrics collection.Classakka.cluster.metricsAkka
CollectionStartMessage$Command for ClusterMetricsSupervisor to start metrics collection.Classakka.cluster.metricsAkka
CollectionStopMessageCommand for ClusterMetricsSupervisor to stop metrics collection.Classakka.cluster.metricsAkka
CollectionStopMessage$Command for ClusterMetricsSupervisor to stop metrics collection.Classakka.cluster.metricsAkka
CpuMetricsSelectorMetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics.Classakka.cluster.metricsAkka
CpuMetricsSelectorMetricsSelector that uses the combined CPU metrics.Classakka.cluster.routingAkka
CpuMetricsSelector$MetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics.Classakka.cluster.metricsAkka
CpuMetricsSelector$MetricsSelector that uses the combined CPU metrics.Classakka.cluster.routingAkka
DDataShardCoordinatorSingleton coordinator (with state based on ddata) that decides where to allocate shards.Classakka.cluster.shardingAkka
DefaultSigarProviderProvide sigar instance as SigarProxy with configured location via ClusterMetricsSettings.Classakka.cluster.metricsAkka
DefaultSigarProvider$Classakka.cluster.metricsAkka
DistributedDataAkka extension for convenient configuration and use of the Replicator.Classakka.cluster.ddataAkka
DistributedData$Classakka.cluster.ddataAkka
DistributedPubSubExtension that starts a DistributedPubSubMediator actor with settings defined in config section akka.Classakka.cluster.pubsubAkka
DistributedPubSub$Classakka.cluster.pubsubAkka
DistributedPubSubMediatorThis actor manages a registry of actor references and replicates the entries to peer actors among all cluster nodes or a group of nodesClassakka.cluster.pubsubAkka
DistributedPubSubMediator$Classakka.cluster.pubsubAkka
DistributedPubSubMediator .Count$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .CurrentTopicsClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .CurrentTopics$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .GetTopicsClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .GetTopics$Send this message to the mediator and it will reply with DistributedPubSubMediator.Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Internal$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Internal$ .TopicLikeInterfaceakka.cluster.pubsub.DistributedPubSubMediator.Internal$Akka
DistributedPubSubMediator .PublishClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Publish$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .PutClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Put$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .RemoveClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Remove$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .SendClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Send$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .SendToAllClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .SendToAll$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .SubscribeClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Subscribe$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .SubscribeAckClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .SubscribeAck$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .UnsubscribeClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .Unsubscribe$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .UnsubscribeAckClassakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMediator .UnsubscribeAck$Classakka.cluster.pubsub.DistributedPubSubMediatorAkka
DistributedPubSubMessagesClassakka.cluster.pubsub.protobuf.msgAkka
DistributedPubSubMessages .AddressProtobuf type Address Defines a remote address.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Address .BuilderProtobuf type Address Defines a remote address.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.AddressAkka
DistributedPubSubMessages .AddressOrBuilderrequired string hostname = 2;ByteStringgetHostnameBytes()Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .DeltaClassakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Delta .BucketProtobuf type Delta.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.DeltaAkka
DistributedPubSubMessages .Delta .Bucket .BuilderProtobuf type Delta.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta.BucketAkka
DistributedPubSubMessages .Delta .BucketOrBuilderrepeated .Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.DeltaAkka
DistributedPubSubMessages .Delta .Builderrepeated .Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.DeltaAkka
DistributedPubSubMessages .Delta .EntryProtobuf type Delta.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.DeltaAkka
DistributedPubSubMessages .Delta .Entry .BuilderProtobuf type Delta.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta.EntryAkka
DistributedPubSubMessages .Delta .EntryOrBuilderrequired string key = 1;ByteStringgetKeyBytes()Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.DeltaAkka
DistributedPubSubMessages .DeltaOrBuilderrepeated .Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .PayloadProtobuf type PayloadSee Also:Serialized FormClassakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Payload .BuilderProtobuf type PayloadConstructs the message based on the state of the Builder.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.PayloadAkka
DistributedPubSubMessages .PayloadOrBuilderrequired bytes enclosedMessage = 1;ByteStringgetMessageManifest()Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .PublishProtobuf type Publish Publish normally local, but it is also used by the ClusterClient.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Publish .BuilderProtobuf type Publish Publish normally local, but it is also used by the ClusterClient.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.PublishAkka
DistributedPubSubMessages .PublishOrBuilderrequired .Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Send Send normally local, but it is also used by the ClusterClient.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Send .Builder Send normally local, but it is also used by the ClusterClient.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.SendAkka
DistributedPubSubMessages .SendOrBuilderrequired bool localAffinity = 2;java.Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .SendToAllProtobuf type SendToAll SendToAll normally local, but it is also used by the ClusterClient.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .SendToAll .BuilderProtobuf type SendToAll SendToAll normally local, but it is also used by the ClusterClient.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.SendToAllAkka
DistributedPubSubMessages .SendToAllOrBuilderrequired bool allButSelf = 2;java.Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .StatusProtobuf type StatusSee Also:Serialized FormClassakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessages .Status .BuilderProtobuf type Statusrepeated .Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.StatusAkka
DistributedPubSubMessages .Status .VersionProtobuf type Status.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.StatusAkka
DistributedPubSubMessages .Status .Version .BuilderProtobuf type Status.Classakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Status.VersionAkka
DistributedPubSubMessages .Status .VersionOrBuilderrequired .Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.StatusAkka
DistributedPubSubMessages .StatusOrBuilderrepeated .Interfaceakka.cluster.pubsub.protobuf.msg.DistributedPubSubMessagesAkka
DistributedPubSubMessageSerializerINTERNAL API: Protobuf serializer of DistributedPubSubMediator messages.Classakka.cluster.pubsub.protobufAkka
DistributedPubSubSettingsparam: role Start the mediator on members tagged with this role.Classakka.cluster.pubsubAkka
DistributedPubSubSettings$Classakka.cluster.pubsubAkka
EWMAClassakka.clusterAkka
EWMAThe exponentially weighted moving average (EWMA) approach captures short-term movements in volatility for a conditional volatility forecasting model.Classakka.cluster.metricsAkka
EWMA$Classakka.clusterAkka
EWMA$Classakka.cluster.metricsAkka
FastMerge Optimization for add/remove followed by merge and merge should just fast forward to It's like a cache between calls of the same thread, you can think of it as a thread local.Interfaceakka.cluster.ddataAkka
FirstSeedNodeProcess Used only for the first seed node.Classakka.clusterAkka
FlagClassakka.cluster.ddataAkka
Flag$Classakka.cluster.ddataAkka
FlagKeyClassakka.cluster.ddataAkka
FlagKey$Classakka.cluster.ddataAkka
GCounterClassakka.cluster.ddataAkka
GCounter$Classakka.cluster.ddataAkka
GCounterKeyClassakka.cluster.ddataAkka
GCounterKey$Classakka.cluster.ddataAkka
GossipClassakka.clusterAkka
Gossip$Classakka.clusterAkka
GossipEnvelope Envelope adding a sender and receiver address to the gossip.Classakka.clusterAkka
GossipEnvelope$Classakka.clusterAkka
GossipOverview Represents the overview of the cluster, holds the cluster convergence table and set with unreachable nodes.Classakka.clusterAkka
GossipOverview$Classakka.clusterAkka
GossipStatsClassakka.clusterAkka
GossipStats$Classakka.clusterAkka
GossipStatus When there are no known changes to the node ring a GossipStatus initiates a gossip chat between two members.Classakka.clusterAkka
GossipStatus$Classakka.clusterAkka
GSetClassakka.cluster.ddataAkka
GSet$Classakka.cluster.ddataAkka
GSetKeyClassakka.cluster.ddataAkka
GSetKey$Classakka.cluster.ddataAkka
HeapMetricsSelectorMetricsSelector that uses the heap metrics.Classakka.cluster.metricsAkka
HeapMetricsSelectorMetricsSelector that uses the heap metrics.Classakka.cluster.routingAkka
HeapMetricsSelector$MetricsSelector that uses the heap metrics.Classakka.cluster.metricsAkka
HeapMetricsSelector$MetricsSelector that uses the heap metrics.Classakka.cluster.routingAkka
HeartbeatNodeRing Data structure for picking heartbeat receivers.Classakka.clusterAkka
HeartbeatNodeRing$Classakka.clusterAkka
InternalClusterActionClassakka.clusterAkka
InternalClusterAction$Classakka.clusterAkka
InternalClusterAction .AddOnMemberRemovedListenerClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .AddOnMemberRemovedListener$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .AddOnMemberUpListenerCommand to ClusterDaemon to create a OnMemberStatusChangedListener.Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .AddOnMemberUpListener$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .GetClusterCoreRef$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .GossipSpeedupTick$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .GossipTick$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .InitJoin$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .InitJoinAckClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .InitJoinAck$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .InitJoinNackClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .InitJoinNack$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .JoinCommand to join the cluster.Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .Join$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .JoinSeedNode$Start message of the process to join one of the seed nodes.Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .JoinSeedNodesCommand to initiate the process to join the specifiedSee Also:Serialized FormClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .JoinSeedNodes$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .LeaderActionsTick$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .MetricsTick$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublishChangesClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublishChanges$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublisherCreatedClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublisherCreated$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublishEventClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublishEvent$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .PublishStatsTick$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .ReapUnreachableTick$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .SendCurrentClusterStateparam: receiver ClusterEvent.Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .SendCurrentClusterState$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .SendGossipToClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .SendGossipTo$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .SubscribeClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .Subscribe$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .UnsubscribeClassakka.cluster.InternalClusterActionAkka
InternalClusterAction .Unsubscribe$Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .Welcome param: from the sender node in the cluster, i.Classakka.cluster.InternalClusterActionAkka
InternalClusterAction .Welcome$Classakka.cluster.InternalClusterActionAkka
JmxMetricsCollectorLoads JVM and system metrics through JMX monitoring beans.Classakka.clusterAkka
JmxMetricsCollectorLoads JVM and system metrics through JMX monitoring beans.Classakka.cluster.metricsAkka
JoinSeedNodeProcess Sends InitJoin to all seed nodes (except itself) and expect InitJoinAck reply back.Classakka.clusterAkka
KeyKey for the key-value data in Replicator.Classakka.cluster.ddataAkka
Key$Classakka.cluster.ddataAkka
LWWMapSpecialized ORMap with LWWRegister values.Classakka.cluster.ddataAkka
LWWMap$Classakka.cluster.ddataAkka
LWWMapKeyClassakka.cluster.ddataAkka
LWWMapKey$Classakka.cluster.ddataAkka
LWWRegister It is described in the paper A comprehensive study of Convergent and Commutative Replicated Data Types.Classakka.cluster.ddataAkka
LWWRegister$Classakka.cluster.ddataAkka
LWWRegister .ClockInterfaceakka.cluster.ddata.LWWRegisterAkka
LWWRegisterKeyClassakka.cluster.ddataAkka
LWWRegisterKey$Classakka.cluster.ddataAkka
ManyVersionVectorClassakka.cluster.ddataAkka
ManyVersionVector$Classakka.cluster.ddataAkka
MemberRepresents the address, current status, and roles of a cluster member node.Classakka.clusterAkka
Member$Module with factory and ordering methods for Member instances.Classakka.clusterAkka
MemberStatusDefines the current status of a cluster member node Can be one of: Joining, Up, Leaving, Exiting and Down.Classakka.clusterAkka
MemberStatus$Classakka.clusterAkka
MemberStatus .Down$Classakka.cluster.MemberStatusAkka
MemberStatus .Exiting$Classakka.cluster.MemberStatusAkka
MemberStatus .Joining$Classakka.cluster.MemberStatusAkka
MemberStatus .Leaving$Classakka.cluster.MemberStatusAkka
MemberStatus .Removed$Classakka.cluster.MemberStatusAkka
MemberStatus .Up$Classakka.cluster.MemberStatusAkka
MemberStatus .WeaklyUp$WeaklyUp is an EXPERIMENTAL feature and is subject to change until it has received more real world testing.Classakka.cluster.MemberStatusAkka
MessageSerializerProtobuf serializer for ClusterMetricsMessage types.Classakka.cluster.metrics.protobufAkka
Metric Equality of Metric is based on its name.Classakka.clusterAkka
Metric Equality of Metric is based on its name.Classakka.cluster.metricsAkka
Metric$Factory for creating valid Metric instances.Classakka.clusterAkka
Metric$Factory for creating valid Metric instances.Classakka.cluster.metricsAkka
MetricNumericConverter Encapsulates evaluation of validity of metric values, conversion of an actual metric value to a Metric for consumption by subscribed cluster entities.Interfaceakka.clusterAkka
MetricNumericConverter Encapsulates evaluation of validity of metric values, conversion of an actual metric value to a Metric for consumption by subscribed cluster entities.Interfaceakka.cluster.metricsAkka
MetricsCollector Implementations of cluster system metrics collectors extend this trait.Interfaceakka.cluster.metricsAkka
MetricsCollectorSamples and collects new data points.Interfaceakka.clusterAkka
MetricsCollector$ Factory to create configured MetricsCollector.Classakka.cluster.metricsAkka
MetricsCollector$ Factory to create configured MetricsCollector.Classakka.clusterAkka
MetricsGossipClassakka.cluster.metricsAkka
MetricsGossipClassakka.clusterAkka
MetricsGossip$Classakka.cluster.metricsAkka
MetricsGossip$Classakka.clusterAkka
MetricsGossipEnvelope Envelope adding a sender address to the cluster metrics gossip.Classakka.cluster.metricsAkka
MetricsGossipEnvelope Envelope adding a sender address to the gossip.Classakka.clusterAkka
MetricsGossipEnvelope$Classakka.cluster.metricsAkka
MetricsGossipEnvelope$Classakka.clusterAkka
MetricsSelectorA MetricsSelector is responsible for producing weights from the node metrics.Interfaceakka.cluster.metricsAkka
MetricsSelectorA MetricsSelector is responsible for producing weights from the node metrics.Interfaceakka.cluster.routingAkka
MetricsSelector$Classakka.cluster.metricsAkka
MetricsSelector$Classakka.cluster.routingAkka
MixMetricsSelectorClassakka.cluster.metricsAkka
MixMetricsSelectorClassakka.cluster.routingAkka
MixMetricsSelector$Singleton instance of the default MixMetricsSelector, which uses [akka.Classakka.cluster.metricsAkka
MixMetricsSelector$Singleton instance of the default MixMetricsSelector, which uses [akka.Classakka.cluster.routingAkka
MixMetricsSelectorBaseBase class for MetricsSelector that combines other selectors and aggregates their capacity.Classakka.cluster.metricsAkka
MixMetricsSelectorBaseBase class for MetricsSelector that combines other selectors and aggregates their capacity.Classakka.cluster.routingAkka
NodeMetricsThe snapshot of current sampled health metrics for any monitored process.Classakka.cluster.metricsAkka
NodeMetricsThe snapshot of current sampled health metrics for any monitored process.Classakka.clusterAkka
NodeMetrics$Classakka.cluster.metricsAkka
NodeMetrics$Classakka.clusterAkka
OneVersionVectorClassakka.cluster.ddataAkka
OneVersionVector$Classakka.cluster.ddataAkka
OnMemberStatusChangedListener The supplied callback will be run, once, when current cluster member come up with the same status.Classakka.clusterAkka
ORMap It has similar semantics as an ORSet, but in case of concurrent updates the values are merged, and must therefore be ReplicatedData types themselves.Classakka.cluster.ddataAkka
ORMap$Classakka.cluster.ddataAkka
ORMapKeyClassakka.cluster.ddataAkka
ORMapKey$Classakka.cluster.ddataAkka
ORMultiMapAn immutable multi-map implementation.Classakka.cluster.ddataAkka
ORMultiMap$Classakka.cluster.ddataAkka
ORMultiMapKeyClassakka.cluster.ddataAkka
ORMultiMapKey$Classakka.cluster.ddataAkka
ORSet Elements can be added and removed any number of times.Classakka.cluster.ddataAkka
ORSet$Classakka.cluster.ddataAkka
ORSetKeyClassakka.cluster.ddataAkka
ORSetKey$Classakka.cluster.ddataAkka
OtherMessageComparatorClassakka.cluster.ddata.protobufAkka
OtherMessageComparator$Classakka.cluster.ddata.protobufAkka
PersistentShard This actor creates children entity actors on demand that it is told to be responsible for.Classakka.cluster.shardingAkka
PersistentShardCoordinatorSingleton coordinator that decides where to allocate shards.Classakka.cluster.shardingAkka
PNCounter It is described in the paper A comprehensive study of Convergent and Commutative Replicated Data Types.Classakka.cluster.ddataAkka
PNCounter$Classakka.cluster.ddataAkka
PNCounterKeyClassakka.cluster.ddataAkka
PNCounterKey$Classakka.cluster.ddataAkka
PNCounterMapMap of named counters.Classakka.cluster.ddataAkka
PNCounterMap$Classakka.cluster.ddataAkka
PNCounterMapKeyClassakka.cluster.ddataAkka
PNCounterMapKey$Classakka.cluster.ddataAkka
PruningStateClassakka.cluster.ddataAkka
PruningState$Classakka.cluster.ddataAkka
PruningState .PruningInitializedClassakka.cluster.ddata.PruningStateAkka
PruningState .PruningInitialized$Classakka.cluster.ddata.PruningStateAkka
PruningState .PruningPerformed$Classakka.cluster.ddata.PruningStateAkka
Reachability Immutable data structure that holds the reachability status of subject nodes as seen from observer nodes.Classakka.clusterAkka
Reachability$Classakka.clusterAkka
Reachability .Reachable$Classakka.cluster.ReachabilityAkka
Reachability .RecordClassakka.cluster.ReachabilityAkka
Reachability .Record$Classakka.cluster.ReachabilityAkka
Reachability .Terminated$Classakka.cluster.ReachabilityAkka
Reachability .Unreachable$Classakka.cluster.ReachabilityAkka
ReadAggregatorClassakka.cluster.ddataAkka
ReadAggregator$Classakka.cluster.ddataAkka
ReadWriteAggregatorClassakka.cluster.ddataAkka
ReadWriteAggregator$Classakka.cluster.ddataAkka
ReadWriteAggregator .SendToSecondary$Classakka.cluster.ddata.ReadWriteAggregatorAkka
RemovedNodePruningReplicatedData that has support for pruning of data belonging to a specific node may implement this interface.Interfaceakka.cluster.ddataAkka
RemoveInternalClusterShardingDataClassakka.cluster.shardingAkka
RemoveInternalClusterShardingData$Utility program that removes the internal data stored with Akka Persistence by the Cluster Sharding coordinator.Classakka.cluster.shardingAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceIdINTERNAL API: Remove all events and snapshots for one specific persistenceId.Classakka.cluster.sharding.RemoveInternalClusterShardingDataAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId$Classakka.cluster.sharding.RemoveInternalClusterShardingDataAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .RemovalsClassakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Removals$Classakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .ResultClassakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Result$Classakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
ReplicatedDataInterface for implementing a state based convergent replicated data type (CvRDT).Interfaceakka.cluster.ddataAkka
ReplicatedDataMessagesClassakka.cluster.ddata.protobuf.msgAkka
ReplicatedDataMessages .FlagProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .Flag .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.FlagAkka
ReplicatedDataMessages .FlagOrBuilderrequired bool enabled = 1;required bool enabled = 1;Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .GCounterProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .GCounter .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounterAkka
ReplicatedDataMessages .GCounter .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounterAkka
ReplicatedDataMessages .GCounter .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounter.EntryAkka
ReplicatedDataMessages .GCounter .EntryOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounterAkka
ReplicatedDataMessages .GCounterOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .GSetProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .GSet .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GSetAkka
ReplicatedDataMessages .GSetOrBuilderrepeated sint32 intElements = 2 [packed = true];intgetIntElementsCount()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .LWWMapProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .LWWMap .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMapAkka
ReplicatedDataMessages .LWWMap .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMapAkka
ReplicatedDataMessages .LWWMap .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMap.EntryAkka
ReplicatedDataMessages .LWWMap .EntryOrBuilderrequired string key = 1;ByteStringgetKeyBytes()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMapAkka
ReplicatedDataMessages .LWWMapOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .LWWRegisterProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .LWWRegister .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWRegisterAkka
ReplicatedDataMessages .LWWRegisterOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .ORMapProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .ORMap .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMapAkka
ReplicatedDataMessages .ORMap .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMapAkka
ReplicatedDataMessages .ORMap .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMap.EntryAkka
ReplicatedDataMessages .ORMap .EntryOrBuilderrequired string key = 1;ByteStringgetKeyBytes()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMapAkka
ReplicatedDataMessages .ORMapOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .ORMultiMapProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .ORMultiMap .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMapAkka
ReplicatedDataMessages .ORMultiMap .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMapAkka
ReplicatedDataMessages .ORMultiMap .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMap.EntryAkka
ReplicatedDataMessages .ORMultiMap .EntryOrBuilderrequired string key = 1;ByteStringgetKeyBytes()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMapAkka
ReplicatedDataMessages .ORMultiMapOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .ORSetProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .ORSet .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORSetAkka
ReplicatedDataMessages .ORSetOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .PNCounterProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .PNCounter .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterAkka
ReplicatedDataMessages .PNCounterMapProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .PNCounterMap .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMapAkka
ReplicatedDataMessages .PNCounterMap .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMapAkka
ReplicatedDataMessages .PNCounterMap .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMap.EntryAkka
ReplicatedDataMessages .PNCounterMap .EntryOrBuilderrequired string key = 1;ByteStringgetKeyBytes()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMapAkka
ReplicatedDataMessages .PNCounterMapOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .PNCounterOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .VersionVectorProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataMessages .VersionVector .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVectorAkka
ReplicatedDataMessages .VersionVector .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVectorAkka
ReplicatedDataMessages .VersionVector .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVector.EntryAkka
ReplicatedDataMessages .VersionVector .EntryOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVectorAkka
ReplicatedDataMessages .VersionVectorOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatedDataMessagesAkka
ReplicatedDataSerializerProtobuf serializer of ReplicatedData.Classakka.cluster.ddata.protobufAkka
ReplicatorA replicated in-memory data store supporting low latency and high availability The Replicator actor takes care of direct replication and gossip basedClassakka.cluster.ddataAkka
Replicator$Classakka.cluster.ddataAkka
Replicator .ChangedThe data value is retrieved with get(akka.Classakka.cluster.ddata.ReplicatorAkka
Replicator .Changed$Classakka.cluster.ddata.ReplicatorAkka
Replicator .DataDeletedClassakka.cluster.ddata.ReplicatorAkka
Replicator .DataDeleted$Classakka.cluster.ddata.ReplicatorAkka
Replicator .DeleteSend this message to the local Replicator to delete a data value for the given key.Classakka.cluster.ddata.ReplicatorAkka
Replicator .Delete$Classakka.cluster.ddata.ReplicatorAkka
Replicator .DeleteSuccessClassakka.cluster.ddata.ReplicatorAkka
Replicator .DeleteSuccess$Classakka.cluster.ddata.ReplicatorAkka
Replicator .FlushChanges$Notify subscribers of changes now, otherwise they will be notified periodically with the configured notify-subscribers-interval.Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetSend this message to the local Replicator to retrieve a data value for the given key.Classakka.cluster.ddata.ReplicatorAkka
Replicator .Get$Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetFailureThe Replicator.Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetFailure$Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetKeyIds$Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetKeyIdsResultClassakka.cluster.ddata.ReplicatorAkka
Replicator .GetKeyIdsResult$Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetReplicaCount$Get current number of replicas, including the local replica.Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetResponseClassakka.cluster.ddata.ReplicatorAkka
Replicator .GetSuccessReply from Get.Classakka.cluster.ddata.ReplicatorAkka
Replicator .GetSuccess$Classakka.cluster.ddata.ReplicatorAkka
Replicator .Internal$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ModifyFailureIf the modify function of the Replicator.Classakka.cluster.ddata.ReplicatorAkka
Replicator .ModifyFailure$Classakka.cluster.ddata.ReplicatorAkka
Replicator .NotFoundClassakka.cluster.ddata.ReplicatorAkka
Replicator .NotFound$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReadAllClassakka.cluster.ddata.ReplicatorAkka
Replicator .ReadAll$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReadFromClassakka.cluster.ddata.ReplicatorAkka
Replicator .ReadFrom$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReadLocal$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReadMajorityClassakka.cluster.ddata.ReplicatorAkka
Replicator .ReadMajority$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReplicaCountCurrent number of replicas.Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReplicaCount$Classakka.cluster.ddata.ReplicatorAkka
Replicator .ReplicationDeleteFailureClassakka.cluster.ddata.ReplicatorAkka
Replicator .ReplicationDeleteFailure$Classakka.cluster.ddata.ReplicatorAkka
Replicator .SubscribeRegister a subscriber that will be notified with a Replicator.Classakka.cluster.ddata.ReplicatorAkka
Replicator .Subscribe$Classakka.cluster.ddata.ReplicatorAkka
Replicator .UnsubscribeUnregister a subscriber.Classakka.cluster.ddata.ReplicatorAkka
Replicator .Unsubscribe$Classakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateClassakka.cluster.ddata.ReplicatorAkka
Replicator .Update$Classakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateFailureClassakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateResponseClassakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateSuccessClassakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateSuccess$Classakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateTimeoutThe direct replication of the Replicator.Classakka.cluster.ddata.ReplicatorAkka
Replicator .UpdateTimeout$Classakka.cluster.ddata.ReplicatorAkka
Replicator .WriteAllClassakka.cluster.ddata.ReplicatorAkka
Replicator .WriteAll$Classakka.cluster.ddata.ReplicatorAkka
Replicator .WriteLocal$Classakka.cluster.ddata.ReplicatorAkka
Replicator .WriteMajorityClassakka.cluster.ddata.ReplicatorAkka
Replicator .WriteMajority$Classakka.cluster.ddata.ReplicatorAkka
Replicator .WriteToClassakka.cluster.ddata.ReplicatorAkka
Replicator .WriteTo$Classakka.cluster.ddata.ReplicatorAkka
ReplicatorMessagesClassakka.cluster.ddata.protobuf.msgAkka
ReplicatorMessages .AddressProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Address .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.AddressAkka
ReplicatorMessages .AddressOrBuilderrequired string hostname = 1;ByteStringgetHostnameBytes()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .ChangedProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Changed .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.ChangedAkka
ReplicatorMessages .ChangedOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .DataEnvelopeProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .DataEnvelope .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelopeAkka
ReplicatorMessages .DataEnvelope .PruningEntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelopeAkka
ReplicatorMessages .DataEnvelope .PruningEntry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelope.PruningEntryAkka
ReplicatorMessages .DataEnvelope .PruningEntryOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelopeAkka
ReplicatorMessages .DataEnvelopeOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .EmptyProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Empty .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.EmptyAkka
ReplicatorMessages .EmptyOrBuilderInterfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .GetProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Get .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.GetAkka
ReplicatorMessages .GetFailureProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .GetFailure .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.GetFailureAkka
ReplicatorMessages .GetFailureOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .GetOrBuilderrequired sint32 consistency = 2;ReplicatorMessages.Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .GetSuccessProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .GetSuccess .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.GetSuccessAkka
ReplicatorMessages .GetSuccessOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .GossipProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Gossip .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.GossipAkka
ReplicatorMessages .Gossip .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.GossipAkka
ReplicatorMessages .Gossip .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.Gossip.EntryAkka
ReplicatorMessages .Gossip .EntryOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessages.GossipAkka
ReplicatorMessages .GossipOrBuilderrepeated .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .NotFoundProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .NotFound .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.NotFoundAkka
ReplicatorMessages .NotFoundOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .OtherMessageProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .OtherMessage .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessageAkka
ReplicatorMessages .OtherMessageOrBuilderrequired bytes enclosedMessage = 1;ByteStringgetMessageManifest()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .ReadProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Read .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.ReadAkka
ReplicatorMessages .ReadOrBuilderrequired string key = 1;ByteStringgetKeyBytes()Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .ReadResultProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .ReadResult .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.ReadResultAkka
ReplicatorMessages .ReadResultOrBuilderoptional .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .StatusProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Status .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.StatusAkka
ReplicatorMessages .Status .EntryProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.StatusAkka
ReplicatorMessages .Status .Entry .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.Status.EntryAkka
ReplicatorMessages .Status .EntryOrBuilderrequired bytes digest = 2;java.Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessages.StatusAkka
ReplicatorMessages .StatusOrBuilderrequired uint32 chunk = 1;ReplicatorMessages.Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .StringGSetProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .StringGSet .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.StringGSetAkka
ReplicatorMessages .StringGSetOrBuilderInterfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .SubscribeProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Subscribe .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.SubscribeAkka
ReplicatorMessages .SubscribeOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .UniqueAddressProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .UniqueAddress .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.UniqueAddressAkka
ReplicatorMessages .UniqueAddressOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .UnsubscribeProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Unsubscribe .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.UnsubscribeAkka
ReplicatorMessages .UnsubscribeOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .WriteProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessages .Write .BuilderProtobuf type akka.Classakka.cluster.ddata.protobuf.msg.ReplicatorMessages.WriteAkka
ReplicatorMessages .WriteOrBuilderrequired .Interfaceakka.cluster.ddata.protobuf.msg.ReplicatorMessagesAkka
ReplicatorMessageSerializerProtobuf serializer of ReplicatorMessage messages.Classakka.cluster.ddata.protobufAkka
ReplicatorMessageSerializer$Classakka.cluster.ddata.protobufAkka
ReplicatorMessageSerializer .SmallCacheA cache that is designed for a small number (<= 32) of entries.Classakka.cluster.ddata.protobuf.ReplicatorMessageSerializerAkka
ReplicatorSettingsparam: role Replicas are running on members tagged with this role.Classakka.cluster.ddataAkka
ReplicatorSettings$Classakka.cluster.ddataAkka
SerializationSupportSome useful serialization helper methods.Interfaceakka.cluster.ddata.protobufAkka
Shard This actor creates children entity actors on demand that it is told to beSee Also:ClusterSharding extensionClassakka.cluster.shardingAkka
Shard$Classakka.cluster.shardingAkka
Shard .CurrentShardStateClassakka.cluster.sharding.ShardAkka
Shard .CurrentShardState$Classakka.cluster.sharding.ShardAkka
Shard .EntityStartedState change for starting an entity in this ShardSee Also:Serialized FormClassakka.cluster.sharding.ShardAkka
Shard .EntityStarted$Classakka.cluster.sharding.ShardAkka
Shard .EntityStoppedState change for an entity which has terminated.Classakka.cluster.sharding.ShardAkka
Shard .EntityStopped$Classakka.cluster.sharding.ShardAkka
Shard .GetCurrentShardState$Classakka.cluster.sharding.ShardAkka
Shard .GetShardStats$Classakka.cluster.sharding.ShardAkka
Shard .RestartEntityWhen an remembering entities and the entity stops without issuing a Passivate, we restart it after a back off using this message.Classakka.cluster.sharding.ShardAkka
Shard .RestartEntity$Classakka.cluster.sharding.ShardAkka
Shard .ShardStatsClassakka.cluster.sharding.ShardAkka
Shard .ShardStats$Classakka.cluster.sharding.ShardAkka
Shard .StateClassakka.cluster.sharding.ShardAkka
Shard .State$Classakka.cluster.sharding.ShardAkka
Shard .StateChangeA case class which represents a state change for the Shardjava.Interfaceakka.cluster.sharding.ShardAkka
ShardCoordinatorSingleton coordinator that decides where to allocate shards.Classakka.cluster.shardingAkka
ShardCoordinator$Classakka.cluster.shardingAkka
ShardCoordinator .AbstractShardAllocationStrategyJava API: Java implementations of custom shard allocation and rebalancing logic used by the ShardCoordinator should extend this abstract class and implement the two methods.Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .Internal$Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .LeastShardAllocationStrategyThe default implementation of ShardCoordinator.Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .RebalanceWorkerINTERNAL API.Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .ShardAllocationStrategy Java implementations should extend ShardCoordinator.Interfaceakka.cluster.sharding.ShardCoordinatorAkka
ShardRegionThis actor creates children entity actors on demand for the shards that it is told to be responsible for.Classakka.cluster.shardingAkka
ShardRegion$Classakka.cluster.shardingAkka
ShardRegion .ClusterShardingStatsReply to ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ClusterShardingStats$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentRegionsReply to GetCurrentRegionsSee Also:Serialized FormClassakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentRegions$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentShardRegionStateReply to ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentShardRegionState$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetClusterShardingStatsSend this message to the ShardRegion actor to request for ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetClusterShardingStats$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetCurrentRegions$Send this message to the ShardRegion actor to request for ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetShardRegionState$Send this message to a ShardRegion actor instance to request a ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetShardRegionStats$Send this message to the ShardRegion actor to request for ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GracefulShutdown$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .HandOffStopperINTERNAL API.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .HashCodeMessageExtractorConvenience implementation of ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .MessageExtractorJava API: Interface of functions to extract entity id, shard id, and the message to send to the entity from anInterfaceakka.cluster.sharding.ShardRegionAkka
ShardRegion .PassivateIf the state of the entities are persistent you may stop entities that are not used to reduce memory consumption.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .Passivate$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardInitializedWe must be sure that a shard is initialized before to start send messages to it.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardInitialized$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardRegionStatsClassakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardRegionStats$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardStateClassakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardState$Classakka.cluster.sharding.ShardRegionAkka
SigarMetricsCollectorLoads metrics through Hyperic SIGAR and JMX monitoring beans.Classakka.cluster.metricsAkka
SigarMetricsCollectorLoads metrics through Hyperic SIGAR and JMX monitoring beans.Classakka.clusterAkka
SigarProviderProvide sigar instance as SigarProxy.Interfaceakka.cluster.metricsAkka
SigarProvider$Classakka.cluster.metricsAkka
StandardMetricsDefinitions of the built-in standard metrics.Classakka.cluster.metricsAkka
StandardMetricsDefinitions of the built-in standard metrics.Classakka.clusterAkka
StandardMetrics$Definitions of the built-in standard metrics.Classakka.cluster.metricsAkka
StandardMetrics$Definitions of the built-in standard metrics.Classakka.clusterAkka
StandardMetrics .CpuClassakka.cluster.metrics.StandardMetricsAkka
StandardMetrics .CpuClassakka.cluster.StandardMetricsAkka
StandardMetrics .Cpu$Classakka.cluster.metrics.StandardMetricsAkka
StandardMetrics .Cpu$Classakka.cluster.StandardMetricsAkka
StandardMetrics .HeapMemoryClassakka.cluster.metrics.StandardMetricsAkka
StandardMetrics .HeapMemoryClassakka.cluster.StandardMetricsAkka
StandardMetrics .HeapMemory$Classakka.cluster.metrics.StandardMetricsAkka
StandardMetrics .HeapMemory$Classakka.cluster.StandardMetricsAkka
SystemLoadAverageMetricsSelectorMetricsSelector that uses the system load average metrics.Classakka.cluster.metricsAkka
SystemLoadAverageMetricsSelectorMetricsSelector that uses the system load average metrics.Classakka.cluster.routingAkka
SystemLoadAverageMetricsSelector$MetricsSelector that uses the system load average metrics.Classakka.cluster.metricsAkka
SystemLoadAverageMetricsSelector$MetricsSelector that uses the system load average metrics.Classakka.cluster.routingAkka
TryNativeClassakka.cluster.metricsAkka
TryNative$Classakka.cluster.metricsAkka
UniqueAddressMember identifier consisting of address and random uid.Classakka.clusterAkka
UniqueAddress$Classakka.clusterAkka
VectorClockClassakka.clusterAkka
VectorClock$VectorClock module with helper classes and methods.Classakka.clusterAkka
VectorClock .After$Classakka.cluster.VectorClockAkka
VectorClock .Before$Classakka.cluster.VectorClockAkka
VectorClock .Concurrent$Classakka.cluster.VectorClockAkka
VectorClock .Node$Classakka.cluster.VectorClockAkka
VectorClock .Same$Classakka.cluster.VectorClockAkka
VectorClock .Timestamp$Classakka.cluster.VectorClockAkka
VectorClockStatsClassakka.clusterAkka
VectorClockStats$Classakka.clusterAkka
VersionVectorRepresentation of a Vector-based clock (counting clock), inspired by Lamport logical clocks.Classakka.cluster.ddataAkka
VersionVector$VersionVector module with helper classes and methods.Classakka.cluster.ddataAkka
VersionVector .After$Classakka.cluster.ddata.VersionVectorAkka
VersionVector .Before$Classakka.cluster.ddata.VersionVectorAkka
VersionVector .Concurrent$Classakka.cluster.ddata.VersionVectorAkka
VersionVector .Same$Classakka.cluster.ddata.VersionVectorAkka
VersionVector .Timestamp$Classakka.cluster.ddata.VersionVectorAkka
WeightedRoutees Pick routee based on its weight.Classakka.cluster.metricsAkka
WeightedRoutees Pick routee based on its weight.Classakka.cluster.routingAkka
WriteAggregatorClassakka.cluster.ddataAkka
WriteAggregator$Classakka.cluster.ddataAkka