Package org.apache.pekko.remote.artery

Class RemoteInstrument

java.lang.Object

org.apache.pekko.remote.artery.RemoteInstrument

public abstract class RemoteInstrument
extends Object

INTERNAL API

Part of the monitoring SPI which allows attaching metadata to outbound remote messages, and reading in metadata from incoming messages.

Multiple instruments are automatically handled, however they MUST NOT overlap in their idenfitiers.

Instances of RemoteInstrument are created from configuration. A new instance of RemoteInstrument will be created for each encoder and decoder. It's only called from the operator, so if it doesn't delegate to any shared instance it doesn't have to be thread-safe.

Constructor Summary

Constructors

Constructor	Description
RemoteInstrument()

Method Summary

Modifier and Type	Method	Description
abstract byte	identifier()	Instrument identifier.
abstract void	remoteMessageReceived(ActorRef recipient, Object message, ActorRef sender, int size, long time)	Called when the message has been deserialized.
abstract void	remoteMessageSent(ActorRef recipient, Object message, ActorRef sender, int size, long time)	Called right before putting the message onto the wire.
abstract void	remoteReadMetadata(ActorRef recipient, Object message, ActorRef sender, ByteBuffer buffer)	Called while deserializing the message once a message (containing a metadata field designated for this instrument) is found.
abstract void	remoteWriteMetadata(ActorRef recipient, Object message, ActorRef sender, ByteBuffer buffer)	Called while serializing the message.
boolean	serializationTimingEnabled()	Should the serialization be timed? Otherwise times are always 0.

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteInstrument

public RemoteInstrument()

Method Details

identifier

public abstract byte identifier()

Instrument identifier.

MUST be >=1 and <32.

Values between 1 and 7 are reserved for Pekko internal use.

remoteMessageReceived

public abstract void remoteMessageReceived(ActorRef recipient,
 Object message,
 ActorRef sender,
 int size,
 long time)

Called when the message has been deserialized.

The size is the total serialized size in bytes of the complete message including Pekko specific headers and any RemoteInstrument metadata. If serializationTimingEnabled returns true, then time will be the total time it took to deserialize all data in the message in nanoseconds, otherwise it is 0.

remoteMessageSent

public abstract void remoteMessageSent(ActorRef recipient,
 Object message,
 ActorRef sender,
 int size,
 long time)

Called right before putting the message onto the wire. Parameters MAY be null (except message and buffer)!

The size is the total serialized size in bytes of the complete message including Pekko specific headers and any RemoteInstrument metadata. If serializationTimingEnabled returns true, then time will be the total time it took to serialize all data in the message in nanoseconds, otherwise it is 0.

remoteReadMetadata

public abstract void remoteReadMetadata(ActorRef recipient,
 Object message,
 ActorRef sender,
 ByteBuffer buffer)

Called while deserializing the message once a message (containing a metadata field designated for this instrument) is found.

remoteWriteMetadata

public abstract void remoteWriteMetadata(ActorRef recipient,
 Object message,
 ActorRef sender,
 ByteBuffer buffer)

Called while serializing the message. Parameters MAY be null (except message and buffer)!

serializationTimingEnabled

public boolean serializationTimingEnabled()

Should the serialization be timed? Otherwise times are always 0.