| 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 |