Package akka.remote.artery.compress
-
Interface Summary Interface Description CompressionProtocol.CompressionAckMessage INTERNAL APICompressionProtocol.CompressionAdvertisement<T> INTERNAL APICompressionProtocol.CompressionMessage INTERNAL APICompressionProtocol.Events$.Event INTERNAL APIInboundCompressions INTERNAL API Decompress and cause compression advertisements. -
Class Summary Class Description CompressionProtocol INTERNAL APICompressionProtocol.ActorRefCompressionAdvertisement INTERNAL API Sent by the "receiving" node after allocating a compression id to a givenActorRefCompressionProtocol.ActorRefCompressionAdvertisement$ CompressionProtocol.ActorRefCompressionAdvertisementAck INTERNAL API Sent by the "sending" node after receivingCompressionProtocol.ActorRefCompressionAdvertisementThe 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 manifestCompressionProtocol.ClassManifestCompressionAdvertisement$ CompressionProtocol.ClassManifestCompressionAdvertisementAck INTERNAL API Sent by the "sending" node after receivingCompressionProtocol.ClassManifestCompressionAdvertisementThe 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 APICompressionProtocol$ INTERNAL APICompressionTable<T> INTERNAL API: Versioned compression table to be advertised between systemsCompressionTable$ INTERNAL APICountMinSketch INTERNAL API: Count-Min Sketch datastructure.DecompressionTable<T> INTERNAL APIDecompressionTable$ INTERNAL APIInboundActorRefCompression 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.Tables<T> InboundCompression.Tables$ InboundCompression$ INTERNAL APIInboundCompressionsImpl INTERNAL APIInboundCompressionsImpl$ InboundManifestCompression INTERNAL APINoInboundCompressions INTERNAL APINoInboundCompressions$ INTERNAL APITopHeavyHitters<T> INTERNAL APITopHeavyHitters.HashCodeVal Value class to avoid mixing up count and hashCode in APIs.TopHeavyHitters.HashCodeVal$ TopHeavyHitters$ INTERNAL API -
Exception Summary Exception Description UnknownCompressedIdException INTERNAL API