StorageBuffer
ストレージバッファ。
実装: IStorageBuffer, IAsyncPersistable
プロパティ
public bool DisableStorageTimer { get; set; }
value = storageBuffer.DisableStorageTimer
storageBuffer.DisableStorageTimer = value
代表取締役社長 佐藤 浩
public long DroppedMessages { get; }
value = storageBuffer.DroppedMessages
How many messages were thrown away because MaxBufferedMessages was reached. What is counted here is gone.
public bool Enabled { get; set; }
value = storageBuffer.Enabled
storageBuffer.Enabled = value
ストレージを有効にします。
public bool EnabledLevel1 { get; set; }
value = storageBuffer.EnabledLevel1
storageBuffer.EnabledLevel1 = value
Level1 ストレージを有効にします。
public bool EnabledOrderBook { get; set; }
value = storageBuffer.EnabledOrderBook
storageBuffer.EnabledOrderBook = value
注文書の保存を有効にします。
public bool EnabledPositions { get; set; }
value = storageBuffer.EnabledPositions
storageBuffer.EnabledPositions = value
位置の記憶を有効にします。
public bool EnabledTransactions { get; set; }
value = storageBuffer.EnabledTransactions
storageBuffer.EnabledTransactions = value
トランザクションストレージを有効にします。
public bool FilterSubscription { get; set; }
value = storageBuffer.FilterSubscription
storageBuffer.FilterSubscription = value
サブスクリプションのみのデータを保存します。
public ISet<DataType> IgnoreGenerated { get; }
value = storageBuffer.IgnoreGenerated
Ignore messages with BuildFrom is not .
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.
メソッド
public ValueTask<IStorageBuffer> CloneAsync(CancellationToken cancellationToken)
result = storageBuffer.CloneAsync(cancellationToken)
Create a copy of the buffer.
- cancellationToken
- CancellationToken
戻り値: Copy.
public IEnumerable<BoardStateMessage> GetBoardStates()
result = storageBuffer.GetBoardStates()
代表取締役社長 佐藤 浩一
戻り値: 日 時
public IDictionary<ValueTuple<SecurityId, DataType>, IEnumerable<CandleMessage>> GetCandles()
result = storageBuffer.GetCandles()
代表取締役社長 佐藤 浩一
戻り値: キャンドル。
public IDictionary<SecurityId, IEnumerable<Level1ChangeMessage>> GetLevel1()
result = storageBuffer.GetLevel1()
代表取締役社長 佐藤 浩一
戻り値: レベル1。
public IEnumerable<NewsMessage> GetNews()
result = storageBuffer.GetNews()
代表取締役社長 佐藤 浩一
戻り値: 新着情報
public IDictionary<SecurityId, IEnumerable<QuoteChangeMessage>> GetOrderBooks()
result = storageBuffer.GetOrderBooks()
代表取締役社長 佐藤 浩一
戻り値: 書籍の注文
public IDictionary<SecurityId, IEnumerable<ExecutionMessage>> GetOrderLog()
result = storageBuffer.GetOrderLog()
代表取締役社長 佐藤 浩一
戻り値: 注文ログ。
public IDictionary<SecurityId, IEnumerable<PositionChangeMessage>> GetPositionChanges()
result = storageBuffer.GetPositionChanges()
代表取締役社長 佐藤 浩一
戻り値: 位置変更。
public IDictionary<SecurityId, IEnumerable<ExecutionMessage>> GetTicks()
result = storageBuffer.GetTicks()
蓄積されたTicksを入手してください。
戻り値: ティックス.
public IDictionary<SecurityId, IEnumerable<ExecutionMessage>> GetTransactions()
result = storageBuffer.GetTransactions()
蓄積された取引を取得します。
戻り値: 取引。
public void ProcessInMessage(Message message)
storageBuffer.ProcessInMessage(message)
プロセスメッセージ。
- message
- ご挨拶
public void ProcessOutMessage(Message message)
storageBuffer.ProcessOutMessage(message)
プロセスメッセージ。
- message
- ご挨拶
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.