akka.persistence.multidc.serialization

Class CrdtSerializer

java.lang.Object

akka.serialization.SerializerWithStringManifest

akka.persistence.multidc.serialization.CrdtSerializer

All Implemented Interfaces:

akka.serialization.BaseSerializer, akka.serialization.Serializer

public final class CrdtSerializer
extends akka.serialization.SerializerWithStringManifest
implements akka.serialization.BaseSerializer

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
CrdtSerializer(akka.actor.ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
Counter	counterFromBinary(byte[] bytes)
byte[]	counterToProtoByteArray(Counter counter)
Counter.Updated	counterUpdatedFromBinary(byte[] bytes)
byte[]	counterUpdatedToProtoBufByteArray(Counter.Updated updated)
java.lang.Object	fromBinary(byte[] bytes, java.lang.String manifest)
java.lang.String	manifest(java.lang.Object o)
ORSet<java.lang.Object>	orsetFromBinary(byte[] bytes)
ORSet<java.lang.Object>	orsetFromProto(Crdts.ORSet orset)
Crdts.ORSet	orsetToProto(ORSet<?> orset)
akka.actor.ExtendedActorSystem	system()
byte[]	toBinary(java.lang.Object o)
VersionVector	versionVectorFromBinary(byte[] bytes)
VersionVector	versionVectorFromProto(Crdts.VersionVector versionVector)
Crdts.VersionVector	versionVectorToProto(VersionVector versionVector)

Methods inherited from class akka.serialization.SerializerWithStringManifest

fromBinary, fromBinary, fromBinary, identifier, includeManifest

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.serialization.BaseSerializer

akka$serialization$BaseSerializer$_setter_$identifier_$eq, identifier, identifierFromConfig, SerializationIdentifiers

Methods inherited from interface akka.serialization.Serializer

fromBinary, fromBinary, fromBinary, includeManifest

Constructor Detail

CrdtSerializer

public CrdtSerializer(akka.actor.ExtendedActorSystem system)

Method Detail

counterFromBinary

public Counter counterFromBinary(byte[] bytes)

counterToProtoByteArray

public byte[] counterToProtoByteArray(Counter counter)

counterUpdatedFromBinary

public Counter.Updated counterUpdatedFromBinary(byte[] bytes)

counterUpdatedToProtoBufByteArray

public byte[] counterUpdatedToProtoBufByteArray(Counter.Updated updated)

fromBinary

public java.lang.Object fromBinary(byte[] bytes,
                                   java.lang.String manifest)

Specified by:

fromBinary in class akka.serialization.SerializerWithStringManifest

manifest

public java.lang.String manifest(java.lang.Object o)

Specified by:

manifest in class akka.serialization.SerializerWithStringManifest

orsetFromBinary

public ORSet<java.lang.Object> orsetFromBinary(byte[] bytes)

orsetFromProto

public ORSet<java.lang.Object> orsetFromProto(Crdts.ORSet orset)

orsetToProto

public Crdts.ORSet orsetToProto(ORSet<?> orset)

system

public akka.actor.ExtendedActorSystem system()

Specified by:

system in interface akka.serialization.BaseSerializer

toBinary

public byte[] toBinary(java.lang.Object o)

Specified by:

toBinary in interface akka.serialization.Serializer

Specified by:

toBinary in class akka.serialization.SerializerWithStringManifest

versionVectorFromBinary

public VersionVector versionVectorFromBinary(byte[] bytes)

versionVectorFromProto

public VersionVector versionVectorFromProto(Crdts.VersionVector versionVector)

versionVectorToProto

public Crdts.VersionVector versionVectorToProto(VersionVector versionVector)