StorageBuffer

StockSharp.Algo.Storages

Tampão de armazenamento.

Implementa: IStorageBuffer, IAsyncPersistable

Propriedades

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

Activar o armazenamento.

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

Activar o armazenamento de nível 1.

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

Activar o armazenamento do livro de pedidos.

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

Activar o armazenamento de posições.

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

Activar o armazenamento de transacções.

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

Guardar dados apenas para assinaturas.

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

Ignorar mensagens com BuildFrom não é .

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.

Métodos

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

Create a copy of the buffer.

cancellationToken
CancellationToken

Retorna: Copy.

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

Acumule BoardStateMessage.

Retorna: Estados Unidos.

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

Acumule CandleMessage.

Retorna: Velas.

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

Acumule Level1ChangeMessage.

Retorna: Nível 1.

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

Acumule NewsMessage.

Retorna: Notícias.

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

Acumule QuoteChangeMessage.

Retorna: Ordens de livros.

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

Acumule OrderLog.

Retorna: Diário de encomendas.

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

Acumule PositionChangeMessage.

Retorna: Mudanças de posição.

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

Acumule Ticks.

Retorna: Tiques.

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

Acumular Transações.

Retorna: Transações.

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

Mensagem de processo.

message
Mensagem.
ProcessOutMessage
public void ProcessOutMessage(Message message)
storageBuffer.ProcessOutMessage(message)

Mensagem de processo.

message
Mensagem.
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.