public class ReplicatedDataSerializer extends akka.serialization.SerializerWithStringManifest implements SerializationSupport, akka.serialization.BaseSerializer
Constructor and Description |
---|
ReplicatedDataSerializer(akka.actor.ExtendedActorSystem system) |
fromBinary, fromBinary, fromBinary, identifier, includeManifest
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addressFromProto, addressProtocol, addressToProto, BufferSize, compress, decompress, otherMessageFromBinary, otherMessageFromProto, otherMessageToProto, protocol, resolveActorRef, ser, serialization, transportInfo, transportInformation, uniqueAddressFromProto, uniqueAddressToProto
public ReplicatedDataSerializer(akka.actor.ExtendedActorSystem system)
public akka.actor.ExtendedActorSystem system()
system
in interface SerializationSupport
system
in interface akka.serialization.BaseSerializer
public java.lang.String manifest(java.lang.Object obj)
manifest
in class akka.serialization.SerializerWithStringManifest
public byte[] toBinary(java.lang.Object obj)
toBinary
in interface akka.serialization.Serializer
toBinary
in class akka.serialization.SerializerWithStringManifest
public java.lang.Object fromBinary(byte[] bytes, java.lang.String manifest)
fromBinary
in class akka.serialization.SerializerWithStringManifest
public ReplicatedDataMessages.GSet gsetToProto(GSet<?> gset)
public GSet<?> gsetFromBinary(byte[] bytes)
public GSet<java.lang.Object> gsetFromProto(ReplicatedDataMessages.GSet gset)
public ReplicatedDataMessages.ORSet orsetToProto(ORSet<?> orset)
public ORSet<java.lang.Object> orsetFromBinary(byte[] bytes)
public ORSet<java.lang.Object> orsetFromProto(ReplicatedDataMessages.ORSet orset)
public ReplicatedDataMessages.Flag flagToProto(Flag flag)
public Flag flagFromBinary(byte[] bytes)
public Flag flagFromProto(ReplicatedDataMessages.Flag flag)
public ReplicatedDataMessages.LWWRegister lwwRegisterToProto(LWWRegister<?> lwwRegister)
public LWWRegister<java.lang.Object> lwwRegisterFromBinary(byte[] bytes)
public LWWRegister<java.lang.Object> lwwRegisterFromProto(ReplicatedDataMessages.LWWRegister lwwRegister)
public ReplicatedDataMessages.GCounter gcounterToProto(GCounter gcounter)
public GCounter gcounterFromBinary(byte[] bytes)
public GCounter gcounterFromProto(ReplicatedDataMessages.GCounter gcounter)
public ReplicatedDataMessages.PNCounter pncounterToProto(PNCounter pncounter)
public PNCounter pncounterFromBinary(byte[] bytes)
public PNCounter pncounterFromProto(ReplicatedDataMessages.PNCounter pncounter)
public ReplicatedDataMessages.VersionVector versionVectorToProto(VersionVector versionVector)
public VersionVector versionVectorFromBinary(byte[] bytes)
public VersionVector versionVectorFromProto(ReplicatedDataMessages.VersionVector versionVector)
public ReplicatedDataMessages.ORMap ormapToProto(ORMap<?> ormap)
public ORMap<ReplicatedData> ormapFromBinary(byte[] bytes)
public ORMap<ReplicatedData> ormapFromProto(ReplicatedDataMessages.ORMap ormap)
public ReplicatedDataMessages.LWWMap lwwmapToProto(LWWMap<?> lwwmap)
public LWWMap<java.lang.Object> lwwmapFromBinary(byte[] bytes)
public LWWMap<java.lang.Object> lwwmapFromProto(ReplicatedDataMessages.LWWMap lwwmap)
public ReplicatedDataMessages.PNCounterMap pncountermapToProto(PNCounterMap pncountermap)
public PNCounterMap pncountermapFromBinary(byte[] bytes)
public PNCounterMap pncountermapFromProto(ReplicatedDataMessages.PNCounterMap pncountermap)
public ReplicatedDataMessages.ORMultiMap multimapToProto(ORMultiMap<?> multimap)
public ORMultiMap<java.lang.Object> multimapFromBinary(byte[] bytes)
public ORMultiMap<java.lang.Object> multimapFromProto(ReplicatedDataMessages.ORMultiMap multimap)
public byte[] keyIdToBinary(java.lang.String id)
public java.lang.String keyIdFromBinary(byte[] bytes)