IStreamWrapper

ObjectState

public ObjectStates ObjectState { get; }

value = iStreamWrapper.ObjectState

Cостояние объекта.

Close

public void Close()

iStreamWrapper.Close()

Закрытие потока.

Open

public void Open(IEnumerable<PlazaTable> tables)

iStreamWrapper.Open(tables)

Открытие потока репликационных данных.

DataBegin

public event Action DataBegin

iStreamWrapper.DataBegin += handler

Нотификация начала транзакции по обработке пакета данных от сервера репликации.

DataCleared

public event Action<PlazaTable, long> DataCleared

iStreamWrapper.DataCleared += handler

Нотификация об удалении всех записей из БД с ревижином меньше минимального серверного.

DataEnd

public event Action DataEnd

iStreamWrapper.DataEnd += handler

Нотификация окончания транзакции по обработке пакета данных от сервера репликации.

DataInserted

public event Action<PlazaTable, IPlazaRecord> DataInserted

iStreamWrapper.DataInserted += handler

Нотификация о вставке записи в БД.

LifeNumChanged

public event Action<int> LifeNumChanged

iStreamWrapper.LifeNumChanged += handler

Нотификация изменения номера жизни в серверной схеме репликации.

Online

public event Action Online

iStreamWrapper.Online += handler

Нотификация о переходе потока в on-line состояние.

StateChanged

public event Action<ObjectStates> StateChanged

iStreamWrapper.StateChanged += handler

Нотификация об изменении состояния потока репликационных данных.