From 85a3bec41904d1fc8cb24c4b295ee56aeb10f212 Mon Sep 17 00:00:00 2001
From: Ruslan Ulianets <ruslan.ulianets@gmail.com>
Date: Wed, 18 Oct 2023 14:21:08 +0300
Subject: [PATCH] Make events as records

---
 src/MySqlCdc/BinlogReader.cs                  |  2 +-
 src/MySqlCdc/Events/DeleteRowsEvent.cs        | 37 ++++++---------
 src/MySqlCdc/Events/EventDeserializer.cs      |  2 +-
 src/MySqlCdc/Events/EventHeader.cs            | 36 ++++++++------
 src/MySqlCdc/Events/EventWithHeader.cs        | 12 +----
 src/MySqlCdc/Events/FormatDescriptionEvent.cs | 27 ++++-------
 src/MySqlCdc/Events/GtidEvent.cs              | 18 +++----
 src/MySqlCdc/Events/HeartbeatEvent.cs         | 15 ++----
 src/MySqlCdc/Events/IntVarEvent.cs            | 18 +++----
 src/MySqlCdc/Events/QueryEvent.cs             | 42 +++++++----------
 src/MySqlCdc/Events/RotateEvent.cs            | 18 +++----
 src/MySqlCdc/Events/RowData.cs                | 33 +++++--------
 src/MySqlCdc/Events/RowsQueryEvent.cs         | 15 ++----
 src/MySqlCdc/Events/TableMapEvent.cs          | 47 +++++++------------
 src/MySqlCdc/Events/UnknownEvent.cs           | 13 ++---
 src/MySqlCdc/Events/UpdateRowsEvent.cs        | 42 +++++++----------
 src/MySqlCdc/Events/UserVarEvent.cs           | 42 ++++++-----------
 src/MySqlCdc/Events/WriteRowsEvent.cs         | 37 ++++++---------
 src/MySqlCdc/Events/XidEvent.cs               | 15 ++----
 src/MySqlCdc/Metadata/DefaultCharset.cs       | 18 +++----
 .../Providers/MariaDb/Events/GtidListEvent.cs | 15 ++----
 src/MySqlCdc/Providers/MariaDb/Gtid/Gtid.cs   | 21 +++------
 .../MySql/Events/PreviousGtidsEvent.cs        | 15 ++----
 .../Providers/MySql/Events/XaPrepareEvent.cs  | 24 ++++------
 src/MySqlCdc/Providers/MySql/Gtid/Gtid.cs     | 18 +++----
 .../Parsers/UserVarEventParserTests.cs        |  2 +-
 .../MySql/PreviousGtidsEventParserTests.cs    |  2 +-
 .../MySql/XaPrepareEventParserTests.cs        |  2 +-
 28 files changed, 215 insertions(+), 373 deletions(-)

diff --git a/src/MySqlCdc/BinlogReader.cs b/src/MySqlCdc/BinlogReader.cs
index ed8a306..cf67441 100644
--- a/src/MySqlCdc/BinlogReader.cs
+++ b/src/MySqlCdc/BinlogReader.cs
@@ -77,7 +77,7 @@ private EventHeader GetEventHeader(ReadOnlySequence<byte> buffer)
     {
         using var memoryOwner = new MemoryOwner(buffer.Slice(0, EventConstants.HeaderSize));
         var reader = new PacketReader(memoryOwner.Memory.Span);
-        return new EventHeader(ref reader);
+        return EventHeader.Read(ref reader);
     }
 
     private HeaderWithEvent Deserialize(ReadOnlySequence<byte> packet)
diff --git a/src/MySqlCdc/Events/DeleteRowsEvent.cs b/src/MySqlCdc/Events/DeleteRowsEvent.cs
index 2b0dd9a..2e30ac8 100644
--- a/src/MySqlCdc/Events/DeleteRowsEvent.cs
+++ b/src/MySqlCdc/Events/DeleteRowsEvent.cs
@@ -4,47 +4,38 @@ namespace MySqlCdc.Events;
 /// Represents one or many deleted rows in row based replication.
 /// <a href="https://mariadb.com/kb/en/library/rows_event_v1/">See more</a>
 /// </summary>
