dev-npgsql/npgsql: Npgsql is the .NET data provider for PostgreSQL.

src/Npgsql/Replication/ReplicationMessage.cs

33 строки1 KB

Brar Piening

Implement the PostgreSQL Streaming Replication Protocol

08 ноя 2020, 22:16

08 ноя 2020, 22:165a3b020

using NpgsqlTypes;
using System;

namespace Npgsql.Replication
{
    /// <summary>
    /// The common base class for all streaming replication messages
    /// </summary>
    public abstract class ReplicationMessage
    {
        /// <summary>
        /// The starting point of the WAL data in this message.
        /// </summary>
        public NpgsqlLogSequenceNumber WalStart { get; private set; }

        /// <summary>
        /// The current end of WAL on the server.
        /// </summary>
        public NpgsqlLogSequenceNumber WalEnd { get; private set; }

        /// <summary>
        /// The server's system clock at the time this message was transmitted, as microseconds since midnight on 2000-01-01.
        /// </summary>
        public DateTime ServerClock { get; private set; }

        private protected void Populate(NpgsqlLogSequenceNumber walStart, NpgsqlLogSequenceNumber walEnd, DateTime serverClock)
        {
            WalStart = walStart;
            WalEnd = walEnd;
            ServerClock = serverClock;
        }
    }
}