HistoryMarketDataManager
Внедрение менеджера исторических рыночных данных.
Наследует: Disposable
Реализует: IHistoryMarketDataManager, IDisposable
Конструкторы
public HistoryMarketDataManager(ITradingTimeLineGenerator timeLineGenerator)
historyMarketDataManager = HistoryMarketDataManager(timeLineGenerator)
Инициализирует новый экземпляр HistoryMarketDataManager.
- timeLineGenerator
- Генератор торговых временных линий.
Свойства
public MarketDataStorageCache AdapterCache { get; set; }
value = historyMarketDataManager.AdapterCache
historyMarketDataManager.AdapterCache = value
MarketDataStorageCache.
public bool CheckTradableDates { get; set; }
value = historyMarketDataManager.CheckTradableDates
historyMarketDataManager.CheckTradableDates = value
Проверьте даты загрузки, можно ли ими торговать.
public DateTime CurrentTime { get; }
value = historyMarketDataManager.CurrentTime
Текущее время UTC.
public IMarketDataDrive Drive { get; set; }
value = historyMarketDataManager.Drive
historyMarketDataManager.Drive = value
Хранилище, которое используется по умолчанию.
public bool IsStarted { get; private set; }
value = historyMarketDataManager.IsStarted
historyMarketDataManager.IsStarted = value
Если таймер работает.
public int LoadedMessageCount { get; private set; }
value = historyMarketDataManager.LoadedMessageCount
historyMarketDataManager.LoadedMessageCount = value
Количество загруженных событий.
public TimeSpan MarketTimeChangedInterval { get; set; }
value = historyMarketDataManager.MarketTimeChangedInterval
historyMarketDataManager.MarketTimeChangedInterval = value
Интервал сообщения TimeMessageпоколения.
public int PostTradeMarketTimeChangedCount { get; set; }
value = historyMarketDataManager.PostTradeMarketTimeChangedCount
historyMarketDataManager.PostTradeMarketTimeChangedCount = value
Количество событий вызывается после окончания торгов.
public DateTime StartDate { get; set; }
value = historyMarketDataManager.StartDate
historyMarketDataManager.StartDate = value
Дата в истории для начала.
public DateTime StopDate { get; set; }
value = historyMarketDataManager.StopDate
historyMarketDataManager.StopDate = value
Дата в истории, чтобы остановиться (дата включена).
public MarketDataStorageCache StorageCache { get; set; }
value = historyMarketDataManager.StorageCache
historyMarketDataManager.StorageCache = value
Кэш.
public StorageFormats StorageFormat { get; set; }
value = historyMarketDataManager.StorageFormat
historyMarketDataManager.StorageFormat = value
Формат рыночных данных.
public IStorageRegistry StorageRegistry { get; set; }
value = historyMarketDataManager.StorageRegistry
historyMarketDataManager.StorageRegistry = value
Хранение рыночных данных.
Методы
protected override void DisposeManaged()
historyMarketDataManager.DisposeManaged()
Освободите ресурсы.
private IEnumerable<Message> DriveGenerators(Message trigger, DateTime time)
result = historyMarketDataManager.DriveGenerators(trigger, time)
Управляет зарегистрированными генераторами с помощью часов воспроизведения и данных того же финансового инструмента, возвращая любые сгенерированные сообщения (чередующиеся вызывающей стороной в одно и то же время сервера). Сигнал времени ускоряет генерацию на основе времени для каждого генератора; триггерное сообщение передается генераторам своего собственного финансового инструмента, и каждое сгенерированное сообщение связывается с другими генераторами того же финансового инструмента, поэтому сгенерированный тик приводит в действие генератор книги заказов этого финансового инструмента. Генераторы игнорируют свой собственный тип вывода, поэтому цепочка завершается.
- trigger
- Повторное сообщение, которое перевело часы.
- time
- Текущее время сервера воспроизведения.
Возвращает: Сгенерированные сообщения, если таковые имеются.
public IAsyncEnumerable<DataType> GetSupportedDataTypesAsync(SecurityId securityId)
result = historyMarketDataManager.GetSupportedDataTypesAsync(securityId)
Получите поддерживаемые типы данных для финансового инструмента.
- securityId
- идентификатор финансового инструмента.
Возвращает: Поддерживаемые типы данных.
public bool HasGenerator(SecurityId securityId, DataType dataType)
result = historyMarketDataManager.HasGenerator(securityId, dataType)
Проверьте, существует ли генератор.
- securityId
- идентификатор финансового инструмента.
- dataType
- Тип данных.
Возвращает: если генератор существует.
public void RegisterGenerator(SecurityId securityId, DataType dataType, MarketDataGenerator generator, long transactionId)
historyMarketDataManager.RegisterGenerator(securityId, dataType, generator, transactionId)
Зарегистрируйте генератор.
- securityId
- идентификатор финансового инструмента.
- dataType
- Тип данных.
- generator
- Генератор.
- transactionId
- Идентификатор транзакции.
public IAsyncEnumerable<Message> StartAsync(IEnumerable<BoardMessage> boards)
result = historyMarketDataManager.StartAsync(boards)
Запустите генерацию рыночных данных.
- boards
- Обмен досками.
Возвращает: Асинхронное перечисление сообщений.
public void Stop()
historyMarketDataManager.Stop()
Остановите таймер.
Возвращает: ITimerHandler
public ValueTask<Exception> SubscribeAsync(MarketDataMessage message, CancellationToken cancellationToken)
result = historyMarketDataManager.SubscribeAsync(message, cancellationToken)
Подпишитесь на рыночные данные.
- message
- Сообщение о подписке.
- cancellationToken
- Токен отмены.
Возвращает: Ошибка, если подписка не удалась, в противном случае — значение null.
public bool UnregisterGenerator(long originalTransactionId)
result = historyMarketDataManager.UnregisterGenerator(originalTransactionId)
Отменить регистрацию генератора.
- originalTransactionId
- Идентификатор исходной транзакции.
Возвращает: если генератор был найден и удален.
public void Unsubscribe(long originalTransactionId)
historyMarketDataManager.Unsubscribe(originalTransactionId)
Отписаться от рыночных данных.
- originalTransactionId
- Идентификатор исходной транзакции подписки.