Module serialization 

Event Serialization Module

This module provides comprehensive serialization support for stream events with:

• Multiple format support (JSON, Protobuf, Avro, Binary)
• Schema evolution and versioning
• Compression integration
• Format auto-detection
• Schema registry integration

Structs

DeltaCompressedEvent

Delta-compressed event representation

DeltaCompressor

Delta compression support for event streams

EnhancedBinaryFormat

Enhanced binary format with streaming support

EventSerializer

Event serializer with format support

EvolutionRules

Schema evolution rules

FormatConverter

Format converter for converting between serialization formats

ProtobufStreamEvent

Protobuf representation of StreamEvent This is a simplified version - in practice you’d use proper .proto definitions

Schema

Schema definition

SchemaRegistry

Schema registry for managing schemas

SerializerOptions

Serializer options

StreamingSerializer

Streaming serializer for batch processing

Enums

CompatibilityMode

Schema compatibility modes

DeltaCompressionType

Delta compression algorithms

EventDelta

Event delta representations

SchemaDefinition

Schema definition types

SerializationFormat

Serialization format types

Functions

from_avro_value

Convert Avro value to StreamEvent

get_default_avro_schema

Get default Avro schema for StreamEvent

to_avro_value

Convert StreamEvent to Avro value