Source code for eventscore.ext.redis.serializers

import json

from eventscore.core.abstract import IEventSerializer
from eventscore.core.types import Event



[docs]
class RedisEventSerializer(IEventSerializer[bytes, str]):

[docs]
    def encode(self, event: Event) -> str:
        return json.dumps(event.asdict())



[docs]
    def decode(self, event: bytes) -> Event:
        return Event.fromdict(json.loads(event.decode()))