akka.remote.artery.compress

Class InboundManifestCompression

java.lang.Object

akka.remote.artery.compress.InboundCompression<java.lang.String>

akka.remote.artery.compress.InboundManifestCompression

public final class InboundManifestCompression
extends InboundCompression<java.lang.String>

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class akka.remote.artery.compress.InboundCompression

InboundCompression.State<T>, InboundCompression.State$

Constructor Summary

Constructors

Constructor and Description
InboundManifestCompression(LoggingAdapter log, ArterySettings.Compression settings, long originUid, InboundContext inboundContext, TopHeavyHitters<java.lang.String> heavyHitters)

Method Summary

Modifier and Type	Method and Description
void	advertiseCompressionTable(OutboundContext outboundContext, CompressionTable<java.lang.String> table) Must be implemented by extending classes in order to send a ControlMessage of appropriate type to the remote system in order to advertise the compression table to it.
OptionVal<java.lang.String>	decompress(byte incomingTableVersion, int idx) Override and specialize if needed, for default compression logic delegate to 3-param overload
void	increment(Address remoteAddress, java.lang.String value, long n) Add n occurrence for the given key and call heavyHittedDetected if element has become a heavy hitter.

Methods inherited from class akka.remote.artery.compress.InboundCompression

confirmAdvertisement, decompressInternal, heavyHitters, log, runNextTableAdvertisement, settings, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

InboundManifestCompression

public InboundManifestCompression(LoggingAdapter log,
                                  ArterySettings.Compression settings,
                                  long originUid,
                                  InboundContext inboundContext,
                                  TopHeavyHitters<java.lang.String> heavyHitters)

Method Detail

advertiseCompressionTable

public void advertiseCompressionTable(OutboundContext outboundContext,
                                      CompressionTable<java.lang.String> table)

Description copied from class: InboundCompression

Must be implemented by extending classes in order to send a ControlMessage of appropriate type to the remote system in order to advertise the compression table to it.

Specified by:

advertiseCompressionTable in class InboundCompression<java.lang.String>

Parameters:

outboundContext - (undocumented)

table - (undocumented)

increment

public void increment(Address remoteAddress,
                      java.lang.String value,
                      long n)

Description copied from class: InboundCompression

Add n occurrence for the given key and call heavyHittedDetected if element has become a heavy hitter. Empty keys are omitted.

Overrides:

increment in class InboundCompression<java.lang.String>

Parameters:

remoteAddress - (undocumented)

value - (undocumented)

n - (undocumented)

decompress

public OptionVal<java.lang.String> decompress(byte incomingTableVersion,
                                              int idx)

Description copied from class: InboundCompression

Override and specialize if needed, for default compression logic delegate to 3-param overload

Specified by:

decompress in class InboundCompression<java.lang.String>