StorageBuffer

StockSharp.Algo.Storages

Буфер хранения.

Реализует: IStorageBuffer, IAsyncPersistable

Свойства

DisableStorageTimer
public bool DisableStorageTimer { get; set; }
value = storageBuffer.DisableStorageTimer
storageBuffer.DisableStorageTimer = value

StartStorageTimer.

DroppedMessages
public long DroppedMessages { get; }
value = storageBuffer.DroppedMessages

How many messages were thrown away because MaxBufferedMessages was reached. What is counted here is gone.

Enabled
public bool Enabled { get; set; }
value = storageBuffer.Enabled
storageBuffer.Enabled = value

Включите хранение.

EnabledLevel1
public bool EnabledLevel1 { get; set; }
value = storageBuffer.EnabledLevel1
storageBuffer.EnabledLevel1 = value

Включите хранилище уровня 1.

EnabledOrderBook
public bool EnabledOrderBook { get; set; }
value = storageBuffer.EnabledOrderBook
storageBuffer.EnabledOrderBook = value

Включите хранение книги заказов.

EnabledPositions
public bool EnabledPositions { get; set; }
value = storageBuffer.EnabledPositions
storageBuffer.EnabledPositions = value

Включите хранение позиций.

EnabledTransactions
public bool EnabledTransactions { get; set; }
value = storageBuffer.EnabledTransactions
storageBuffer.EnabledTransactions = value

Включите хранение транзакций.

FilterSubscription
public bool FilterSubscription { get; set; }
value = storageBuffer.FilterSubscription
storageBuffer.FilterSubscription = value

Сохраняйте данные только для подписки.

IgnoreGenerated
public ISet<DataType> IgnoreGenerated { get; }
value = storageBuffer.IgnoreGenerated

Игнорировать сообщения с BuildFrom не является.

MaxBufferedMessages
public long MaxBufferedMessages { get; set; }
value = storageBuffer.MaxBufferedMessages
storageBuffer.MaxBufferedMessages = value

How many messages may wait to be written before new ones are thrown away. Zero, the default, is no limit at all.

Методы

CloneAsync
public ValueTask<IStorageBuffer> CloneAsync(CancellationToken cancellationToken)
result = storageBuffer.CloneAsync(cancellationToken)

Create a copy of the buffer.

cancellationToken
CancellationToken

Возвращает: Copy.

GetBoardStates
public IEnumerable<BoardStateMessage> GetBoardStates()
result = storageBuffer.GetBoardStates()

Получите накопленные BoardStateMessage.

Возвращает: Штаты.

GetCandles
public IDictionary<ValueTuple<SecurityId, DataType>, IEnumerable<CandleMessage>> GetCandles()
result = storageBuffer.GetCandles()

Получите накопленные CandleMessage.

Возвращает: Свечи.

GetLevel1
public IDictionary<SecurityId, IEnumerable<Level1ChangeMessage>> GetLevel1()
result = storageBuffer.GetLevel1()

Получите накопленные Level1ChangeMessage.

Возвращает: Уровень1.

GetNews
public IEnumerable<NewsMessage> GetNews()
result = storageBuffer.GetNews()

Получите накопленные NewsMessage.

Возвращает: Новости.

GetOrderBooks
public IDictionary<SecurityId, IEnumerable<QuoteChangeMessage>> GetOrderBooks()
result = storageBuffer.GetOrderBooks()

Получите накопленные QuoteChangeMessage.

Возвращает: Заказ книг.

GetOrderLog
public IDictionary<SecurityId, IEnumerable<ExecutionMessage>> GetOrderLog()
result = storageBuffer.GetOrderLog()

Получите накопленные OrderLog.

Возвращает: Журнал заказов.

GetPositionChanges
public IDictionary<SecurityId, IEnumerable<PositionChangeMessage>> GetPositionChanges()
result = storageBuffer.GetPositionChanges()

Получите накопленные PositionChangeMessage.

Возвращает: Позиция меняется.

GetTicks
public IDictionary<SecurityId, IEnumerable<ExecutionMessage>> GetTicks()
result = storageBuffer.GetTicks()

Получайте накопленные Тики.

Возвращает: Клещи.

GetTransactions
public IDictionary<SecurityId, IEnumerable<ExecutionMessage>> GetTransactions()
result = storageBuffer.GetTransactions()

Получите накопленные транзакции.

Возвращает: Транзакции.

ProcessInMessage
public void ProcessInMessage(Message message)
storageBuffer.ProcessInMessage(message)

Обработать сообщение.

message
Сообщение.
ProcessOutMessage
public void ProcessOutMessage(Message message)
storageBuffer.ProcessOutMessage(message)

Обработать сообщение.

message
Сообщение.
PutBack
public void PutBack(IEnumerable<Message> messages)
storageBuffer.PutBack(messages)

Puts back what could not be written, so the next round writes it rather than losing it.

messages
What was taken and not written.