/
dev-npgsql
/
npgsql
Обзор
Документация
Войти
/
dev-npgsql
/
npgsql
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
test-logs
src/Npgsql/Replication/PgOutput/Messages/DefaultUpdateMessage.cs
37 строк
1 KB
Nino Floris
Handler rework (#5123)
26 сен 2023, 00:08
Не верифицирован
26 сен 2023, 00:08
0b7aecb
Код
Авторство
О чём код?
using System; using System.Threading; using System.Threading.Tasks; using Npgsql.Internal; using NpgsqlTypes; namespace Npgsql.Replication.PgOutput.Messages; /// <summary> /// Logical Replication Protocol update message for tables with REPLICA IDENTITY set to DEFAULT. /// </summary> public class DefaultUpdateMessage : UpdateMessage { readonly ReplicationTuple _newRow; /// <summary> /// Columns representing the new row. /// </summary> public override ReplicationTuple NewRow => _newRow; internal DefaultUpdateMessage(NpgsqlConnector connector) => _newRow = new(connector); internal UpdateMessage Populate( NpgsqlLogSequenceNumber walStart, NpgsqlLogSequenceNumber walEnd, DateTime serverClock, uint? transactionXid, RelationMessage relation, ushort numColumns) { base.Populate(walStart, walEnd, serverClock, transactionXid, relation); _newRow.Reset(numColumns, relation.RowDescription); return this; } internal Task Consume(CancellationToken cancellationToken) => _newRow.Consume(cancellationToken); }