| Interface | Description |
|---|---|
| CompressionProtocol.CompressionAckMessage |
INTERNAL API
|
| CompressionProtocol.CompressionAdvertisement<T> |
INTERNAL API
|
| CompressionProtocol.CompressionMessage |
INTERNAL API
|
| CompressionProtocol.Events$.Event |
INTERNAL API
|
| InboundCompressions |
INTERNAL API
Decompress and cause compression advertisements.
|
| Class | Description |
|---|---|
| CompressionProtocol |
INTERNAL API
|
| CompressionProtocol.ActorRefCompressionAdvertisement |
INTERNAL API
Sent by the "receiving" node after allocating a compression id to a given
ActorRef |
| CompressionProtocol.ActorRefCompressionAdvertisement$ | |
| CompressionProtocol.ActorRefCompressionAdvertisementAck |
INTERNAL API
Sent by the "sending" node after receiving
CompressionProtocol.ActorRefCompressionAdvertisement
The advertisement is also confirmed by the first message using that table version,
but we need separate ack in case the sender is not using any of the refs in the advertised
table. |
| CompressionProtocol.ActorRefCompressionAdvertisementAck$ | |
| CompressionProtocol.ClassManifestCompressionAdvertisement |
INTERNAL API
Sent by the "receiving" node after allocating a compression id to a given class manifest
|
| CompressionProtocol.ClassManifestCompressionAdvertisement$ | |
| CompressionProtocol.ClassManifestCompressionAdvertisementAck |
INTERNAL API
Sent by the "sending" node after receiving
CompressionProtocol.ClassManifestCompressionAdvertisement
The advertisement is also confirmed by the first message using that table version,
but we need separate ack in case the sender is not using any of the refs in the advertised
table. |
| CompressionProtocol.ClassManifestCompressionAdvertisementAck$ | |
| CompressionProtocol.Events$ |
INTERNAL API
|
| CompressionProtocol$ |
INTERNAL API
|
| CompressionTable<T> |
INTERNAL API: Versioned compression table to be advertised between systems
|
| CompressionTable$ |
INTERNAL API
|
| CountMinSketch |
INTERNAL API: Count-Min Sketch datastructure.
|
| DecompressionTable<T> |
INTERNAL API
|
| DecompressionTable$ |
INTERNAL API
|
| InboundActorRefCompression |
INTERNAL API
Dedicated per remote system inbound compression table.
|
| InboundCompression<T> |
INTERNAL API
Handles counting and detecting of heavy-hitters and compressing them via a table lookup.
|
| InboundCompression.State<T> | |
| InboundCompression.State$ | |
| InboundCompression$ |
INTERNAL API
|
| InboundCompressionsImpl |
INTERNAL API
|
| InboundCompressionsImpl$ | |
| InboundManifestCompression |
INTERNAL API
|
| NoInboundCompressions |
INTERNAL API
|
| NoInboundCompressions$ |
INTERNAL API
|
| TopHeavyHitters<T> |
INTERNAL API
|
| TopHeavyHitters.HashCodeVal |
Value class to avoid mixing up count and hashCode in APIs.
|
| TopHeavyHitters.HashCodeVal$ | |
| TopHeavyHitters$ |
INTERNAL API
|
| Exception | Description |
|---|---|
| UnknownCompressedIdException |
INTERNAL API
|