PlazaStreamManager

PlazaStreamManager

public PlazaStreamManager(string configPath, PlazaTableRegistry tableRegistry, PlazaRevisionManager revisionManager, SynchronizedDictionary<PlazaStream, int> connectionGroupping, PlazaConnectionPool connectionPool, Action<Message> enqueueMessage)

plazaStreamManager = PlazaStreamManager(configPath, tableRegistry, revisionManager, connectionGroupping, connectionPool, enqueueMessage)

Менеджер потоков данных.

ConnectionGroupping

public SynchronizedDictionary<PlazaStream, int> ConnectionGroupping { get; }

value = plazaStreamManager.ConnectionGroupping

Настройки группировки потоков по соединениям.

Begin

public event Action<PlazaStream, PlazaTable[]> Begin

plazaStreamManager.Begin += handler

Событие начала обработки данных.

Cleared

public event Action<PlazaStream, PlazaTable, long> Cleared

plazaStreamManager.Cleared += handler

Событие удаления данных.

End

public event Action<PlazaStream, PlazaTable[]> End

plazaStreamManager.End += handler

Событие окончания обработки данных.

Flushed

public event Action<PlazaStream, PlazaTable[]> Flushed

plazaStreamManager.Flushed += handler

Событие сброса состояния всего потока.

Inserted

public event Action<PlazaStream, PlazaTable, IPlazaRecord> Inserted

plazaStreamManager.Inserted += handler

Событие вставки новых данных.

Online

public event Action<PlazaStream, PlazaTable[]> Online

plazaStreamManager.Online += handler

Событие перехода в онлайн.