Package org.apache.pekko.cluster.ddata.protobuf

Interface SerializationSupport

All Known Implementing Classes:

AbstractSerializationSupport, ReplicatedDataSerializer, ReplicatorMessageSerializer

public interface SerializationSupport

Some useful serialization helper methods.

Method Summary

Modifier and Type	Method	Description
Address	addressFromProto(ReplicatorMessages.Address address)
String	addressProtocol()
ReplicatorMessages.Address.Builder	addressToProto(Address address)
int	BufferSize()
byte[]	compress(org.apache.pekko.protobufv3.internal.MessageLite msg)
byte[]	decompress(byte[] bytes)
Object	otherMessageFromBinary(byte[] bytes)
Object	otherMessageFromProto(ReplicatorMessages.OtherMessage other)
ReplicatorMessages.OtherMessage	otherMessageToProto(Object msg)
void	protocol_$eq(String x$1)
ActorRef	resolveActorRef(String path)
void	ser_$eq(Serialization x$1)
Serialization	serialization()
ExtendedActorSystem	system()
void	transportInfo_$eq(Serialization.Information x$1)
Serialization.Information	transportInformation()
UniqueAddress	uniqueAddressFromProto(ReplicatorMessages.UniqueAddress uniqueAddress)
ReplicatorMessages.UniqueAddress.Builder	uniqueAddressToProto(UniqueAddress uniqueAddress)
VersionVector	versionVectorFromBinary(byte[] bytes)
VersionVector	versionVectorFromProto(ReplicatorMessages.VersionVector versionVector)
ReplicatorMessages.VersionVector	versionVectorToProto(VersionVector versionVector)

Method Details

BufferSize

int BufferSize()

addressFromProto

Address addressFromProto(ReplicatorMessages.Address address)

addressProtocol

String addressProtocol()

addressToProto

ReplicatorMessages.Address.Builder addressToProto(Address address)

compress

byte[] compress(org.apache.pekko.protobufv3.internal.MessageLite msg)

decompress

byte[] decompress(byte[] bytes)

otherMessageFromBinary

Object otherMessageFromBinary(byte[] bytes)

otherMessageFromProto

Object otherMessageFromProto(ReplicatorMessages.OtherMessage other)

otherMessageToProto

ReplicatorMessages.OtherMessage otherMessageToProto(Object msg)

protocol_$eq

void protocol_$eq(String x$1)

resolveActorRef

ActorRef resolveActorRef(String path)

ser_$eq

void ser_$eq(Serialization x$1)

serialization

Serialization serialization()

system

ExtendedActorSystem system()

transportInfo_$eq

void transportInfo_$eq(Serialization.Information x$1)

transportInformation

Serialization.Information transportInformation()

uniqueAddressFromProto

UniqueAddress uniqueAddressFromProto(ReplicatorMessages.UniqueAddress uniqueAddress)

uniqueAddressToProto

ReplicatorMessages.UniqueAddress.Builder uniqueAddressToProto(UniqueAddress uniqueAddress)

versionVectorFromBinary

VersionVector versionVectorFromBinary(byte[] bytes)

versionVectorFromProto

VersionVector versionVectorFromProto(ReplicatorMessages.VersionVector versionVector)

versionVectorToProto

ReplicatorMessages.VersionVector versionVectorToProto(VersionVector versionVector)