44 lines
1.1 KiB
C#
44 lines
1.1 KiB
C#
using System;
|
|
|
|
using Confluent.Kafka;
|
|
|
|
using Google.Protobuf;
|
|
|
|
namespace ASC.Common.Caching
|
|
{
|
|
public class ProtobufSerializer<T> : ISerializer<T> where T : IMessage<T>, new()
|
|
{
|
|
public byte[] Serialize(T data, SerializationContext context)
|
|
{
|
|
return data.ToByteArray();
|
|
}
|
|
}
|
|
|
|
public class ProtobufDeserializer<T> : IDeserializer<T> where T : IMessage<T>, new()
|
|
{
|
|
private readonly MessageParser<T> parser;
|
|
|
|
public ProtobufDeserializer()
|
|
{
|
|
parser = new MessageParser<T>(() => new T());
|
|
}
|
|
|
|
public T Deserialize(ReadOnlySpan<byte> data, bool isNull, SerializationContext context)
|
|
{
|
|
return parser.ParseFrom(data.ToArray());
|
|
}
|
|
}
|
|
|
|
public static class GuidExtension
|
|
{
|
|
public static ByteString ToByteString(this Guid id)
|
|
{
|
|
return ByteString.CopyFrom(id.ToByteArray());
|
|
}
|
|
public static Guid FromByteString(this ByteString id)
|
|
{
|
|
return new Guid(id.ToByteArray());
|
|
}
|
|
}
|
|
}
|