-public class DeleteRowsEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="DeleteRowsEvent"/>.
+/// </remarks>
+public record DeleteRowsEvent(
+    long TableId,
+    int Flags,
+    int ColumnsNumber,
+    bool[] ColumnsPresent,
+    IReadOnlyList<RowData> Rows) : IBinlogEvent
 {
     /// <summary>
     /// Gets id of the table where rows were deleted
     /// </summary>
-    public long TableId { get; }
+    public long TableId { get; } = TableId;
 
     /// <summary>
     /// Gets <a href="https://mariadb.com/kb/en/rows_event_v1/#flags">flags</a>
     /// </summary>
-    public int Flags { get; }
+    public int Flags { get; } = Flags;
 
     /// <summary>
     /// Gets number of columns in the table
     /// </summary>
-    public int ColumnsNumber { get; }
+    public int ColumnsNumber { get; } = ColumnsNumber;
 
     /// <summary>
     /// Gets bitmap of columns present in row event. See binlog_row_image parameter.
     /// </summary>
-    public bool[] ColumnsPresent { get; }
+    public bool[] ColumnsPresent { get; } = ColumnsPresent;
 
     /// <summary>
     /// Gets deleted rows
     /// </summary>
-    public IReadOnlyList<RowData> Rows { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="DeleteRowsEvent"/>.
-    /// </summary>
-    public DeleteRowsEvent(
-        long tableId,
-        int flags,
-        int columnsNumber,
-        bool[] columnsPresent,
-        IReadOnlyList<RowData> rows)
-    {
-        TableId = tableId;
-        Flags = flags;
-        ColumnsNumber = columnsNumber;
-        ColumnsPresent = columnsPresent;
-        Rows = rows;
-    }
+    public IReadOnlyList<RowData> Rows { get; } = Rows;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/EventDeserializer.cs b/src/MySqlCdc/Events/EventDeserializer.cs
index 32e29fb..e136460 100644
--- a/src/MySqlCdc/Events/EventDeserializer.cs
+++ b/src/MySqlCdc/Events/EventDeserializer.cs
@@ -53,7 +53,7 @@ protected EventDeserializer()
 
     internal virtual HeaderWithEvent DeserializeEvent(ref PacketReader reader)
     {
-        var eventHeader = new EventHeader(ref reader);
+        var eventHeader = EventHeader.Read(ref reader);
 
         // Consider verifying checksum
         // ChecksumType.Verify(eventBuffer, checksumBuffer);
diff --git a/src/MySqlCdc/Events/EventHeader.cs b/src/MySqlCdc/Events/EventHeader.cs
index 39c0ecd..5e1c5eb 100644
--- a/src/MySqlCdc/Events/EventHeader.cs
+++ b/src/MySqlCdc/Events/EventHeader.cs
@@ -8,48 +8,56 @@ namespace MySqlCdc.Events;
 /// See <a href="https://mariadb.com/kb/en/library/2-binlog-event-header/">MariaDB docs</a>
 /// See <a href="https://dev.mysql.com/doc/internals/en/binlog-version.html">MySQL docs</a>
 /// </summary>
-public class EventHeader
+public record EventHeader(
+    long Timestamp,
+    EventType EventType,
+    long ServerId,
+    long EventLength,
+    long NextEventPosition,
+    int EventFlags)
 {
     /// <summary>
     /// Provides creation time in seconds from Unix.
     /// </summary>
-    public long Timestamp { get; }
+    public long Timestamp { get; } = Timestamp;
 
     /// <summary>
     /// Gets type of the binlog event.
     /// </summary>
-    public EventType EventType { get; }
+    public EventType EventType { get; } = EventType;
 
     /// <summary>
     /// Gets id of the server that created the event.
     /// </summary>
-    public long ServerId { get; }
+    public long ServerId { get; } = ServerId;
 
     /// <summary>
     /// Gets event length (header + event + checksum).
     /// </summary>
-    public long EventLength { get; }
+    public long EventLength { get; } = EventLength;
 
     /// <summary>
     /// Gets file position of next event.
     /// </summary>
-    public long NextEventPosition { get; }
+    public long NextEventPosition { get; } = NextEventPosition;
 
     /// <summary>
     /// Gets event flags. See <a href="https://mariadb.com/kb/en/2-binlog-event-header/#event-flag">documentation</a>.
     /// </summary>
-    public int EventFlags { get; }
+    public int EventFlags { get; } = EventFlags;
 
     /// <summary>
     /// Creates a new <see cref="EventHeader"/>.
     /// </summary>
-    public EventHeader(ref PacketReader reader)
+    public static EventHeader Read(ref PacketReader reader)
     {
-        Timestamp = reader.ReadUInt32LittleEndian();
-        EventType = (EventType)reader.ReadByte();
-        ServerId = reader.ReadUInt32LittleEndian();
-        EventLength = reader.ReadUInt32LittleEndian();
-        NextEventPosition = reader.ReadUInt32LittleEndian();
-        EventFlags = reader.ReadUInt16LittleEndian();
+        return new EventHeader(
+            reader.ReadUInt32LittleEndian(),
+            (EventType)reader.ReadByte(),
+            reader.ReadUInt32LittleEndian(),
+            reader.ReadUInt32LittleEndian(),
+            reader.ReadUInt32LittleEndian(),
+            reader.ReadUInt16LittleEndian()
+        );
     }
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/EventWithHeader.cs b/src/MySqlCdc/Events/EventWithHeader.cs
index cf4564e..b712438 100644
--- a/src/MySqlCdc/Events/EventWithHeader.cs
+++ b/src/MySqlCdc/Events/EventWithHeader.cs
@@ -2,14 +2,4 @@
 
 namespace MySqlCdc.Events;
 
-internal class HeaderWithEvent : IPacket
-{
-    public EventHeader Header { get; }
-    public IBinlogEvent Event { get; }
-
-    public HeaderWithEvent(EventHeader header, IBinlogEvent @event)
-    {
-        Header = header;
-        Event = @event;
-    }
-}
\ No newline at end of file
+internal record HeaderWithEvent(EventHeader Header, IBinlogEvent Event) : IPacket;
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/FormatDescriptionEvent.cs b/src/MySqlCdc/Events/FormatDescriptionEvent.cs
index 8f1ec74..31bff79 100644
--- a/src/MySqlCdc/Events/FormatDescriptionEvent.cs
+++ b/src/MySqlCdc/Events/FormatDescriptionEvent.cs
@@ -8,33 +8,26 @@ namespace MySqlCdc.Events;
 /// See <a href="https://dev.mysql.com/doc/internals/en/format-description-event.html">MySQL docs</a>
 /// See <a href="https://mariadb.com/kb/en/library/5-slave-registration/#events-transmission-after-com_binlog_dump">start events flow</a>
 /// </summary>
-public class FormatDescriptionEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="FormatDescriptionEvent"/>.
+/// </remarks>
+public record FormatDescriptionEvent(
+    int BinlogVersion,
+    string ServerVersion,
+    ChecksumType ChecksumType) : IBinlogEvent
 {
     /// <summary>
     /// Gets binary log format version. This should always be 4.
     /// </summary>
-    public int BinlogVersion { get; }
+    public int BinlogVersion { get; } = BinlogVersion;
 
     /// <summary>
     /// Gets MariaDB/MySQL server version name.
     /// </summary>
-    public string ServerVersion { get; }
+    public string ServerVersion { get; } = ServerVersion;
 
     /// <summary>
     /// Gets checksum algorithm type.
     /// </summary>
-    public ChecksumType ChecksumType { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="FormatDescriptionEvent"/>.
-    /// </summary>
-    public FormatDescriptionEvent(
-        int binlogVersion,
-        string serverVersion,
-        ChecksumType checksumType)
-    {
-        BinlogVersion = binlogVersion;
-        ServerVersion = serverVersion;
-        ChecksumType = checksumType;
-    }
+    public ChecksumType ChecksumType { get; } = ChecksumType;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/GtidEvent.cs b/src/MySqlCdc/Events/GtidEvent.cs
index f84dc7c..1310f34 100644
--- a/src/MySqlCdc/Events/GtidEvent.cs
+++ b/src/MySqlCdc/Events/GtidEvent.cs
@@ -20,24 +20,18 @@ public interface IGtidState
 /// Marks start of a new event group(transaction).
 /// <a href="https://mariadb.com/kb/en/gtid_event/">See more</a>
 /// </summary>
-public class GtidEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="GtidEvent"/>.
+/// </remarks>
+public record GtidEvent(IGtid Gtid, byte Flags) : IBinlogEvent
 {
     /// <summary>
     /// Gets Global Transaction ID of the event group.
     /// </summary>
-    public IGtid Gtid { get; }
+    public IGtid Gtid { get; } = Gtid;
 
     /// <summary>
     /// Gets flags.
     /// </summary>
-    public byte Flags { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="GtidEvent"/>.
-    /// </summary>
-    public GtidEvent(IGtid gtid, byte flags)
-    {
-        Gtid = gtid;
-        Flags = flags;
-    }
+    public byte Flags { get; } = Flags;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/HeartbeatEvent.cs b/src/MySqlCdc/Events/HeartbeatEvent.cs
index 8df3a98..2a50eb5 100644
--- a/src/MySqlCdc/Events/HeartbeatEvent.cs
+++ b/src/MySqlCdc/Events/HeartbeatEvent.cs
@@ -4,18 +4,13 @@ namespace MySqlCdc.Events;
 /// The event is sent from master to the client for keep alive feature.
 /// <a href="https://mariadb.com/kb/en/library/heartbeat_log_event/">See more</a>
 /// </summary>
-public class HeartbeatEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="HeartbeatEvent"/>.
+/// </remarks>
+public record HeartbeatEvent(string BinlogFilename) : IBinlogEvent
 {
     /// <summary>
     /// Gets current master binlog filename
     /// </summary>
-    public string BinlogFilename { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="HeartbeatEvent"/>.
-    /// </summary>
-    public HeartbeatEvent(string binlogFilename)
-    {
-        BinlogFilename = binlogFilename;
-    }
+    public string BinlogFilename { get; } = BinlogFilename;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/IntVarEvent.cs b/src/MySqlCdc/Events/IntVarEvent.cs
index fafe442..e7067b5 100644
--- a/src/MySqlCdc/Events/IntVarEvent.cs
+++ b/src/MySqlCdc/Events/IntVarEvent.cs
@@ -4,7 +4,10 @@ namespace MySqlCdc.Events;
 /// Generated when an auto increment column or LAST_INSERT_ID() function are used.
 /// <a href="https://mariadb.com/kb/en/library/intvar_event/">See more</a>
 /// </summary>
-public class IntVarEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="IntVarEvent"/>.
+/// </remarks>
+public record IntVarEvent(byte Type, long Value) : IBinlogEvent
 {
     /// <summary>
     /// Gets type.
@@ -12,19 +15,10 @@ public class IntVarEvent : IBinlogEvent
     /// 0x01 - LAST_INSERT_ID.
     /// 0x02 - Insert id (auto_increment).
     /// </summary>
-    public byte Type { get; }
+    public byte Type { get; } = Type;
 
     /// <summary>
     /// Gets value.
     /// </summary>
-    public long Value { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="IntVarEvent"/>.
-    /// </summary>
-    public IntVarEvent(byte type, long value)
-    {
-        Type = type;
-        Value = value;
-    }
+    public long Value { get; } = Value;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/QueryEvent.cs b/src/MySqlCdc/Events/QueryEvent.cs
index 2525dd5..9b5c592 100644
--- a/src/MySqlCdc/Events/QueryEvent.cs
+++ b/src/MySqlCdc/Events/QueryEvent.cs
@@ -4,54 +4,44 @@ namespace MySqlCdc.Events;
 /// Represents sql statement in binary log.
 /// <a href="https://mariadb.com/kb/en/library/query_event/">See more</a>
 /// </summary>
-public class QueryEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="QueryEvent"/>.
+/// </remarks>
+public record QueryEvent(
+    long ThreadId,
+    long Duration,
+    int ErrorCode,
+    byte[] StatusVariables,
+    string DatabaseName,
+    string SqlStatement) : IBinlogEvent
 {
     /// <summary>
     /// Gets id of the thread that issued the statement.
     /// </summary>
-    public long ThreadId { get; }
+    public long ThreadId { get; } = ThreadId;
 
     /// <summary>
     /// Gets the execution time of the statement in seconds.
     /// </summary>
-    public long Duration { get; }
+    public long Duration { get; } = Duration;
 
     /// <summary>
     /// Gets the error code of the executed statement.
     /// </summary>
-    public int ErrorCode { get; }
+    public int ErrorCode { get; } = ErrorCode;
 
     /// <summary>
     /// Gets status variables.
     /// </summary>
-    public byte[] StatusVariables { get; }
+    public byte[] StatusVariables { get; } = StatusVariables;
 
     /// <summary>
     /// Gets the default database name.
     /// </summary>
-    public string DatabaseName { get; }
+    public string DatabaseName { get; } = DatabaseName;
 
     /// <summary>
     /// Gets the SQL statement.
     /// </summary>
-    public string SqlStatement { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="QueryEvent"/>.
-    /// </summary>
-    public QueryEvent(
-        long threadId,
-        long duration,
-        int errorCode,
-        byte[] statusVariables,
-        string databaseName,
-        string sqlStatement)
-    {
-        ThreadId = threadId;
-        Duration = duration;
-        ErrorCode = errorCode;
-        StatusVariables = statusVariables;
-        DatabaseName = databaseName;
-        SqlStatement = sqlStatement;
-    }
+    public string SqlStatement { get; } = SqlStatement;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/RotateEvent.cs b/src/MySqlCdc/Events/RotateEvent.cs
index 6aa1ca8..77fe999 100644
--- a/src/MySqlCdc/Events/RotateEvent.cs
+++ b/src/MySqlCdc/Events/RotateEvent.cs
@@ -5,24 +5,18 @@ namespace MySqlCdc.Events;
 /// Fake version is also returned when replication is started.
 /// <a href="https://mariadb.com/kb/en/library/rotate_event/">See more</a>
 /// </summary>
-public class RotateEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="RotateEvent"/>.
+/// </remarks>
+public record RotateEvent(string BinlogFilename, long BinlogPosition) : IBinlogEvent
 {
     /// <summary>
     /// Gets next binlog filename
     /// </summary>
-    public string BinlogFilename { get; }
+    public string BinlogFilename { get; } = BinlogFilename;
 
     /// <summary>
     /// Gets next binlog position
     /// </summary>
-    public long BinlogPosition { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="RotateEvent"/>.
-    /// </summary>
-    public RotateEvent(string binlogFilename, long binlogPosition)
-    {
-        BinlogFilename = binlogFilename;
-        BinlogPosition = binlogPosition;
-    }
+    public long BinlogPosition { get; } = BinlogPosition;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/RowData.cs b/src/MySqlCdc/Events/RowData.cs
index 12a64f1..19380a5 100644
--- a/src/MySqlCdc/Events/RowData.cs
+++ b/src/MySqlCdc/Events/RowData.cs
@@ -3,43 +3,32 @@ namespace MySqlCdc.Events;
 /// <summary>
 /// Represents an inserted or deleted row in row based replication.
 /// </summary>
-public class RowData
+/// <remarks>
+/// Creates a new <see cref="RowData"/>.
+/// </remarks>
+public record RowData(IReadOnlyList<object?> Cells)
 {
     /// <summary>
     /// Column values of the changed row.
     /// </summary>
-    public IReadOnlyList<object?> Cells { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="RowData"/>.
-    /// </summary>
-    public RowData(IReadOnlyList<object?> cells)
-    {
-        Cells = cells;
-    }
+    public IReadOnlyList<object?> Cells { get; } = Cells;
 }
 
 /// <summary>
 /// Represents an updated row in row based replication.
 /// </summary>
-public class UpdateRowData
+/// <remarks>
+/// Creates a new <see cref="UpdateRowData"/>.
+/// </remarks>
+public record UpdateRowData(RowData BeforeUpdate, RowData AfterUpdate)
 {
     /// <summary>
     /// Row state before it was updated.
     /// </summary>
-    public RowData BeforeUpdate { get; }
+    public RowData BeforeUpdate { get; } = BeforeUpdate;
 
     /// <summary>
     /// Actual row state after update.
     /// </summary>
-    public RowData AfterUpdate { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="UpdateRowData"/>.
-    /// </summary>
-    public UpdateRowData(RowData beforeUpdate, RowData afterUpdate)
-    {
-        BeforeUpdate = beforeUpdate;
-        AfterUpdate = afterUpdate;
-    }
+    public RowData AfterUpdate { get; } = AfterUpdate;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/RowsQueryEvent.cs b/src/MySqlCdc/Events/RowsQueryEvent.cs
index 771fde8..9c084cf 100644
--- a/src/MySqlCdc/Events/RowsQueryEvent.cs
+++ b/src/MySqlCdc/Events/RowsQueryEvent.cs
@@ -5,18 +5,13 @@ namespace MySqlCdc.Events;
 /// See <a href="https://dev.mysql.com/doc/internals/en/rows-query-event.html">MySQL docs</a>
 /// See <a href="https://mariadb.com/kb/en/annotate_rows_event/">MariaDB docs</a>
 /// </summary>
-public class RowsQueryEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="RowsQueryEvent"/>.
+/// </remarks>
+public record RowsQueryEvent(string Query) : IBinlogEvent
 {
     /// <summary>
     /// Gets SQL statement
     /// </summary>
-    public string Query { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="RowsQueryEvent"/>.
-    /// </summary>
-    public RowsQueryEvent(string query)
-    {
-        Query = query;
-    }
+    public string Query { get; } = Query;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/TableMapEvent.cs b/src/MySqlCdc/Events/TableMapEvent.cs
index 6fd5250..ca55cfa 100644
--- a/src/MySqlCdc/Events/TableMapEvent.cs
+++ b/src/MySqlCdc/Events/TableMapEvent.cs
@@ -6,61 +6,50 @@ namespace MySqlCdc.Events;
 /// The event has table defition for row events.
 /// <a href="https://mariadb.com/kb/en/library/table_map_event/">See more</a>
 /// </summary>
-public class TableMapEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="TableMapEvent"/>.
+/// </remarks>
+public record TableMapEvent(
+    long TableId,
+    string DatabaseName,
+    string TableName,
+    byte[] ColumnTypes,
+    int[] ColumnMetadata,
+    bool[] NullBitmap,
+    TableMetadata? TableMetadata) : IBinlogEvent
 {
     /// <summary>
     /// Gets id of the changed table
     /// </summary>
-    public long TableId { get; }
+    public long TableId { get; } = TableId;
 
     /// <summary>
     /// Gets database name of the changed table
     /// </summary>
-    public string DatabaseName { get; }
+    public string DatabaseName { get; } = DatabaseName;
 
     /// <summary>
     /// Gets name of the changed table
     /// </summary>
-    public string TableName { get; }
+    public string TableName { get; } = TableName;
 
     /// <summary>
     /// Gets column types of the changed table
     /// </summary>
-    public byte[] ColumnTypes { get; }
+    public byte[] ColumnTypes { get; } = ColumnTypes;
 
     /// <summary>
     /// Gets columns metadata
     /// </summary>
-    public int[] ColumnMetadata { get; }
+    public int[] ColumnMetadata { get; } = ColumnMetadata;
 
     /// <summary>
     /// Gets columns nullability
     /// </summary>
-    public bool[] NullBitmap { get; }
+    public bool[] NullBitmap { get; } = NullBitmap;
 
     /// <summary>
     /// Gets table metadata for MySQL 8.0.1+
     /// </summary>
-    public TableMetadata? TableMetadata { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="TableMapEvent"/>.
-    /// </summary>
-    public TableMapEvent(
-        long tableId,
-        string databaseName,
-        string tableName,
-        byte[] columnTypes,
-        int[] columnMetadata,
-        bool[] nullBitmap,
-        TableMetadata? tableMetadata)
-    {
-        TableId = tableId;
-        DatabaseName = databaseName;
-        TableName = tableName;
-        ColumnTypes = columnTypes;
-        ColumnMetadata = columnMetadata;
-        NullBitmap = nullBitmap;
-        TableMetadata = tableMetadata;
-    }
+    public TableMetadata? TableMetadata { get; } = TableMetadata;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/UnknownEvent.cs b/src/MySqlCdc/Events/UnknownEvent.cs
index 5555314..ee0643b 100644
--- a/src/MySqlCdc/Events/UnknownEvent.cs
+++ b/src/MySqlCdc/Events/UnknownEvent.cs
@@ -3,12 +3,7 @@ namespace MySqlCdc.Events;
 /// <summary>
 /// Represents other binlog events.
 /// </summary>
-public class UnknownEvent : IBinlogEvent
-{
-    /// <summary>
-    /// Creates a new <see cref="UnknownEvent"/>.
-    /// </summary>
-    public UnknownEvent()
-    {
-    }
-}
\ No newline at end of file
+/// <remarks>
+/// Creates a new <see cref="UnknownEvent"/>.
+/// </remarks>
+public record UnknownEvent : IBinlogEvent;
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/UpdateRowsEvent.cs b/src/MySqlCdc/Events/UpdateRowsEvent.cs
index 71f4cdc..1192044 100644
--- a/src/MySqlCdc/Events/UpdateRowsEvent.cs
+++ b/src/MySqlCdc/Events/UpdateRowsEvent.cs
@@ -5,54 +5,44 @@ namespace MySqlCdc.Events;
 /// Includes versions before and after update.
 /// <a href="https://mariadb.com/kb/en/library/rows_event_v1/">See more</a>
 /// </summary>
-public class UpdateRowsEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="UpdateRowsEvent"/>.
+/// </remarks>
+public record UpdateRowsEvent(
+    long TableId,
+    int Flags,
+    int ColumnsNumber,
+    bool[] ColumnsPresentBeforeUpdate,
+    bool[] ColumnsPresentAfterUpdate,
+    IReadOnlyList<UpdateRowData> Rows) : IBinlogEvent
 {
     /// <summary>
     /// Gets id of the table where rows were updated
     /// </summary>
-    public long TableId { get; }
+    public long TableId { get; } = TableId;
 
     /// <summary>
     /// Gets <a href="https://mariadb.com/kb/en/rows_event_v1/#flags">flags</a>
     /// </summary>
-    public int Flags { get; }
+    public int Flags { get; } = Flags;
 
     /// <summary>
     /// Gets number of columns in the table
     /// </summary>
-    public int ColumnsNumber { get; }
+    public int ColumnsNumber { get; } = ColumnsNumber;
 
     /// <summary>
     /// Gets bitmap of columns present in row event before update. See binlog_row_image parameter.
     /// </summary>
-    public bool[] ColumnsPresentBeforeUpdate { get; }
+    public bool[] ColumnsPresentBeforeUpdate { get; } = ColumnsPresentBeforeUpdate;
 
     /// <summary>
     /// Gets bitmap of columns present in row event after update. See binlog_row_image parameter.
     /// </summary>
-    public bool[] ColumnsPresentAfterUpdate { get; }
+    public bool[] ColumnsPresentAfterUpdate { get; } = ColumnsPresentAfterUpdate;
 
     /// <summary>
     /// Gets updated rows
     /// </summary>
-    public IReadOnlyList<UpdateRowData> Rows { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="UpdateRowsEvent"/>.
-    /// </summary>
-    public UpdateRowsEvent(
-        long tableId,
-        int flags,
-        int columnsNumber,
-        bool[] columnsPresentBeforeUpdate,
-        bool[] columnsPresentAfterUpdate,
-        IReadOnlyList<UpdateRowData> rows)
-    {
-        TableId = tableId;
-        Flags = flags;
-        ColumnsNumber = columnsNumber;
-        ColumnsPresentBeforeUpdate = columnsPresentBeforeUpdate;
-        ColumnsPresentAfterUpdate = columnsPresentAfterUpdate;
-        Rows = rows;
-    }
+    public IReadOnlyList<UpdateRowData> Rows { get; } = Rows;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/UserVarEvent.cs b/src/MySqlCdc/Events/UserVarEvent.cs
index 6ef67a6..c772791 100644
--- a/src/MySqlCdc/Events/UserVarEvent.cs
+++ b/src/MySqlCdc/Events/UserVarEvent.cs
@@ -4,61 +4,47 @@ namespace MySqlCdc.Events;
 /// A USER_VAR_EVENT is written every time a statement uses a user defined variable.
 /// <a href="https://mariadb.com/kb/en/user_var_event/">See more</a>
 /// </summary>
-public class UserVarEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="UserVarEvent"/>.
+/// </remarks>
+public record UserVarEvent(string Name, VariableValue? Value) : IBinlogEvent
 {
     /// <summary>
     /// User variable name
     /// </summary>
-    public string Name { get; }
+    public string Name { get; } = Name;
 
     /// <summary>
     /// User variable value
     /// </summary>
-    public VariableValue? Value { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="UserVarEvent"/>.
-    /// </summary>
-    public UserVarEvent(string name, VariableValue? value)
-    {
-        Name = name;
-        Value = value;
-    }
+    public VariableValue? Value { get; } = Value;
 }
 
 /// <summary>
 /// User variable value
 /// </summary>
-public class VariableValue
+/// <remarks>
+/// Creates a new <see cref="VariableValue"/>.
+/// </remarks>
+public record VariableValue(byte VariableType, int CollationNumber, string Value, byte Flags)
 {
     /// <summary>
     /// Variable type
     /// </summary>
-    public byte VariableType { get; }
+    public byte VariableType { get; } = VariableType;
 
     /// <summary>
     /// Collation number
     /// </summary>
-    public int CollationNumber { get; }
+    public int CollationNumber { get; } = CollationNumber;
 
     /// <summary>
     /// User variable value
     /// </summary>
-    public string Value { get; }
+    public string Value { get; } = Value;
 
     /// <summary>
     /// flags
     /// </summary>
-    public byte Flags { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="VariableValue"/>.
-    /// </summary>
-    public VariableValue(byte variableType, int collationNumber, string value, byte flags)
-    {
-        VariableType = variableType;
-        CollationNumber = collationNumber;
-        Value = value;
-        Flags = flags;
-    }
+    public byte Flags { get; } = Flags;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/WriteRowsEvent.cs b/src/MySqlCdc/Events/WriteRowsEvent.cs
index 3d7e78c..36ebd4d 100644
--- a/src/MySqlCdc/Events/WriteRowsEvent.cs
+++ b/src/MySqlCdc/Events/WriteRowsEvent.cs
@@ -4,47 +4,38 @@ namespace MySqlCdc.Events;
 /// Represents one or many inserted rows in row based replication.
 /// <a href="https://mariadb.com/kb/en/library/rows_event_v1/">See more</a>
 /// </summary>
-public class WriteRowsEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="WriteRowsEvent"/>.
+/// </remarks>
+public record WriteRowsEvent(
+    long TableId,
+    int Flags,
+    int ColumnsNumber,
+    bool[] ColumnsPresent,
+    IReadOnlyList<RowData> Rows) : IBinlogEvent
 {
     /// <summary>
     /// Gets id of the table where rows were inserted
     /// </summary>
-    public long TableId { get; }
+    public long TableId { get; } = TableId;
 
     /// <summary>
     /// Gets <a href="https://mariadb.com/kb/en/rows_event_v1/#flags">flags</a>
     /// </summary>
-    public int Flags { get; }
+    public int Flags { get; } = Flags;
 
     /// <summary>
     /// Gets number of columns in the table
     /// </summary>
-    public int ColumnsNumber { get; }
+    public int ColumnsNumber { get; } = ColumnsNumber;
 
     /// <summary>
     /// Gets bitmap of columns present in row event. See binlog_row_image parameter.
     /// </summary>
-    public bool[] ColumnsPresent { get; }
+    public bool[] ColumnsPresent { get; } = ColumnsPresent;
 
     /// <summary>
     /// Gets inserted rows
     /// </summary>
-    public IReadOnlyList<RowData> Rows { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="WriteRowsEvent"/>.
-    /// </summary>
-    public WriteRowsEvent(
-        long tableId,
-        int flags,
-        int columnsNumber,
-        bool[] columnsPresent,
-        IReadOnlyList<RowData> rows)
-    {
-        TableId = tableId;
-        Flags = flags;
-        ColumnsNumber = columnsNumber;
-        ColumnsPresent = columnsPresent;
-        Rows = rows;
-    }
+    public IReadOnlyList<RowData> Rows { get; } = Rows;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Events/XidEvent.cs b/src/MySqlCdc/Events/XidEvent.cs
index 28842c6..8136647 100644
--- a/src/MySqlCdc/Events/XidEvent.cs
+++ b/src/MySqlCdc/Events/XidEvent.cs
@@ -4,18 +4,13 @@ namespace MySqlCdc.Events;
 /// Represents a transaction commit event.
 /// <a href="https://mariadb.com/kb/en/library/xid_event/">See more</a>
 /// </summary>
-public class XidEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="XidEvent"/>.
+/// </remarks>
+public record XidEvent(long Xid) : IBinlogEvent
 {
     /// <summary>
     /// Gets the XID transaction number
     /// </summary>
-    public long Xid { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="XidEvent"/>.
-    /// </summary>
-    public XidEvent(long xid)
-    {
-        Xid = xid;
-    }
+    public long Xid { get; } = Xid;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Metadata/DefaultCharset.cs b/src/MySqlCdc/Metadata/DefaultCharset.cs
index 2eeb454..0d33774 100644
--- a/src/MySqlCdc/Metadata/DefaultCharset.cs
+++ b/src/MySqlCdc/Metadata/DefaultCharset.cs
@@ -3,24 +3,18 @@ namespace MySqlCdc.Metadata;
 /// <summary>
 /// Represents charsets of character columns.
 /// </summary>
-public class DefaultCharset
+/// <remarks>
+/// Creates a new <see cref="DefaultCharset"/>.
+/// </remarks>
+public record DefaultCharset(int DefaultCharsetCollation, IReadOnlyDictionary<int, int> CharsetCollations)
 {
     /// <summary>
     /// Gets the most used charset collation.
     /// </summary>
-    public int DefaultCharsetCollation { get; }
+    public int DefaultCharsetCollation { get; } = DefaultCharsetCollation;
 
     /// <summary>
     /// Gets ColumnIndex-Charset map for columns that don't use the default charset.
     /// </summary>
-    public IReadOnlyDictionary<int, int> CharsetCollations { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="DefaultCharset"/>.
-    /// </summary>
-    public DefaultCharset(int defaultCharsetCollation, IReadOnlyDictionary<int, int> charsetCollations)
-    {
-        DefaultCharsetCollation = defaultCharsetCollation;
-        CharsetCollations = charsetCollations;
-    }
+    public IReadOnlyDictionary<int, int> CharsetCollations { get; } = CharsetCollations;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Providers/MariaDb/Events/GtidListEvent.cs b/src/MySqlCdc/Providers/MariaDb/Events/GtidListEvent.cs
index b0c04cb..79d7286 100644
--- a/src/MySqlCdc/Providers/MariaDb/Events/GtidListEvent.cs
+++ b/src/MySqlCdc/Providers/MariaDb/Events/GtidListEvent.cs
@@ -6,18 +6,13 @@ namespace MySqlCdc.Events;
 /// Shows current replication state with list of last gtid for each replication domain.
 /// <a href="https://mariadb.com/kb/en/gtid_list_event/">See more</a>
 /// </summary>
-public class GtidListEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="GtidListEvent"/>.
+/// </remarks>
+public record GtidListEvent(GtidList GtidList) : IBinlogEvent
 {
     /// <summary>
     /// Gets a list of Gtid that represents current replication state
     /// </summary>
-    public GtidList GtidList { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="GtidListEvent"/>.
-    /// </summary>
-    public GtidListEvent(GtidList gtidList)
-    {
-        GtidList = gtidList;
-    }
+    public GtidList GtidList { get; } = GtidList;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Providers/MariaDb/Gtid/Gtid.cs b/src/MySqlCdc/Providers/MariaDb/Gtid/Gtid.cs
index 36192f3..79955a6 100644
--- a/src/MySqlCdc/Providers/MariaDb/Gtid/Gtid.cs
+++ b/src/MySqlCdc/Providers/MariaDb/Gtid/Gtid.cs
@@ -5,32 +5,25 @@ namespace MySqlCdc.Providers.MariaDb;
 /// <summary>
 /// MariaDB 10.0.2+ representation of Gtid.
 /// </summary>
-public class Gtid : IGtid
+/// <remarks>
+/// Creates a new <see cref="Gtid"/>.
+/// </remarks>
+public record Gtid(long DomainId, long ServerId, long Sequence) : IGtid
 {
     /// <summary>
     /// Gets domain identifier in multi-master setup.
     /// </summary>
-    public long DomainId { get; }
+    public long DomainId { get; } = DomainId;
 
     /// <summary>
     /// Gets identifier of the server that generated the event.
     /// </summary>
-    public long ServerId { get; }
+    public long ServerId { get; } = ServerId;
 
     /// <summary>
     /// Gets sequence number of the event on the original server.
     /// </summary>
-    public long Sequence { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="Gtid"/>.
-    /// </summary>
-    public Gtid(long domainId, long serverId, long sequence)
-    {
-        DomainId = domainId;
-        ServerId = serverId;
-        Sequence = sequence;
-    }
+    public long Sequence { get; } = Sequence;
 
     /// <summary>
     /// Returns string representation of Gtid in MariaDB.
diff --git a/src/MySqlCdc/Providers/MySql/Events/PreviousGtidsEvent.cs b/src/MySqlCdc/Providers/MySql/Events/PreviousGtidsEvent.cs
index 8c6e5b6..33fa6be 100644
--- a/src/MySqlCdc/Providers/MySql/Events/PreviousGtidsEvent.cs
+++ b/src/MySqlCdc/Providers/MySql/Events/PreviousGtidsEvent.cs
@@ -5,18 +5,13 @@ namespace MySqlCdc.Events;
 /// <summary>
 /// Used to record the gtid_executed of previous binlog files.
 /// </summary>
-public class PreviousGtidsEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="PreviousGtidsEvent"/>.
+/// </remarks>
+public record PreviousGtidsEvent(GtidSet GtidSet) : IBinlogEvent
 {
     /// <summary>
     /// Gets GtidSet of previous files.
     /// </summary>
-    public GtidSet GtidSet { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="PreviousGtidsEvent"/>.
-    /// </summary>
-    public PreviousGtidsEvent(GtidSet gtidSet)
-    {
-        GtidSet = gtidSet;
-    }
+    public GtidSet GtidSet { get; } = GtidSet;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Providers/MySql/Events/XaPrepareEvent.cs b/src/MySqlCdc/Providers/MySql/Events/XaPrepareEvent.cs
index c5b6305..9bf5d42 100644
--- a/src/MySqlCdc/Providers/MySql/Events/XaPrepareEvent.cs
+++ b/src/MySqlCdc/Providers/MySql/Events/XaPrepareEvent.cs
@@ -3,36 +3,28 @@ namespace MySqlCdc.Events;
 /// <summary>
 /// Represents the commit event of a prepared XA transaction.
 /// </summary>
-public class XaPrepareEvent : IBinlogEvent
+/// <remarks>
+/// Creates a new <see cref="XaPrepareEvent"/>.
+/// </remarks>
+public record XaPrepareEvent(bool OnePhase, int FormatId, string Gtrid, string Bqual) : IBinlogEvent
 {
     /// <summary>
     /// XA transaction commit type. False => XA PREPARE. True => XA COMMIT ... ONE PHASE
     /// </summary>
-    public bool OnePhase { get; }
+    public bool OnePhase { get; } = OnePhase;
 
     /// <summary>
     /// The formatID part of the transaction xid.
     /// </summary>
-    public int FormatId { get; }
+    public int FormatId { get; } = FormatId;
 
     /// <summary>
     /// A global transaction identifier.
     /// </summary>  
-    public string Gtrid { get; }
+    public string Gtrid { get; } = Gtrid;
 
     /// <summary>
     /// A branch qualifier.
     /// </summary>  
-    public string Bqual { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="XaPrepareEvent"/>.
-    /// </summary>
-    public XaPrepareEvent(bool onePhase, int formatId, string gtrid, string bqual)
-    {
-        OnePhase = onePhase;
-        FormatId = formatId;
-        Gtrid = gtrid;
-        Bqual = bqual;
-    }
+    public string Bqual { get; } = Bqual;
 }
\ No newline at end of file
diff --git a/src/MySqlCdc/Providers/MySql/Gtid/Gtid.cs b/src/MySqlCdc/Providers/MySql/Gtid/Gtid.cs
index cb2205c..1851609 100644
--- a/src/MySqlCdc/Providers/MySql/Gtid/Gtid.cs
+++ b/src/MySqlCdc/Providers/MySql/Gtid/Gtid.cs
@@ -5,26 +5,20 @@ namespace MySqlCdc.Providers.MySql;
 /// <summary>
 /// MySQL 5.6+ representation of Gtid.
 /// </summary>
-public class Gtid : IGtid
+/// <remarks>
+/// Creates a new <see cref="Gtid"/>.
+/// </remarks>
+public record Gtid(Uuid SourceId, long TransactionId) : IGtid
 {
     /// <summary>
     /// Gets identifier of the original server that generated the event.
     /// </summary>
-    public Uuid SourceId { get; }
+    public Uuid SourceId { get; } = SourceId;
 
     /// <summary>
     /// Gets sequence number of the event on the original server.
     /// </summary>
-    public long TransactionId { get; }
-
-    /// <summary>
-    /// Creates a new <see cref="Gtid"/>.
-    /// </summary>
-    public Gtid(Uuid sourceId, long transactionId)
-    {
-        SourceId = sourceId;
-        TransactionId = transactionId;
-    }
+    public long TransactionId { get; } = TransactionId;
 
     /// <summary>
     /// Returns string representation of Gtid in MySQL Server.
diff --git a/tests/MySqlCdc.Tests/Parsers/UserVarEventParserTests.cs b/tests/MySqlCdc.Tests/Parsers/UserVarEventParserTests.cs
index c0ceb83..2fe8b5b 100644
--- a/tests/MySqlCdc.Tests/Parsers/UserVarEventParserTests.cs
+++ b/tests/MySqlCdc.Tests/Parsers/UserVarEventParserTests.cs
@@ -17,7 +17,7 @@ public class UserVarEventParserTests
     public void Test_UserVarEvent_ReturnsEvent()
     {
         var reader = new PacketReader(Payload);
-        var eventHeader = new EventHeader(ref reader);
+        var eventHeader = EventHeader.Read(ref reader);
 
         var parser = new UserVarEventParser();
         var @event = (UserVarEvent)parser.ParseEvent(eventHeader, ref reader);
diff --git a/tests/MySqlCdc.Tests/Providers/MySql/PreviousGtidsEventParserTests.cs b/tests/MySqlCdc.Tests/Providers/MySql/PreviousGtidsEventParserTests.cs
index 076480d..3d88572 100644
--- a/tests/MySqlCdc.Tests/Providers/MySql/PreviousGtidsEventParserTests.cs
+++ b/tests/MySqlCdc.Tests/Providers/MySql/PreviousGtidsEventParserTests.cs
@@ -31,6 +31,6 @@ public void Test_ParsePreviousGtidsEvent_ReturnsGtidSet()
     private EventHeader CreateEventHeader()
     {
         var reader = new PacketReader(Payload);
-        return new EventHeader(ref reader);
+        return EventHeader.Read(ref reader);
     }
 }
\ No newline at end of file
diff --git a/tests/MySqlCdc.Tests/Providers/MySql/XaPrepareEventParserTests.cs b/tests/MySqlCdc.Tests/Providers/MySql/XaPrepareEventParserTests.cs
index 5712ea9..eeb366a 100644
--- a/tests/MySqlCdc.Tests/Providers/MySql/XaPrepareEventParserTests.cs
+++ b/tests/MySqlCdc.Tests/Providers/MySql/XaPrepareEventParserTests.cs
@@ -27,6 +27,6 @@ public void Test_ParseXaPrepareEvent_ReturnsEvent()
     private EventHeader CreateEventHeader()
     {
         var reader = new PacketReader(Payload);
-        return new EventHeader(ref reader);
+        return EventHeader.Read(ref reader);
     }
 }
\ No newline at end of file