Name | Description | Type | Package | Framework |
AbstractReplicatedData | Java API: Interface for implementing a ReplicatedData in Java. | Class | akka.cluster.ddata | Akka |
|
AbstractSerializationSupport | | Class | akka.cluster.ddata.protobuf | Akka |
|
AdaptiveLoadBalancingGroup | A router group that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingGroup | A router group that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.routing | Akka |
|
AdaptiveLoadBalancingGroup$ | | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingGroup$ | | Class | akka.cluster.routing | Akka |
|
AdaptiveLoadBalancingMetricsListener | Subscribe to ClusterMetricsEvents and update routing logic depending on the events. | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingMetricsListener | | Class | akka.cluster.routing | Akka |
|
AdaptiveLoadBalancingPool | A router pool that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingPool | A router pool that performs load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.routing | Akka |
|
AdaptiveLoadBalancingPool$ | | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingPool$ | | Class | akka.cluster.routing | Akka |
|
AdaptiveLoadBalancingRoutingLogic | Load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingRoutingLogic | Load balancing of messages to cluster nodes based on cluster metric data. | Class | akka.cluster.routing | Akka |
|
AdaptiveLoadBalancingRoutingLogic$ | | Class | akka.cluster.metrics | Akka |
|
AdaptiveLoadBalancingRoutingLogic$ | | Class | akka.cluster.routing | Akka |
|
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 the | Class | akka.cluster | Akka |
|
AutoDown$ | | Class | akka.cluster | Akka |
|
AutoDown .UnreachableTimeout | | Class | akka.cluster.AutoDown | Akka |
|
AutoDown .UnreachableTimeout$ | | Class | akka.cluster.AutoDown | Akka |
|
AutoDownBase | The implementation is split into two classes AutoDown and AutoDownBase to be able to unit test the logic without running cluster. | Class | akka.cluster | Akka |
|
CapacityMetricsSelector | A MetricsSelector producing weights from remaining capacity. | Class | akka.cluster.metrics | Akka |
|
CapacityMetricsSelector | A MetricsSelector producing weights from remaining capacity. | Class | akka.cluster.routing | Akka |
|
Cluster | This module is responsible cluster membership information. | Class | akka.cluster | Akka |
|
Cluster$ | Cluster Extension Id and factory for creating Cluster extension. | Class | akka.cluster | Akka |
|
ClusterActorRefProvider | The ClusterActorRefProvider will load the Cluster extension, i. | Class | akka.cluster | Akka |
|
ClusterClient | This actor is intended to be used on an external node that is not member of the cluster. | Class | akka.cluster.client | Akka |
|
ClusterClient$ | | Class | akka.cluster.client | Akka |
|
ClusterClient .Internal$ | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClient .Publish | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClient .Publish$ | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClient .Send | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClient .Send$ | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClient .SendToAll | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClient .SendToAll$ | | Class | akka.cluster.client.ClusterClient | Akka |
|
ClusterClientMessages | | Class | akka.cluster.client.protobuf.msg | Akka |
|
ClusterClientMessages .Contacts | Protobuf type ContactsSee Also:Serialized Form | Class | akka.cluster.client.protobuf.msg.ClusterClientMessages | Akka |
|
ClusterClientMessages .Contacts .Builder | Protobuf type Contactsrepeated string contactPoints = 1; | Class | akka.cluster.client.protobuf.msg.ClusterClientMessages.Contacts | Akka |
|
ClusterClientMessages .ContactsOrBuilder | | Interface | akka.cluster.client.protobuf.msg.ClusterClientMessages | Akka |
|
ClusterClientMessageSerializer | INTERNAL API: Serializer of ClusterClient messages. | Class | akka.cluster.client.protobuf | Akka |
|
ClusterClientReceptionist | Extension that starts ClusterReceptionist and accompanying DistributedPubSubMediator with settings defined in config section akka. | Class | akka.cluster.client | Akka |
|
ClusterClientReceptionist$ | | Class | akka.cluster.client | Akka |
|
ClusterClientSettings | param: initialContacts Actor paths of the ClusterReceptionist actors on the servers (cluster nodes) that the client will try to contact initially. | Class | akka.cluster.client | Akka |
|
ClusterClientSettings$ | | Class | akka.cluster.client | Akka |
|
ClusterCoreDaemon | | Class | akka.cluster | Akka |
|
ClusterCoreSupervisor | ClusterCoreDaemon and ClusterDomainEventPublisher can't be restarted because the state would be obsolete. | Class | akka.cluster | Akka |
|
ClusterDaemon | Supervisor managing the different Cluster daemons. | Class | akka.cluster | Akka |
|
ClusterDeployer | Deployer of cluster aware routers. | Class | akka.cluster | Akka |
|
ClusterDomainEventPublisher | Responsible for domain event subscriptions and publishing of domain events to event bus. | Class | akka.cluster | Akka |
|
ClusterEvent | Domain events published to the event bus. | Class | akka.cluster | Akka |
|
ClusterEvent$ | Domain events published to the event bus. | Class | akka.cluster | Akka |
|
ClusterEvent .ClusterMetricsChanged | Current snapshot of cluster node metrics. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .ClusterMetricsChanged$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .ClusterShuttingDown$ | This event is published when the cluster node is shutting down, before the final ClusterEvent. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .CurrentClusterState | Current snapshot state of the cluster. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .CurrentClusterState$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .CurrentInternalStats | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .CurrentInternalStats$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .InitialStateAsEvents$ | When using this subscription mode the events corresponding to the current state will be sent to the subscriber to mimic what you would | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .InitialStateAsSnapshot$ | When using this subscription mode a snapshot of ClusterEvent. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .LeaderChanged | Leader of the cluster members changed. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .LeaderChanged$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberEvent | Marker interface for membership events. | Interface | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberExited | Member status changed to MemberStatus. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberExited$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberJoined | Member status changed to Joining. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberJoined$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberLeft | Member status changed to Leaving. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberLeft$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberRemoved | Member completely removed from the cluster. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberRemoved$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberUp | Member status changed to Up. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberUp$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberWeaklyUp | Member status changed to WeaklyUp. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .MemberWeaklyUp$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .ReachabilityChanged | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .ReachabilityChanged$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .ReachableMember | A member is considered as reachable by the failure detector after having been unreachable. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .ReachableMember$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .RoleLeaderChanged | First member (leader) of the members within a role set changed. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .RoleLeaderChanged$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .SeenChanged | The nodes that have seen current version of the Gossip. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .SeenChanged$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .SubscriptionInitialStateMode | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .UnreachableMember | A member is considered as unreachable by the failure detector. | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterEvent .UnreachableMember$ | | Class | akka.cluster.ClusterEvent | Akka |
|
ClusterHeartbeatReceiver | Receives Heartbeat messages and replies. | Class | akka.cluster | Akka |
|
ClusterHeartbeatSender | | Class | akka.cluster | Akka |
|
ClusterHeartbeatSender$ | | Class | akka.cluster | Akka |
|
ClusterHeartbeatSender .ExpectedFirstHeartbeat | | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSender .ExpectedFirstHeartbeat$ | | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSender .Heartbeat | Sent at regular intervals for failure detection. | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSender .Heartbeat$ | | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSender .HeartbeatRsp | Sent as reply to ClusterHeartbeatSender. | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSender .HeartbeatRsp$ | | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSender .HeartbeatTick$ | | Class | akka.cluster.ClusterHeartbeatSender | Akka |
|
ClusterHeartbeatSenderState | State of ClusterHeartbeatSender. | Class | akka.cluster | Akka |
|
ClusterHeartbeatSenderState$ | | Class | akka.cluster | Akka |
|
ClusterJmx | | Class | akka.cluster | Akka |
|
ClusterMessages | | Class | akka.cluster.protobuf.msg | Akka |
|
ClusterMessages .Address | Protobuf type Address Defines a remote address. | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Address .Builder | Protobuf type Address Defines a remote address. | Class | akka.cluster.protobuf.msg.ClusterMessages.Address | Akka |
|
ClusterMessages .AddressOrBuilder | required string hostname = 2;ByteStringgetHostnameBytes() | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Empty | | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Empty .Builder | Constructs the message based on the state of the Builder. | Class | akka.cluster.protobuf.msg.ClusterMessages.Empty | Akka |
|
ClusterMessages .EmptyOrBuilder | | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Gossip | Protobuf type GossipSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Gossip .Builder | Protobuf type Gossiprepeated . | Class | akka.cluster.protobuf.msg.ClusterMessages.Gossip | Akka |
|
ClusterMessages .GossipEnvelope | Protobuf type GossipEnvelopeSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .GossipEnvelope .Builder | Protobuf type GossipEnvelopeConstructs the message based on the state of the Builder. | Class | akka.cluster.protobuf.msg.ClusterMessages.GossipEnvelope | Akka |
|
ClusterMessages .GossipEnvelopeOrBuilder | required . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .GossipOrBuilder | repeated . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .GossipOverview | Protobuf type GossipOverviewSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .GossipOverview .Builder | Protobuf type GossipOverview | Class | akka.cluster.protobuf.msg.ClusterMessages.GossipOverview | Akka |
|
ClusterMessages .GossipOverviewOrBuilder | repeated . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .GossipStatus | Protobuf type GossipStatusSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .GossipStatus .Builder | Protobuf type GossipStatusrepeated string allHashes = 2; | Class | akka.cluster.protobuf.msg.ClusterMessages.GossipStatus | Akka |
|
ClusterMessages .GossipStatusOrBuilder | | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Join | | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Join .Builder | repeated string roles = 2;ClusterMessages. | Class | akka.cluster.protobuf.msg.ClusterMessages.Join | Akka |
|
ClusterMessages .JoinOrBuilder | required . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Member | Protobuf type MemberSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Member .Builder | Protobuf type Memberrepeated int32 rolesIndexes = 4 [packed = true]; | Class | akka.cluster.protobuf.msg.ClusterMessages.Member | Akka |
|
ClusterMessages .MemberOrBuilder | | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .MemberStatus | | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .MetricsGossip | Protobuf type MetricsGossipSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .MetricsGossip .Builder | Protobuf type MetricsGossiprepeated . | Class | akka.cluster.protobuf.msg.ClusterMessages.MetricsGossip | Akka |
|
ClusterMessages .MetricsGossipEnvelope | Protobuf type MetricsGossipEnvelope Metrics Gossip Envelope | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .MetricsGossipEnvelope .Builder | Protobuf type MetricsGossipEnvelope Metrics Gossip Envelope | Class | akka.cluster.protobuf.msg.ClusterMessages.MetricsGossipEnvelope | Akka |
|
ClusterMessages .MetricsGossipEnvelopeOrBuilder | required . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .MetricsGossipOrBuilder | repeated . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .NodeMetrics | Protobuf type NodeMetricsSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .NodeMetrics .Builder | Protobuf type NodeMetricsrepeated . | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .EWMA | Protobuf type NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .EWMA .Builder | Protobuf type NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics.EWMA | Akka |
|
ClusterMessages .NodeMetrics .EWMAOrBuilder | required double alpha = 2;required double value = 1; | Interface | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .Metric | Protobuf type NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .Metric .Builder | Protobuf type NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics.Metric | Akka |
|
ClusterMessages .NodeMetrics .MetricOrBuilder | optional . | Interface | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .Number | Protobuf type NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .Number .Builder | Protobuf type NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics.Number | Akka |
|
ClusterMessages .NodeMetrics .NumberOrBuilder | optional bytes serialized = 4;ClusterMessages. | Interface | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetrics .NumberType | Protobuf enum NodeMetrics. | Class | akka.cluster.protobuf.msg.ClusterMessages.NodeMetrics | Akka |
|
ClusterMessages .NodeMetricsOrBuilder | required int32 addressIndex = 1;ClusterMessages. | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .ObserverReachability | Protobuf type ObserverReachabilitySee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .ObserverReachability .Builder | Protobuf type ObserverReachability | Class | akka.cluster.protobuf.msg.ClusterMessages.ObserverReachability | Akka |
|
ClusterMessages .ObserverReachabilityOrBuilder | required int32 addressIndex = 1;ClusterMessages. | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .ReachabilityStatus | Protobuf enum ReachabilityStatus Reachability status | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .SubjectReachability | Protobuf type SubjectReachabilitySee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .SubjectReachability .Builder | Protobuf type SubjectReachabilityConstructs the message based on the state of the Builder. | Class | akka.cluster.protobuf.msg.ClusterMessages.SubjectReachability | Akka |
|
ClusterMessages .SubjectReachabilityOrBuilder | required int32 addressIndex = 1;ClusterMessages. | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .UniqueAddress | Protobuf type UniqueAddress Defines a remote address with uid. | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .UniqueAddress .Builder | Protobuf type UniqueAddress Defines a remote address with uid. | Class | akka.cluster.protobuf.msg.ClusterMessages.UniqueAddress | Akka |
|
ClusterMessages .UniqueAddressOrBuilder | required . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .VectorClock | Protobuf type VectorClockSee Also:Serialized Form | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .VectorClock .Builder | Protobuf type VectorClockrepeated . | Class | akka.cluster.protobuf.msg.ClusterMessages.VectorClock | Akka |
|
ClusterMessages .VectorClock .Version | Protobuf type VectorClock. | Class | akka.cluster.protobuf.msg.ClusterMessages.VectorClock | Akka |
|
ClusterMessages .VectorClock .Version .Builder | Protobuf type VectorClock. | Class | akka.cluster.protobuf.msg.ClusterMessages.VectorClock.Version | Akka |
|
ClusterMessages .VectorClock .VersionOrBuilder | required int32 hashIndex = 1;required int64 timestamp = 2; | Interface | akka.cluster.protobuf.msg.ClusterMessages.VectorClock | Akka |
|
ClusterMessages .VectorClockOrBuilder | optional int64 timestamp = 1; the timestamp could be removed but left for test data compatibility | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Welcome | Protobuf type Welcome Welcome, reply to Join | Class | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessages .Welcome .Builder | Protobuf type Welcome Welcome, reply to Join | Class | akka.cluster.protobuf.msg.ClusterMessages.Welcome | Akka |
|
ClusterMessages .WelcomeOrBuilder | required . | Interface | akka.cluster.protobuf.msg.ClusterMessages | Akka |
|
ClusterMessageSerializer | Protobuf serializer of cluster messages. | Class | akka.cluster.protobuf | Akka |
|
ClusterMetricsChanged | Current snapshot of cluster node metrics. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsChanged$ | | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsCollector | Cluster metrics is primarily for load-balancing of nodes. | Class | akka.cluster | Akka |
|
ClusterMetricsCollector | Actor responsible for periodic data sampling in the node and publication to the cluster. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsExtension | Cluster metrics extension. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsExtension$ | Cluster metrics extension provider. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsMessages | | Class | akka.cluster.metrics.protobuf.msg | Akka |
|
ClusterMetricsMessages .Address | Protobuf type Address Defines a remote address. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .Address .Builder | Protobuf type Address Defines a remote address. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.Address | Akka |
|
ClusterMetricsMessages .AddressOrBuilder | required string hostname = 2;ByteStringgetHostnameBytes() | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .MetricsGossip | Protobuf type MetricsGossipSee Also:Serialized Form | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .MetricsGossip .Builder | Protobuf type MetricsGossiprepeated . | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.MetricsGossip | Akka |
|
ClusterMetricsMessages .MetricsGossipEnvelope | Protobuf type MetricsGossipEnvelope Metrics Gossip Envelope | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .MetricsGossipEnvelope .Builder | Protobuf type MetricsGossipEnvelope Metrics Gossip Envelope | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.MetricsGossipEnvelope | Akka |
|
ClusterMetricsMessages .MetricsGossipEnvelopeOrBuilder | required . | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .MetricsGossipOrBuilder | repeated . | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .NodeMetrics | Protobuf type NodeMetricsSee Also:Serialized Form | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsMessages .NodeMetrics .Builder | Protobuf type NodeMetrics | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .EWMA | Protobuf type NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .EWMA .Builder | Protobuf type NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics.EWMA | Akka |
|
ClusterMetricsMessages .NodeMetrics .EWMAOrBuilder | required double alpha = 2;required double value = 1; | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .Metric | Protobuf type NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .Metric .Builder | Protobuf type NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics.Metric | Akka |
|
ClusterMetricsMessages .NodeMetrics .MetricOrBuilder | optional . | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .Number | Protobuf type NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .Number .Builder | Protobuf type NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics.Number | Akka |
|
ClusterMetricsMessages .NodeMetrics .NumberOrBuilder | optional bytes serialized = 4;ClusterMetricsMessages. | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetrics .NumberType | Protobuf enum NodeMetrics. | Class | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages.NodeMetrics | Akka |
|
ClusterMetricsMessages .NodeMetricsOrBuilder | required int32 addressIndex = 1;ClusterMetricsMessages. | Interface | akka.cluster.metrics.protobuf.msg.ClusterMetricsMessages | Akka |
|
ClusterMetricsSettings | Metrics extension settings. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsSettings$ | | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsStrategy | Default ClusterMetricsSupervisor strategy: A configurable OneForOneStrategy with restart-on-throwable decider. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsStrategy$ | Provide custom metrics strategy resources. | Class | akka.cluster.metrics | Akka |
|
ClusterMetricsSupervisor | Actor providing customizable metrics collection supervision. | Class | akka.cluster.metrics | Akka |
|
ClusterNodeMBean | Interface for the cluster JMX MBean. | Interface | akka.cluster | Akka |
|
ClusterReadView | Read view of cluster state, updated via subscription of cluster events published on the event bus. | Class | akka.cluster | Akka |
|
ClusterReceptionist | ClusterClient connects to this actor to retrieve. | Class | akka.cluster.client | Akka |
|
ClusterReceptionist$ | | Class | akka.cluster.client | Akka |
|
ClusterReceptionist .Internal$ | | Class | akka.cluster.client.ClusterReceptionist | Akka |
|
ClusterReceptionistSettings | param: role Start the receptionist on members tagged with this role. | Class | akka.cluster.client | Akka |
|
ClusterReceptionistSettings$ | | Class | akka.cluster.client | Akka |
|
ClusterRemoteWatcher | Specialization of RemoteWatcher that keeps track of cluster member nodes and is responsible for watchees on cluster nodes. | Class | akka.cluster | Akka |
|
ClusterRemoteWatcher$ | | Class | akka.cluster | Akka |
|
ClusterRouterActor | The router actor, subscribes to cluster events and adjusts the routees. | Interface | akka.cluster.routing | Akka |
|
ClusterRouterConfigBase | Create the actual router, responsible for routing messages to routees. | Interface | akka.cluster.routing | Akka |
|
ClusterRouterGroup | RouterConfig implementation for deployment on cluster nodes. | Class | akka.cluster.routing | Akka |
|
ClusterRouterGroup$ | | Class | akka.cluster.routing | Akka |
|
ClusterRouterGroupActor | | Class | akka.cluster.routing | Akka |
|
ClusterRouterGroupSettings | | Class | akka.cluster.routing | Akka |
|
ClusterRouterGroupSettings$ | | Class | akka.cluster.routing | Akka |
|
ClusterRouterPool | RouterConfig implementation for deployment on cluster nodes. | Class | akka.cluster.routing | Akka |
|
ClusterRouterPool$ | | Class | akka.cluster.routing | Akka |
|
ClusterRouterPoolActor | | Class | akka.cluster.routing | Akka |
|
ClusterRouterPoolSettings | | Class | akka.cluster.routing | Akka |
|
ClusterRouterPoolSettings$ | | Class | akka.cluster.routing | Akka |
|
ClusterRouterSettingsBase | | Interface | akka.cluster.routing | Akka |
|
ClusterRouterSettingsBase$ | | Class | akka.cluster.routing | Akka |
|
ClusterScope | | Class | akka.cluster | Akka |
|
ClusterScope$ | Cluster aware scope of a DeploySee Also:Serialized Form | Class | akka.cluster | Akka |
|
ClusterSettings | | Class | akka.cluster | Akka |
|
ClusterSharding | | Class | akka.cluster.sharding | Akka |
|
ClusterSharding$ | This extension provides sharding functionality of actors in a cluster. | Class | akka.cluster.sharding | Akka |
|
ClusterShardingGuardian | INTERNAL API. | Class | akka.cluster.sharding | Akka |
|
ClusterShardingGuardian$ | | Class | akka.cluster.sharding | Akka |
|
ClusterShardingGuardian .Start | | Class | akka.cluster.sharding.ClusterShardingGuardian | Akka |
|
ClusterShardingGuardian .Start$ | | Class | akka.cluster.sharding.ClusterShardingGuardian | Akka |
|
ClusterShardingGuardian .Started | | Class | akka.cluster.sharding.ClusterShardingGuardian | Akka |
|
ClusterShardingGuardian .Started$ | | Class | akka.cluster.sharding.ClusterShardingGuardian | Akka |
|
ClusterShardingGuardian .StartProxy | | Class | akka.cluster.sharding.ClusterShardingGuardian | Akka |
|
ClusterShardingGuardian .StartProxy$ | | Class | akka.cluster.sharding.ClusterShardingGuardian | Akka |
|
ClusterShardingMessages | | Class | akka.cluster.sharding.protobuf.msg | Akka |
|
ClusterShardingMessages .ActorRefMessage | Protobuf type ActorRefMessageSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ActorRefMessage .Builder | Protobuf type ActorRefMessageConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessage | Akka |
|
ClusterShardingMessages .ActorRefMessageOrBuilder | required string ref = 1;ByteStringgetRefBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .CoordinatorState | Protobuf type CoordinatorStateSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .CoordinatorState .Builder | Protobuf type CoordinatorStaterepeated string regionProxies = 3; | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState | Akka |
|
ClusterShardingMessages .CoordinatorState .ShardEntry | Protobuf type CoordinatorState. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState | Akka |
|
ClusterShardingMessages .CoordinatorState .ShardEntry .Builder | Protobuf type CoordinatorState. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntry | Akka |
|
ClusterShardingMessages .CoordinatorState .ShardEntryOrBuilder | required string regionRef = 2;ByteStringgetRegionRefBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState | Akka |
|
ClusterShardingMessages .CoordinatorStateOrBuilder | | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .EntityStarted | Protobuf type EntityStartedSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .EntityStarted .Builder | Protobuf type EntityStartedConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStarted | Akka |
|
ClusterShardingMessages .EntityStartedOrBuilder | required string entityId = 1;ByteStringgetEntityIdBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .EntityState | Protobuf type EntityStateSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .EntityState .Builder | Protobuf type EntityStaterepeated string entities = 1; | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityState | Akka |
|
ClusterShardingMessages .EntityStateOrBuilder | | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .EntityStopped | Protobuf type EntityStoppedSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .EntityStopped .Builder | Protobuf type EntityStoppedConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStopped | Akka |
|
ClusterShardingMessages .EntityStoppedOrBuilder | required string entityId = 1;ByteStringgetEntityIdBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardHome | Protobuf type ShardHomeSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardHome .Builder | Protobuf type ShardHomeConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHome | Akka |
|
ClusterShardingMessages .ShardHomeAllocated | Protobuf type ShardHomeAllocatedSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardHomeAllocated .Builder | Protobuf type ShardHomeAllocatedConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocated | Akka |
|
ClusterShardingMessages .ShardHomeAllocatedOrBuilder | required string region = 2;ByteStringgetRegionBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardHomeOrBuilder | required string region = 2;ByteStringgetRegionBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardIdMessage | Protobuf type ShardIdMessageSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardIdMessage .Builder | Protobuf type ShardIdMessageConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessage | Akka |
|
ClusterShardingMessages .ShardIdMessageOrBuilder | required string shard = 1;ByteStringgetShardBytes() | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardStats | Protobuf type ShardStatsSee Also:Serialized Form | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessages .ShardStats .Builder | Protobuf type ShardStatsConstructs the message based on the state of the Builder. | Class | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardStats | Akka |
|
ClusterShardingMessages .ShardStatsOrBuilder | required int32 entityCount = 2;java. | Interface | akka.cluster.sharding.protobuf.msg.ClusterShardingMessages | Akka |
|
ClusterShardingMessageSerializer | INTERNAL API: Protobuf serializer of ClusterSharding messages. | Class | akka.cluster.sharding.protobuf | Akka |
|
ClusterShardingSettings | param: role specifies that this entity type requires cluster nodes with a specific role. | Class | akka.cluster.sharding | Akka |
|
ClusterShardingSettings$ | | Class | akka.cluster.sharding | Akka |
|
ClusterShardingSettings .TuningParameters | | Class | akka.cluster.sharding.ClusterShardingSettings | Akka |
|
ClusterSingletonManager | Manages singleton actor instance among all cluster nodes or a group of nodes tagged with a specific role. | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonManager$ | | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonManager .Internal$ | | Class | akka.cluster.singleton.ClusterSingletonManager | Akka |
|
ClusterSingletonManagerIsStuck | Thrown when a consistent state can't be determined within the defined retry limits. | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonManagerSettings | param: singletonName The actor name of the child singleton actor. | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonManagerSettings$ | | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonMessageSerializer | INTERNAL API: Serializer of ClusterSingleton messages. | Class | akka.cluster.singleton.protobuf | Akka |
|
ClusterSingletonProxy | The ClusterSingletonProxy works together with the ClusterSingletonManager to provide a distributed proxy to the singleton actor. | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonProxy$ | | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonProxySettings | param: singletonName The actor name of the singleton actor that is started by the ClusterSingletonManager. | Class | akka.cluster.singleton | Akka |
|
ClusterSingletonProxySettings$ | | Class | akka.cluster.singleton | Akka |
|
ClusterUserAction | | Class | akka.cluster | Akka |
|
ClusterUserAction$ | | Class | akka.cluster | Akka |
|
ClusterUserAction .Down | Command to mark node as temporary down. | Class | akka.cluster.ClusterUserAction | Akka |
|
ClusterUserAction .Down$ | | Class | akka.cluster.ClusterUserAction | Akka |
|
ClusterUserAction .JoinTo | Command to initiate join another node (represented by address). | Class | akka.cluster.ClusterUserAction | Akka |
|
ClusterUserAction .JoinTo$ | | Class | akka.cluster.ClusterUserAction | Akka |
|
ClusterUserAction .Leave | Command to leave the cluster. | Class | akka.cluster.ClusterUserAction | Akka |
|
ClusterUserAction .Leave$ | | Class | akka.cluster.ClusterUserAction | Akka |
|
CollectionControlMessage | Runtime collection management commands. | Class | akka.cluster.metrics | Akka |
|
CollectionStartMessage | Command for ClusterMetricsSupervisor to start metrics collection. | Class | akka.cluster.metrics | Akka |
|
CollectionStartMessage$ | Command for ClusterMetricsSupervisor to start metrics collection. | Class | akka.cluster.metrics | Akka |
|
CollectionStopMessage | Command for ClusterMetricsSupervisor to stop metrics collection. | Class | akka.cluster.metrics | Akka |
|
CollectionStopMessage$ | Command for ClusterMetricsSupervisor to stop metrics collection. | Class | akka.cluster.metrics | Akka |
|
CpuMetricsSelector | MetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics. | Class | akka.cluster.metrics | Akka |
|
CpuMetricsSelector | MetricsSelector that uses the combined CPU metrics. | Class | akka.cluster.routing | Akka |
|
CpuMetricsSelector$ | MetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics. | Class | akka.cluster.metrics | Akka |
|
CpuMetricsSelector$ | MetricsSelector that uses the combined CPU metrics. | Class | akka.cluster.routing | Akka |
|
DDataShardCoordinator | Singleton coordinator (with state based on ddata) that decides where to allocate shards. | Class | akka.cluster.sharding | Akka |
|
DefaultSigarProvider | Provide sigar instance as SigarProxy with configured location via ClusterMetricsSettings. | Class | akka.cluster.metrics | Akka |
|
DefaultSigarProvider$ | | Class | akka.cluster.metrics | Akka |
|
DistributedData | Akka extension for convenient configuration and use of the Replicator. | Class | akka.cluster.ddata | Akka |
|
DistributedData$ | | Class | akka.cluster.ddata | Akka |
|
DistributedPubSub | Extension that starts a DistributedPubSubMediator actor with settings defined in config section akka. | Class | akka.cluster.pubsub | Akka |
|
DistributedPubSub$ | | Class | akka.cluster.pubsub | Akka |
|
DistributedPubSubMediator | This actor manages a registry of actor references and replicates the entries to peer actors among all cluster nodes or a group of nodes | Class | akka.cluster.pubsub | Akka |
|
DistributedPubSubMediator$ | | Class | akka.cluster.pubsub | Akka |
|
DistributedPubSubMediator .Count$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .CurrentTopics | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .CurrentTopics$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .GetTopics | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .GetTopics$ | Send this message to the mediator and it will reply with DistributedPubSubMediator. | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Internal$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Internal$ .TopicLike | | Interface | akka.cluster.pubsub.DistributedPubSubMediator.Internal$ | Akka |
|
DistributedPubSubMediator .Publish | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Publish$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Put | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Put$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Remove | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Remove$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Send | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Send$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .SendToAll | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .SendToAll$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Subscribe | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Subscribe$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .SubscribeAck | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .SubscribeAck$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Unsubscribe | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .Unsubscribe$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .UnsubscribeAck | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMediator .UnsubscribeAck$ | | Class | akka.cluster.pubsub.DistributedPubSubMediator | Akka |
|
DistributedPubSubMessages | | Class | akka.cluster.pubsub.protobuf.msg | Akka |
|
DistributedPubSubMessages .Address | Protobuf type Address Defines a remote address. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Address .Builder | Protobuf type Address Defines a remote address. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Address | Akka |
|
DistributedPubSubMessages .AddressOrBuilder | required string hostname = 2;ByteStringgetHostnameBytes() | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Delta | | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Delta .Bucket | Protobuf type Delta. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta | Akka |
|
DistributedPubSubMessages .Delta .Bucket .Builder | Protobuf type Delta. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta.Bucket | Akka |
|
DistributedPubSubMessages .Delta .BucketOrBuilder | repeated . | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta | Akka |
|
DistributedPubSubMessages .Delta .Builder | repeated . | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta | Akka |
|
DistributedPubSubMessages .Delta .Entry | Protobuf type Delta. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta | Akka |
|
DistributedPubSubMessages .Delta .Entry .Builder | Protobuf type Delta. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta.Entry | Akka |
|
DistributedPubSubMessages .Delta .EntryOrBuilder | required string key = 1;ByteStringgetKeyBytes() | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Delta | Akka |
|
DistributedPubSubMessages .DeltaOrBuilder | repeated . | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Payload | Protobuf type PayloadSee Also:Serialized Form | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Payload .Builder | Protobuf type PayloadConstructs the message based on the state of the Builder. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Payload | Akka |
|
DistributedPubSubMessages .PayloadOrBuilder | required bytes enclosedMessage = 1;ByteStringgetMessageManifest() | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Publish | Protobuf type Publish Publish normally local, but it is also used by the ClusterClient. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Publish .Builder | Protobuf type Publish Publish normally local, but it is also used by the ClusterClient. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Publish | Akka |
|
DistributedPubSubMessages .PublishOrBuilder | required . | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Send | Send normally local, but it is also used by the ClusterClient. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Send .Builder | Send normally local, but it is also used by the ClusterClient. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Send | Akka |
|
DistributedPubSubMessages .SendOrBuilder | required bool localAffinity = 2;java. | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .SendToAll | Protobuf type SendToAll SendToAll normally local, but it is also used by the ClusterClient. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .SendToAll .Builder | Protobuf type SendToAll SendToAll normally local, but it is also used by the ClusterClient. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.SendToAll | Akka |
|
DistributedPubSubMessages .SendToAllOrBuilder | required bool allButSelf = 2;java. | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Status | Protobuf type StatusSee Also:Serialized Form | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessages .Status .Builder | Protobuf type Statusrepeated . | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Status | Akka |
|
DistributedPubSubMessages .Status .Version | Protobuf type Status. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Status | Akka |
|
DistributedPubSubMessages .Status .Version .Builder | Protobuf type Status. | Class | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Status.Version | Akka |
|
DistributedPubSubMessages .Status .VersionOrBuilder | required . | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages.Status | Akka |
|
DistributedPubSubMessages .StatusOrBuilder | repeated . | Interface | akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages | Akka |
|
DistributedPubSubMessageSerializer | INTERNAL API: Protobuf serializer of DistributedPubSubMediator messages. | Class | akka.cluster.pubsub.protobuf | Akka |
|
DistributedPubSubSettings | param: role Start the mediator on members tagged with this role. | Class | akka.cluster.pubsub | Akka |
|
DistributedPubSubSettings$ | | Class | akka.cluster.pubsub | Akka |
|
EWMA | | Class | akka.cluster | Akka |
|
EWMA | The exponentially weighted moving average (EWMA) approach captures short-term movements in volatility for a conditional volatility forecasting model. | Class | akka.cluster.metrics | Akka |
|
EWMA$ | | Class | akka.cluster | Akka |
|
EWMA$ | | Class | akka.cluster.metrics | Akka |
|
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. | Interface | akka.cluster.ddata | Akka |
|
FirstSeedNodeProcess | Used only for the first seed node. | Class | akka.cluster | Akka |
|
Flag | | Class | akka.cluster.ddata | Akka |
|
Flag$ | | Class | akka.cluster.ddata | Akka |
|
FlagKey | | Class | akka.cluster.ddata | Akka |
|
FlagKey$ | | Class | akka.cluster.ddata | Akka |
|
GCounter | | Class | akka.cluster.ddata | Akka |
|
GCounter$ | | Class | akka.cluster.ddata | Akka |
|
GCounterKey | | Class | akka.cluster.ddata | Akka |
|
GCounterKey$ | | Class | akka.cluster.ddata | Akka |
|
Gossip | | Class | akka.cluster | Akka |
|
Gossip$ | | Class | akka.cluster | Akka |
|
GossipEnvelope | Envelope adding a sender and receiver address to the gossip. | Class | akka.cluster | Akka |
|
GossipEnvelope$ | | Class | akka.cluster | Akka |
|
GossipOverview | Represents the overview of the cluster, holds the cluster convergence table and set with unreachable nodes. | Class | akka.cluster | Akka |
|
GossipOverview$ | | Class | akka.cluster | Akka |
|
GossipStats | | Class | akka.cluster | Akka |
|
GossipStats$ | | Class | akka.cluster | Akka |
|
GossipStatus | When there are no known changes to the node ring a GossipStatus initiates a gossip chat between two members. | Class | akka.cluster | Akka |
|
GossipStatus$ | | Class | akka.cluster | Akka |
|
GSet | | Class | akka.cluster.ddata | Akka |
|
GSet$ | | Class | akka.cluster.ddata | Akka |
|
GSetKey | | Class | akka.cluster.ddata | Akka |
|
GSetKey$ | | Class | akka.cluster.ddata | Akka |
|
HeapMetricsSelector | MetricsSelector that uses the heap metrics. | Class | akka.cluster.metrics | Akka |
|
HeapMetricsSelector | MetricsSelector that uses the heap metrics. | Class | akka.cluster.routing | Akka |
|
HeapMetricsSelector$ | MetricsSelector that uses the heap metrics. | Class | akka.cluster.metrics | Akka |
|
HeapMetricsSelector$ | MetricsSelector that uses the heap metrics. | Class | akka.cluster.routing | Akka |
|
HeartbeatNodeRing | Data structure for picking heartbeat receivers. | Class | akka.cluster | Akka |
|
HeartbeatNodeRing$ | | Class | akka.cluster | Akka |
|
InternalClusterAction | | Class | akka.cluster | Akka |
|
InternalClusterAction$ | | Class | akka.cluster | Akka |
|
InternalClusterAction .AddOnMemberRemovedListener | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .AddOnMemberRemovedListener$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .AddOnMemberUpListener | Command to ClusterDaemon to create a OnMemberStatusChangedListener. | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .AddOnMemberUpListener$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .GetClusterCoreRef$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .GossipSpeedupTick$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .GossipTick$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .InitJoin$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .InitJoinAck | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .InitJoinAck$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .InitJoinNack | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .InitJoinNack$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Join | Command to join the cluster. | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Join$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .JoinSeedNode$ | Start message of the process to join one of the seed nodes. | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .JoinSeedNodes | Command to initiate the process to join the specifiedSee Also:Serialized Form | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .JoinSeedNodes$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .LeaderActionsTick$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .MetricsTick$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublishChanges | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublishChanges$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublisherCreated | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublisherCreated$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublishEvent | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublishEvent$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .PublishStatsTick$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .ReapUnreachableTick$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .SendCurrentClusterState | param: receiver ClusterEvent. | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .SendCurrentClusterState$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .SendGossipTo | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .SendGossipTo$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Subscribe | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Subscribe$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Unsubscribe | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Unsubscribe$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Welcome | param: from the sender node in the cluster, i. | Class | akka.cluster.InternalClusterAction | Akka |
|
InternalClusterAction .Welcome$ | | Class | akka.cluster.InternalClusterAction | Akka |
|
JmxMetricsCollector | Loads JVM and system metrics through JMX monitoring beans. | Class | akka.cluster | Akka |
|
JmxMetricsCollector | Loads JVM and system metrics through JMX monitoring beans. | Class | akka.cluster.metrics | Akka |
|
JoinSeedNodeProcess | Sends InitJoin to all seed nodes (except itself) and expect InitJoinAck reply back. | Class | akka.cluster | Akka |
|
Key | Key for the key-value data in Replicator. | Class | akka.cluster.ddata | Akka |
|
Key$ | | Class | akka.cluster.ddata | Akka |
|
LWWMap | Specialized ORMap with LWWRegister values. | Class | akka.cluster.ddata | Akka |
|
LWWMap$ | | Class | akka.cluster.ddata | Akka |
|
LWWMapKey | | Class | akka.cluster.ddata | Akka |
|
LWWMapKey$ | | Class | akka.cluster.ddata | Akka |
|
LWWRegister | It is described in the paper A comprehensive study of Convergent and Commutative Replicated Data Types. | Class | akka.cluster.ddata | Akka |
|
LWWRegister$ | | Class | akka.cluster.ddata | Akka |
|
LWWRegister .Clock | | Interface | akka.cluster.ddata.LWWRegister | Akka |
|
LWWRegisterKey | | Class | akka.cluster.ddata | Akka |
|
LWWRegisterKey$ | | Class | akka.cluster.ddata | Akka |
|
ManyVersionVector | | Class | akka.cluster.ddata | Akka |
|
ManyVersionVector$ | | Class | akka.cluster.ddata | Akka |
|
Member | Represents the address, current status, and roles of a cluster member node. | Class | akka.cluster | Akka |
|
Member$ | Module with factory and ordering methods for Member instances. | Class | akka.cluster | Akka |
|
MemberStatus | Defines the current status of a cluster member node Can be one of: Joining, Up, Leaving, Exiting and Down. | Class | akka.cluster | Akka |
|
MemberStatus$ | | Class | akka.cluster | Akka |
|
MemberStatus .Down$ | | Class | akka.cluster.MemberStatus | Akka |
|
MemberStatus .Exiting$ | | Class | akka.cluster.MemberStatus | Akka |
|
MemberStatus .Joining$ | | Class | akka.cluster.MemberStatus | Akka |
|
MemberStatus .Leaving$ | | Class | akka.cluster.MemberStatus | Akka |
|
MemberStatus .Removed$ | | Class | akka.cluster.MemberStatus | Akka |
|
MemberStatus .Up$ | | Class | akka.cluster.MemberStatus | Akka |
|
MemberStatus .WeaklyUp$ | WeaklyUp is an EXPERIMENTAL feature and is subject to change until it has received more real world testing. | Class | akka.cluster.MemberStatus | Akka |
|
MessageSerializer | Protobuf serializer for ClusterMetricsMessage types. | Class | akka.cluster.metrics.protobuf | Akka |
|
Metric | Equality of Metric is based on its name. | Class | akka.cluster | Akka |
|
Metric | Equality of Metric is based on its name. | Class | akka.cluster.metrics | Akka |
|
Metric$ | Factory for creating valid Metric instances. | Class | akka.cluster | Akka |
|
Metric$ | Factory for creating valid Metric instances. | Class | akka.cluster.metrics | Akka |
|
MetricNumericConverter | Encapsulates evaluation of validity of metric values, conversion of an actual metric value to a Metric for consumption by subscribed cluster entities. | Interface | akka.cluster | Akka |
|
MetricNumericConverter | Encapsulates evaluation of validity of metric values, conversion of an actual metric value to a Metric for consumption by subscribed cluster entities. | Interface | akka.cluster.metrics | Akka |
|
MetricsCollector | Implementations of cluster system metrics collectors extend this trait. | Interface | akka.cluster.metrics | Akka |
|
MetricsCollector | Samples and collects new data points. | Interface | akka.cluster | Akka |
|
MetricsCollector$ | Factory to create configured MetricsCollector. | Class | akka.cluster.metrics | Akka |
|
MetricsCollector$ | Factory to create configured MetricsCollector. | Class | akka.cluster | Akka |
|
MetricsGossip | | Class | akka.cluster.metrics | Akka |
|
MetricsGossip | | Class | akka.cluster | Akka |
|
MetricsGossip$ | | Class | akka.cluster.metrics | Akka |
|
MetricsGossip$ | | Class | akka.cluster | Akka |
|
MetricsGossipEnvelope | Envelope adding a sender address to the cluster metrics gossip. | Class | akka.cluster.metrics | Akka |
|
MetricsGossipEnvelope | Envelope adding a sender address to the gossip. | Class | akka.cluster | Akka |
|
MetricsGossipEnvelope$ | | Class | akka.cluster.metrics | Akka |
|
MetricsGossipEnvelope$ | | Class | akka.cluster | Akka |
|
MetricsSelector | A MetricsSelector is responsible for producing weights from the node metrics. | Interface | akka.cluster.metrics | Akka |
|
MetricsSelector | A MetricsSelector is responsible for producing weights from the node metrics. | Interface | akka.cluster.routing | Akka |
|
MetricsSelector$ | | Class | akka.cluster.metrics | Akka |
|
MetricsSelector$ | | Class | akka.cluster.routing | Akka |
|
MixMetricsSelector | | Class | akka.cluster.metrics | Akka |
|
MixMetricsSelector | | Class | akka.cluster.routing | Akka |
|
MixMetricsSelector$ | Singleton instance of the default MixMetricsSelector, which uses [akka. | Class | akka.cluster.metrics | Akka |
|
MixMetricsSelector$ | Singleton instance of the default MixMetricsSelector, which uses [akka. | Class | akka.cluster.routing | Akka |
|
MixMetricsSelectorBase | Base class for MetricsSelector that combines other selectors and aggregates their capacity. | Class | akka.cluster.metrics | Akka |
|
MixMetricsSelectorBase | Base class for MetricsSelector that combines other selectors and aggregates their capacity. | Class | akka.cluster.routing | Akka |
|
NodeMetrics | The snapshot of current sampled health metrics for any monitored process. | Class | akka.cluster.metrics | Akka |
|
NodeMetrics | The snapshot of current sampled health metrics for any monitored process. | Class | akka.cluster | Akka |
|
NodeMetrics$ | | Class | akka.cluster.metrics | Akka |
|
NodeMetrics$ | | Class | akka.cluster | Akka |
|
OneVersionVector | | Class | akka.cluster.ddata | Akka |
|
OneVersionVector$ | | Class | akka.cluster.ddata | Akka |
|
OnMemberStatusChangedListener | The supplied callback will be run, once, when current cluster member come up with the same status. | Class | akka.cluster | Akka |
|
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. | Class | akka.cluster.ddata | Akka |
|
ORMap$ | | Class | akka.cluster.ddata | Akka |
|
ORMapKey | | Class | akka.cluster.ddata | Akka |
|
ORMapKey$ | | Class | akka.cluster.ddata | Akka |
|
ORMultiMap | An immutable multi-map implementation. | Class | akka.cluster.ddata | Akka |
|
ORMultiMap$ | | Class | akka.cluster.ddata | Akka |
|
ORMultiMapKey | | Class | akka.cluster.ddata | Akka |
|
ORMultiMapKey$ | | Class | akka.cluster.ddata | Akka |
|
ORSet | Elements can be added and removed any number of times. | Class | akka.cluster.ddata | Akka |
|
ORSet$ | | Class | akka.cluster.ddata | Akka |
|
ORSetKey | | Class | akka.cluster.ddata | Akka |
|
ORSetKey$ | | Class | akka.cluster.ddata | Akka |
|
OtherMessageComparator | | Class | akka.cluster.ddata.protobuf | Akka |
|
OtherMessageComparator$ | | Class | akka.cluster.ddata.protobuf | Akka |
|
PersistentShard | This actor creates children entity actors on demand that it is told to be responsible for. | Class | akka.cluster.sharding | Akka |
|
PersistentShardCoordinator | Singleton coordinator that decides where to allocate shards. | Class | akka.cluster.sharding | Akka |
|
PNCounter | It is described in the paper A comprehensive study of Convergent and Commutative Replicated Data Types. | Class | akka.cluster.ddata | Akka |
|
PNCounter$ | | Class | akka.cluster.ddata | Akka |
|
PNCounterKey | | Class | akka.cluster.ddata | Akka |
|
PNCounterKey$ | | Class | akka.cluster.ddata | Akka |
|
PNCounterMap | Map of named counters. | Class | akka.cluster.ddata | Akka |
|
PNCounterMap$ | | Class | akka.cluster.ddata | Akka |
|
PNCounterMapKey | | Class | akka.cluster.ddata | Akka |
|
PNCounterMapKey$ | | Class | akka.cluster.ddata | Akka |
|
PruningState | | Class | akka.cluster.ddata | Akka |
|
PruningState$ | | Class | akka.cluster.ddata | Akka |
|
PruningState .PruningInitialized | | Class | akka.cluster.ddata.PruningState | Akka |
|
PruningState .PruningInitialized$ | | Class | akka.cluster.ddata.PruningState | Akka |
|
PruningState .PruningPerformed$ | | Class | akka.cluster.ddata.PruningState | Akka |
|
Reachability | Immutable data structure that holds the reachability status of subject nodes as seen from observer nodes. | Class | akka.cluster | Akka |
|
Reachability$ | | Class | akka.cluster | Akka |
|
Reachability .Reachable$ | | Class | akka.cluster.Reachability | Akka |
|
Reachability .Record | | Class | akka.cluster.Reachability | Akka |
|
Reachability .Record$ | | Class | akka.cluster.Reachability | Akka |
|
Reachability .Terminated$ | | Class | akka.cluster.Reachability | Akka |
|
Reachability .Unreachable$ | | Class | akka.cluster.Reachability | Akka |
|
ReadAggregator | | Class | akka.cluster.ddata | Akka |
|
ReadAggregator$ | | Class | akka.cluster.ddata | Akka |
|
ReadWriteAggregator | | Class | akka.cluster.ddata | Akka |
|
ReadWriteAggregator$ | | Class | akka.cluster.ddata | Akka |
|
ReadWriteAggregator .SendToSecondary$ | | Class | akka.cluster.ddata.ReadWriteAggregator | Akka |
|
RemovedNodePruning | ReplicatedData that has support for pruning of data belonging to a specific node may implement this interface. | Interface | akka.cluster.ddata | Akka |
|
RemoveInternalClusterShardingData | | Class | akka.cluster.sharding | Akka |
|
RemoveInternalClusterShardingData$ | Utility program that removes the internal data stored with Akka Persistence by the Cluster Sharding coordinator. | Class | akka.cluster.sharding | Akka |
|
RemoveInternalClusterShardingData .RemoveOnePersistenceId | INTERNAL API: Remove all events and snapshots for one specific persistenceId. | Class | akka.cluster.sharding.RemoveInternalClusterShardingData | Akka |
|
RemoveInternalClusterShardingData .RemoveOnePersistenceId$ | | Class | akka.cluster.sharding.RemoveInternalClusterShardingData | Akka |
|
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Removals | | Class | akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId | Akka |
|
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Removals$ | | Class | akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId | Akka |
|
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Result | | Class | akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId | Akka |
|
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Result$ | | Class | akka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceId | Akka |
|
ReplicatedData | Interface for implementing a state based convergent replicated data type (CvRDT). | Interface | akka.cluster.ddata | Akka |
|
ReplicatedDataMessages | | Class | akka.cluster.ddata.protobuf.msg | Akka |
|
ReplicatedDataMessages .Flag | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .Flag .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.Flag | Akka |
|
ReplicatedDataMessages .FlagOrBuilder | required bool enabled = 1;required bool enabled = 1; | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .GCounter | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .GCounter .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounter | Akka |
|
ReplicatedDataMessages .GCounter .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounter | Akka |
|
ReplicatedDataMessages .GCounter .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounter.Entry | Akka |
|
ReplicatedDataMessages .GCounter .EntryOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GCounter | Akka |
|
ReplicatedDataMessages .GCounterOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .GSet | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .GSet .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.GSet | Akka |
|
ReplicatedDataMessages .GSetOrBuilder | repeated sint32 intElements = 2 [packed = true];intgetIntElementsCount() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .LWWMap | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .LWWMap .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMap | Akka |
|
ReplicatedDataMessages .LWWMap .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMap | Akka |
|
ReplicatedDataMessages .LWWMap .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMap.Entry | Akka |
|
ReplicatedDataMessages .LWWMap .EntryOrBuilder | required string key = 1;ByteStringgetKeyBytes() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWMap | Akka |
|
ReplicatedDataMessages .LWWMapOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .LWWRegister | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .LWWRegister .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.LWWRegister | Akka |
|
ReplicatedDataMessages .LWWRegisterOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .ORMap | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .ORMap .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMap | Akka |
|
ReplicatedDataMessages .ORMap .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMap | Akka |
|
ReplicatedDataMessages .ORMap .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMap.Entry | Akka |
|
ReplicatedDataMessages .ORMap .EntryOrBuilder | required string key = 1;ByteStringgetKeyBytes() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMap | Akka |
|
ReplicatedDataMessages .ORMapOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .ORMultiMap | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .ORMultiMap .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMap | Akka |
|
ReplicatedDataMessages .ORMultiMap .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMap | Akka |
|
ReplicatedDataMessages .ORMultiMap .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMap.Entry | Akka |
|
ReplicatedDataMessages .ORMultiMap .EntryOrBuilder | required string key = 1;ByteStringgetKeyBytes() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORMultiMap | Akka |
|
ReplicatedDataMessages .ORMultiMapOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .ORSet | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .ORSet .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.ORSet | Akka |
|
ReplicatedDataMessages .ORSetOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .PNCounter | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .PNCounter .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounter | Akka |
|
ReplicatedDataMessages .PNCounterMap | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .PNCounterMap .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMap | Akka |
|
ReplicatedDataMessages .PNCounterMap .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMap | Akka |
|
ReplicatedDataMessages .PNCounterMap .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMap.Entry | Akka |
|
ReplicatedDataMessages .PNCounterMap .EntryOrBuilder | required string key = 1;ByteStringgetKeyBytes() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.PNCounterMap | Akka |
|
ReplicatedDataMessages .PNCounterMapOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .PNCounterOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .VersionVector | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataMessages .VersionVector .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVector | Akka |
|
ReplicatedDataMessages .VersionVector .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVector | Akka |
|
ReplicatedDataMessages .VersionVector .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVector.Entry | Akka |
|
ReplicatedDataMessages .VersionVector .EntryOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages.VersionVector | Akka |
|
ReplicatedDataMessages .VersionVectorOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatedDataMessages | Akka |
|
ReplicatedDataSerializer | Protobuf serializer of ReplicatedData. | Class | akka.cluster.ddata.protobuf | Akka |
|
Replicator | A replicated in-memory data store supporting low latency and high availability The Replicator actor takes care of direct replication and gossip based | Class | akka.cluster.ddata | Akka |
|
Replicator$ | | Class | akka.cluster.ddata | Akka |
|
Replicator .Changed | The data value is retrieved with get(akka. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Changed$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .DataDeleted | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .DataDeleted$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Delete | Send this message to the local Replicator to delete a data value for the given key. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Delete$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .DeleteSuccess | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .DeleteSuccess$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .FlushChanges$ | Notify subscribers of changes now, otherwise they will be notified periodically with the configured notify-subscribers-interval. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Get | Send this message to the local Replicator to retrieve a data value for the given key. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Get$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetFailure | The Replicator. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetFailure$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetKeyIds$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetKeyIdsResult | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetKeyIdsResult$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetReplicaCount$ | Get current number of replicas, including the local replica. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetResponse | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetSuccess | Reply from Get. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .GetSuccess$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Internal$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ModifyFailure | If the modify function of the Replicator. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ModifyFailure$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .NotFound | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .NotFound$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadAll | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadAll$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadFrom | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadFrom$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadLocal$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadMajority | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReadMajority$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReplicaCount | Current number of replicas. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReplicaCount$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReplicationDeleteFailure | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .ReplicationDeleteFailure$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Subscribe | Register a subscriber that will be notified with a Replicator. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Subscribe$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Unsubscribe | Unregister a subscriber. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Unsubscribe$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Update | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .Update$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .UpdateFailure | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .UpdateResponse | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .UpdateSuccess | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .UpdateSuccess$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .UpdateTimeout | The direct replication of the Replicator. | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .UpdateTimeout$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteAll | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteAll$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteLocal$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteMajority | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteMajority$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteTo | | Class | akka.cluster.ddata.Replicator | Akka |
|
Replicator .WriteTo$ | | Class | akka.cluster.ddata.Replicator | Akka |
|
ReplicatorMessages | | Class | akka.cluster.ddata.protobuf.msg | Akka |
|
ReplicatorMessages .Address | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Address .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Address | Akka |
|
ReplicatorMessages .AddressOrBuilder | required string hostname = 1;ByteStringgetHostnameBytes() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Changed | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Changed .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Changed | Akka |
|
ReplicatorMessages .ChangedOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .DataEnvelope | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .DataEnvelope .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelope | Akka |
|
ReplicatorMessages .DataEnvelope .PruningEntry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelope | Akka |
|
ReplicatorMessages .DataEnvelope .PruningEntry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelope.PruningEntry | Akka |
|
ReplicatorMessages .DataEnvelope .PruningEntryOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.DataEnvelope | Akka |
|
ReplicatorMessages .DataEnvelopeOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Empty | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Empty .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Empty | Akka |
|
ReplicatorMessages .EmptyOrBuilder | | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Get | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Get .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Get | Akka |
|
ReplicatorMessages .GetFailure | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .GetFailure .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.GetFailure | Akka |
|
ReplicatorMessages .GetFailureOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .GetOrBuilder | required sint32 consistency = 2;ReplicatorMessages. | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .GetSuccess | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .GetSuccess .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.GetSuccess | Akka |
|
ReplicatorMessages .GetSuccessOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Gossip | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Gossip .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Gossip | Akka |
|
ReplicatorMessages .Gossip .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Gossip | Akka |
|
ReplicatorMessages .Gossip .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Gossip.Entry | Akka |
|
ReplicatorMessages .Gossip .EntryOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Gossip | Akka |
|
ReplicatorMessages .GossipOrBuilder | repeated . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .NotFound | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .NotFound .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.NotFound | Akka |
|
ReplicatorMessages .NotFoundOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .OtherMessage | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .OtherMessage .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.OtherMessage | Akka |
|
ReplicatorMessages .OtherMessageOrBuilder | required bytes enclosedMessage = 1;ByteStringgetMessageManifest() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Read | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Read .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Read | Akka |
|
ReplicatorMessages .ReadOrBuilder | required string key = 1;ByteStringgetKeyBytes() | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .ReadResult | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .ReadResult .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.ReadResult | Akka |
|
ReplicatorMessages .ReadResultOrBuilder | optional . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Status | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Status .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Status | Akka |
|
ReplicatorMessages .Status .Entry | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Status | Akka |
|
ReplicatorMessages .Status .Entry .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Status.Entry | Akka |
|
ReplicatorMessages .Status .EntryOrBuilder | required bytes digest = 2;java. | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Status | Akka |
|
ReplicatorMessages .StatusOrBuilder | required uint32 chunk = 1;ReplicatorMessages. | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .StringGSet | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .StringGSet .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.StringGSet | Akka |
|
ReplicatorMessages .StringGSetOrBuilder | | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Subscribe | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Subscribe .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Subscribe | Akka |
|
ReplicatorMessages .SubscribeOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .UniqueAddress | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .UniqueAddress .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.UniqueAddress | Akka |
|
ReplicatorMessages .UniqueAddressOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Unsubscribe | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Unsubscribe .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Unsubscribe | Akka |
|
ReplicatorMessages .UnsubscribeOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Write | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessages .Write .Builder | Protobuf type akka. | Class | akka.cluster.ddata.protobuf.msg.ReplicatorMessages.Write | Akka |
|
ReplicatorMessages .WriteOrBuilder | required . | Interface | akka.cluster.ddata.protobuf.msg.ReplicatorMessages | Akka |
|
ReplicatorMessageSerializer | Protobuf serializer of ReplicatorMessage messages. | Class | akka.cluster.ddata.protobuf | Akka |
|
ReplicatorMessageSerializer$ | | Class | akka.cluster.ddata.protobuf | Akka |
|
ReplicatorMessageSerializer .SmallCache | A cache that is designed for a small number (<= 32) of entries. | Class | akka.cluster.ddata.protobuf.ReplicatorMessageSerializer | Akka |
|
ReplicatorSettings | param: role Replicas are running on members tagged with this role. | Class | akka.cluster.ddata | Akka |
|
ReplicatorSettings$ | | Class | akka.cluster.ddata | Akka |
|
SerializationSupport | Some useful serialization helper methods. | Interface | akka.cluster.ddata.protobuf | Akka |
|
Shard | This actor creates children entity actors on demand that it is told to beSee Also:ClusterSharding extension | Class | akka.cluster.sharding | Akka |
|
Shard$ | | Class | akka.cluster.sharding | Akka |
|
Shard .CurrentShardState | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .CurrentShardState$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .EntityStarted | State change for starting an entity in this ShardSee Also:Serialized Form | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .EntityStarted$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .EntityStopped | State change for an entity which has terminated. | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .EntityStopped$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .GetCurrentShardState$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .GetShardStats$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .RestartEntity | When an remembering entities and the entity stops without issuing a Passivate, we restart it after a back off using this message. | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .RestartEntity$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .ShardStats | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .ShardStats$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .State | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .State$ | | Class | akka.cluster.sharding.Shard | Akka |
|
Shard .StateChange | A case class which represents a state change for the Shardjava. | Interface | akka.cluster.sharding.Shard | Akka |
|
ShardCoordinator | Singleton coordinator that decides where to allocate shards. | Class | akka.cluster.sharding | Akka |
|
ShardCoordinator$ | | Class | akka.cluster.sharding | Akka |
|
ShardCoordinator .AbstractShardAllocationStrategy | Java API: Java implementations of custom shard allocation and rebalancing logic used by the ShardCoordinator should extend this abstract class and implement the two methods. | Class | akka.cluster.sharding.ShardCoordinator | Akka |
|
ShardCoordinator .Internal$ | | Class | akka.cluster.sharding.ShardCoordinator | Akka |
|
ShardCoordinator .LeastShardAllocationStrategy | The default implementation of ShardCoordinator. | Class | akka.cluster.sharding.ShardCoordinator | Akka |
|
ShardCoordinator .RebalanceWorker | INTERNAL API. | Class | akka.cluster.sharding.ShardCoordinator | Akka |
|
ShardCoordinator .ShardAllocationStrategy | Java implementations should extend ShardCoordinator. | Interface | akka.cluster.sharding.ShardCoordinator | Akka |
|
ShardRegion | This actor creates children entity actors on demand for the shards that it is told to be responsible for. | Class | akka.cluster.sharding | Akka |
|
ShardRegion$ | | Class | akka.cluster.sharding | Akka |
|
ShardRegion .ClusterShardingStats | Reply to ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ClusterShardingStats$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .CurrentRegions | Reply to GetCurrentRegionsSee Also:Serialized Form | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .CurrentRegions$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .CurrentShardRegionState | Reply to ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .CurrentShardRegionState$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .GetClusterShardingStats | Send this message to the ShardRegion actor to request for ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .GetClusterShardingStats$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .GetCurrentRegions$ | Send this message to the ShardRegion actor to request for ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .GetShardRegionState$ | Send this message to a ShardRegion actor instance to request a ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .GetShardRegionStats$ | Send this message to the ShardRegion actor to request for ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .GracefulShutdown$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .HandOffStopper | INTERNAL API. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .HashCodeMessageExtractor | Convenience implementation of ShardRegion. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .MessageExtractor | Java API: Interface of functions to extract entity id, shard id, and the message to send to the entity from an | Interface | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .Passivate | If the state of the entities are persistent you may stop entities that are not used to reduce memory consumption. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .Passivate$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ShardInitialized | We must be sure that a shard is initialized before to start send messages to it. | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ShardInitialized$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ShardRegionStats | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ShardRegionStats$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ShardState | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
ShardRegion .ShardState$ | | Class | akka.cluster.sharding.ShardRegion | Akka |
|
SigarMetricsCollector | Loads metrics through Hyperic SIGAR and JMX monitoring beans. | Class | akka.cluster.metrics | Akka |
|
SigarMetricsCollector | Loads metrics through Hyperic SIGAR and JMX monitoring beans. | Class | akka.cluster | Akka |
|
SigarProvider | Provide sigar instance as SigarProxy. | Interface | akka.cluster.metrics | Akka |
|
SigarProvider$ | | Class | akka.cluster.metrics | Akka |
|
StandardMetrics | Definitions of the built-in standard metrics. | Class | akka.cluster.metrics | Akka |
|
StandardMetrics | Definitions of the built-in standard metrics. | Class | akka.cluster | Akka |
|
StandardMetrics$ | Definitions of the built-in standard metrics. | Class | akka.cluster.metrics | Akka |
|
StandardMetrics$ | Definitions of the built-in standard metrics. | Class | akka.cluster | Akka |
|
StandardMetrics .Cpu | | Class | akka.cluster.metrics.StandardMetrics | Akka |
|
StandardMetrics .Cpu | | Class | akka.cluster.StandardMetrics | Akka |
|
StandardMetrics .Cpu$ | | Class | akka.cluster.metrics.StandardMetrics | Akka |
|
StandardMetrics .Cpu$ | | Class | akka.cluster.StandardMetrics | Akka |
|
StandardMetrics .HeapMemory | | Class | akka.cluster.metrics.StandardMetrics | Akka |
|
StandardMetrics .HeapMemory | | Class | akka.cluster.StandardMetrics | Akka |
|
StandardMetrics .HeapMemory$ | | Class | akka.cluster.metrics.StandardMetrics | Akka |
|
StandardMetrics .HeapMemory$ | | Class | akka.cluster.StandardMetrics | Akka |
|
SystemLoadAverageMetricsSelector | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.metrics | Akka |
|
SystemLoadAverageMetricsSelector | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.routing | Akka |
|
SystemLoadAverageMetricsSelector$ | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.metrics | Akka |
|
SystemLoadAverageMetricsSelector$ | MetricsSelector that uses the system load average metrics. | Class | akka.cluster.routing | Akka |
|
TryNative | | Class | akka.cluster.metrics | Akka |
|
TryNative$ | | Class | akka.cluster.metrics | Akka |
|
UniqueAddress | Member identifier consisting of address and random uid. | Class | akka.cluster | Akka |
|
UniqueAddress$ | | Class | akka.cluster | Akka |
|
VectorClock | | Class | akka.cluster | Akka |
|
VectorClock$ | VectorClock module with helper classes and methods. | Class | akka.cluster | Akka |
|
VectorClock .After$ | | Class | akka.cluster.VectorClock | Akka |
|
VectorClock .Before$ | | Class | akka.cluster.VectorClock | Akka |
|
VectorClock .Concurrent$ | | Class | akka.cluster.VectorClock | Akka |
|
VectorClock .Node$ | | Class | akka.cluster.VectorClock | Akka |
|
VectorClock .Same$ | | Class | akka.cluster.VectorClock | Akka |
|
VectorClock .Timestamp$ | | Class | akka.cluster.VectorClock | Akka |
|
VectorClockStats | | Class | akka.cluster | Akka |
|
VectorClockStats$ | | Class | akka.cluster | Akka |
|
VersionVector | Representation of a Vector-based clock (counting clock), inspired by Lamport logical clocks. | Class | akka.cluster.ddata | Akka |
|
VersionVector$ | VersionVector module with helper classes and methods. | Class | akka.cluster.ddata | Akka |
|
VersionVector .After$ | | Class | akka.cluster.ddata.VersionVector | Akka |
|
VersionVector .Before$ | | Class | akka.cluster.ddata.VersionVector | Akka |
|
VersionVector .Concurrent$ | | Class | akka.cluster.ddata.VersionVector | Akka |
|
VersionVector .Same$ | | Class | akka.cluster.ddata.VersionVector | Akka |
|
VersionVector .Timestamp$ | | Class | akka.cluster.ddata.VersionVector | Akka |
|
WeightedRoutees | Pick routee based on its weight. | Class | akka.cluster.metrics | Akka |
|
WeightedRoutees | Pick routee based on its weight. | Class | akka.cluster.routing | Akka |
|
WriteAggregator | | Class | akka.cluster.ddata | Akka |
|
WriteAggregator$ | | Class | akka.cluster.ddata | Akka |