HistoryMarketDataManager

HistoryMarketDataManager

public HistoryMarketDataManager(ITradingTimeLineGenerator timeLineGenerator)

historyMarketDataManager = HistoryMarketDataManager(timeLineGenerator)

HistoryMarketDataManager の新規インスタンスを初期化します。

timeLineGenerator

取引時間ライン発電機。

AdapterCache

public MarketDataStorageCache AdapterCache { get; set; }

value = historyMarketDataManager.AdapterCache
historyMarketDataManager.AdapterCache = value

代表取締役社長 佐藤 浩

CheckTradableDates

public bool CheckTradableDates { get; set; }

value = historyMarketDataManager.CheckTradableDates
historyMarketDataManager.CheckTradableDates = value

読み込み日は、追跡可能であることを確認してください。

CurrentTime

public DateTime CurrentTime { get; }

value = historyMarketDataManager.CurrentTime

現在のUTCの時間。

Drive

public IMarketDataDrive Drive { get; set; }

value = historyMarketDataManager.Drive
historyMarketDataManager.Drive = value

デフォルトで使用されているストレージ。

IsStarted

public bool IsStarted { get; private set; }

value = historyMarketDataManager.IsStarted
historyMarketDataManager.IsStarted = value

タイマーが実行されているかどうか。

LoadedMessageCount

public int LoadedMessageCount { get; private set; }

value = historyMarketDataManager.LoadedMessageCount
historyMarketDataManager.LoadedMessageCount = value

ロードされたイベントの数。

MarketTimeChangedInterval

public TimeSpan MarketTimeChangedInterval { get; set; }

value = historyMarketDataManager.MarketTimeChangedInterval
historyMarketDataManager.MarketTimeChangedInterval = value

送信先のメールの間隔TimeMessage生成

PostTradeMarketTimeChangedCount

public int PostTradeMarketTimeChangedCount { get; set; }

value = historyMarketDataManager.PostTradeMarketTimeChangedCount
historyMarketDataManager.PostTradeMarketTimeChangedCount = value

取引終了後のイベント呼び出し数。

StartDate

public DateTime StartDate { get; set; }

value = historyMarketDataManager.StartDate
historyMarketDataManager.StartDate = value

歴史の始まりの日付。

StopDate

public DateTime StopDate { get; set; }

value = historyMarketDataManager.StopDate
historyMarketDataManager.StopDate = value

歴史の終点(日付は含まれます)。

StorageCache

public MarketDataStorageCache StorageCache { get; set; }

value = historyMarketDataManager.StorageCache
historyMarketDataManager.StorageCache = value

キャッシュ。

StorageFormat

public StorageFormats StorageFormat { get; set; }

value = historyMarketDataManager.StorageFormat
historyMarketDataManager.StorageFormat = value

市場データの形式。

StorageRegistry

public IStorageRegistry StorageRegistry { get; set; }

value = historyMarketDataManager.StorageRegistry
historyMarketDataManager.StorageRegistry = value

市場データストレージ。

DisposeManaged

protected override void DisposeManaged()

historyMarketDataManager.DisposeManaged()

リソースのリリース

DriveGenerators

private IEnumerable<Message> DriveGenerators(Message trigger, DateTime time)

result = historyMarketDataManager.DriveGenerators(trigger, time)

登録されたジェネレータを、再生クロックと同金融商品データとともに動かし、生成されたメッセージ(同じサーバー時間で発信者によって解釈される)を返します。タイムシグナルは、すべてのジェネレータのタイムベース生成を促進します。トリガーメッセージは、独自の金融商品のジェネレータをフィードし、各生成されたメッセージは、他の同じ金融商品ジェネレータにチェーンされ、財務機器のオーダーブックジェネレーターが生成されるティックドライブです。ジェネレーターは、独自の出力タイプを無視します。そのため、チェーンは他の同じ金融商品ジェネレーターに終了します。

trigger

時計を高度にした再生メッセージ。

time

サーバの現在の再生時間。

戻り値: 生成されたメッセージは、任意のメッセージです。

GetSupportedDataTypesAsync

public IAsyncEnumerable<DataType> GetSupportedDataTypesAsync(SecurityId securityId)

result = historyMarketDataManager.GetSupportedDataTypesAsync(securityId)

金融商品にサポートされているデータタイプを取得します。

securityId

金融商品ID

戻り値: サポートされているデータタイプ。

HasGenerator

public bool HasGenerator(SecurityId securityId, DataType dataType)

result = historyMarketDataManager.HasGenerator(securityId, dataType)

発電機が存在するかどうかを確認してください。

securityId

金融商品ID

dataType

データ型。

戻り値: ジェネレータが存在する場合。

RegisterGenerator

public void RegisterGenerator(SecurityId securityId, DataType dataType, MarketDataGenerator generator, long transactionId)

historyMarketDataManager.RegisterGenerator(securityId, dataType, generator, transactionId)

発電機を登録します。

securityId

金融商品ID

dataType

データ型。

generator

ジェネレーター。

transactionId

取引ID。

Reset

public void Reset()

historyMarketDataManager.Reset()

リセット状態。

StartAsync

public IAsyncEnumerable<Message> StartAsync(IEnumerable<BoardMessage> boards)

result = historyMarketDataManager.StartAsync(boards)

市場データ生成を開始します。

boards

交換ボード。

戻り値: メッセージのエンメラブルを非同期化

Stop

public void Stop()

historyMarketDataManager.Stop()

タイマーを停止します。

戻り値: 担当: 佐藤 宏

SubscribeAsync

public ValueTask<Exception> SubscribeAsync(MarketDataMessage message, CancellationToken cancellationToken)

result = historyMarketDataManager.SubscribeAsync(message, cancellationToken)

市場データへの登録

message

サブスクリプションメッセージ。

cancellationToken

キャンセルトークン。

戻り値: サブスクリプションが失敗した場合は、エラーが無効に。

UnregisterGenerator

public bool UnregisterGenerator(long originalTransactionId)

result = historyMarketDataManager.UnregisterGenerator(originalTransactionId)

未登録発電機。

originalTransactionId

元のトランザクションID。

戻り値: 発電機が見つけられ、取除かれたら。

Unsubscribe

public void Unsubscribe(long originalTransactionId)

historyMarketDataManager.Unsubscribe(originalTransactionId)

市場データから退会する。

originalTransactionId

元のサブスクリプショントランザクション ID。