HistoryMarketDataManager
Aplicación de datos del mercado de historia.
Hereda de: Disposable
Implementa: IHistoryMarketDataManager, IDisposable
Constructores
public HistoryMarketDataManager(ITradingTimeLineGenerator timeLineGenerator)
historyMarketDataManager = HistoryMarketDataManager(timeLineGenerator)
Inicia una nueva instancia de la HistoryMarketDataManager.
- timeLineGenerator
- Generador de línea de tiempo de tráfico.
Propiedades
public MarketDataStorageCache AdapterCache { get; set; }
value = historyMarketDataManager.AdapterCache
historyMarketDataManager.AdapterCache = value
MarketDataStorageCache.
public bool CheckTradableDates { get; set; }
value = historyMarketDataManager.CheckTradableDates
historyMarketDataManager.CheckTradableDates = value
Compruebe las fechas de carga son tradable.
public DateTime CurrentTime { get; }
value = historyMarketDataManager.CurrentTime
Hora actual de la UTC.
public IMarketDataDrive Drive { get; set; }
value = historyMarketDataManager.Drive
historyMarketDataManager.Drive = value
El almacenamiento que se utiliza por defecto.
public bool IsStarted { get; private set; }
value = historyMarketDataManager.IsStarted
historyMarketDataManager.IsStarted = value
Ya sea que el temporizador se esté ejecutando.
public int LoadedMessageCount { get; private set; }
value = historyMarketDataManager.LoadedMessageCount
historyMarketDataManager.LoadedMessageCount = value
El número de eventos cargados.
public TimeSpan MarketTimeChangedInterval { get; set; }
value = historyMarketDataManager.MarketTimeChangedInterval
historyMarketDataManager.MarketTimeChangedInterval = value
El intervalo de mensajes TimeMessagegeneración.
public int PostTradeMarketTimeChangedCount { get; set; }
value = historyMarketDataManager.PostTradeMarketTimeChangedCount
historyMarketDataManager.PostTradeMarketTimeChangedCount = value
El número de eventos llama después del final del comercio.
public DateTime StartDate { get; set; }
value = historyMarketDataManager.StartDate
historyMarketDataManager.StartDate = value
Fecha en la historia para empezar.
public DateTime StopDate { get; set; }
value = historyMarketDataManager.StopDate
historyMarketDataManager.StopDate = value
Fecha de parar (se incluye fecha).
public MarketDataStorageCache StorageCache { get; set; }
value = historyMarketDataManager.StorageCache
historyMarketDataManager.StorageCache = value
Cache.
public StorageFormats StorageFormat { get; set; }
value = historyMarketDataManager.StorageFormat
historyMarketDataManager.StorageFormat = value
El formato de los datos del mercado.
public IStorageRegistry StorageRegistry { get; set; }
value = historyMarketDataManager.StorageRegistry
historyMarketDataManager.StorageRegistry = value
Almacenamiento de datos de mercado.
Métodos
protected override void DisposeManaged()
historyMarketDataManager.DisposeManaged()
Libera recursos.
private IEnumerable<Message> DriveGenerators(Message trigger, DateTime time)
result = historyMarketDataManager.DriveGenerators(trigger, time)
Conduce los generadores registrados con el reloj de repetición y los datos del mismo instrumento financiero, devolviendo cualquier mensaje generado (interleavado por el callador en el mismo tiempo del servidor). Una señal de tiempo avanza generación basada en el tiempo para cada generador; el mensaje de activación alimenta los generadores de su propio instrumento financiero, y cada mensaje generado está encadenado en los otros generadores de instrumentos Generadores del mismo tipo, así que un generador de agujas generados que la salida del instrumento financiero.
- trigger
- El mensaje repetitivo que avanzó el reloj.
- time
- El tiempo actual del servidor de replay.
Devuelve: Los mensajes generados, si los hay.
public IAsyncEnumerable<DataType> GetSupportedDataTypesAsync(SecurityId securityId)
result = historyMarketDataManager.GetSupportedDataTypesAsync(securityId)
Obtenga tipos de datos compatibles para instrumentos financieros.
- securityId
- identificación de instrumentos financieros.
Devuelve: Tipos de datos compatibles.
public bool HasGenerator(SecurityId securityId, DataType dataType)
result = historyMarketDataManager.HasGenerator(securityId, dataType)
Compruebe si el generador existe.
- securityId
- identificación de instrumentos financieros.
- dataType
- Tipo de datos.
Devuelve: si el generador existe.
public void RegisterGenerator(SecurityId securityId, DataType dataType, MarketDataGenerator generator, long transactionId)
historyMarketDataManager.RegisterGenerator(securityId, dataType, generator, transactionId)
Generador de registro.
- securityId
- identificación de instrumentos financieros.
- dataType
- Tipo de datos.
- generator
- Generador.
- transactionId
- ID de transacción.
public IAsyncEnumerable<Message> StartAsync(IEnumerable<BoardMessage> boards)
result = historyMarketDataManager.StartAsync(boards)
Iniciar la generación de datos del mercado.
- boards
- Exchange boards.
Devuelve: Async enumerable of messages.
public void Stop()
historyMarketDataManager.Stop()
Para el temporizador.
Devuelve: ITimerHandler
public ValueTask<Exception> SubscribeAsync(MarketDataMessage message, CancellationToken cancellationToken)
result = historyMarketDataManager.SubscribeAsync(message, cancellationToken)
Suscríbete a los datos del mercado.
- message
- Mensaje de suscripción.
- cancellationToken
- Cancelación token.
Devuelve: Error si la suscripción falla, null de lo contrario.
public bool UnregisterGenerator(long originalTransactionId)
result = historyMarketDataManager.UnregisterGenerator(originalTransactionId)
Generador no registrado.
- originalTransactionId
- id de transacción original.
Devuelve: si el generador fue encontrado y eliminado.
public void Unsubscribe(long originalTransactionId)
historyMarketDataManager.Unsubscribe(originalTransactionId)
Descríbete de los datos del mercado.
- originalTransactionId
- transacción de suscripción original id.