PolygonIOMessageAdapter

StockSharp.PolygonIO

Адаптер сообщений для PolygonIO.

Наследует: MessageAdapter

Реализует: ITokenAdapter, IKeySecretAdapter, IAddressAdapter<string>

Конструкторы

PolygonIOMessageAdapter
public PolygonIOMessageAdapter(IdGenerator transactionIdGenerator)
polygonIOMessageAdapter = PolygonIOMessageAdapter(transactionIdGenerator)

Инициализирует новый экземпляр PolygonIOMessageAdapter.

transactionIdGenerator
Генератор идентификаторов транзакций.

Свойства

Address
public string Address { get; set; }
value = polygonIOMessageAdapter.Address
polygonIOMessageAdapter.Address = value

Адрес сервера.

AllTimeFrames
public static IEnumerable<TimeSpan> AllTimeFrames { get; }
value = PolygonIOMessageAdapter.AllTimeFrames

Возможные сроки.

ConnectionType
public PolygonIOConnectionTypes ConnectionType { get; set; }
value = polygonIOMessageAdapter.ConnectionType
polygonIOMessageAdapter.ConnectionType = value

Тип подключения.

FeatureName
public override string FeatureName { get; }
value = polygonIOMessageAdapter.FeatureName

Особенное имя.

FlatFilesRepo
public string FlatFilesRepo { get; set; }
value = polygonIOMessageAdapter.FlatFilesRepo
polygonIOMessageAdapter.FlatFilesRepo = value

Полигоновые плоские файлы (S3) имя ведра.

FlatFilesSections
public IEnumerable<SecurityTypes> FlatFilesSections { get; set; }
value = polygonIOMessageAdapter.FlatFilesSections
polygonIOMessageAdapter.FlatFilesSections = value

Разделы инструментов (типы финансовых инструментов) для плоских файлов Polygon. Если пусто, режим плоских файлов выключен.

Key
public SecureString Key { get; set; }
value = polygonIOMessageAdapter.Key
polygonIOMessageAdapter.Key = value

AWS Access Key id для плоских файлов Polygon (S3)

Secret
public SecureString Secret { get; set; }
value = polygonIOMessageAdapter.Secret
polygonIOMessageAdapter.Secret = value

Секретный ключ доступа AWS для плоских файлов Polygon (S3)

Token
public SecureString Token { get; set; }
value = polygonIOMessageAdapter.Token
polygonIOMessageAdapter.Token = value

Токен-правила, с которыми он связан (например, для правила ISubscriptionProvider) заказ будет токеном. Если правило ни с чем не связано, то будет возвращено.

Методы

ConnectAsync
protected override ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.ConnectAsync(connectMsg, cancellationToken)
DisconnectAsync
protected override ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.DisconnectAsync(disconnectMsg, cancellationToken)
IsAllDownloadingSupported
public override bool IsAllDownloadingSupported(DataType dataType)
result = polygonIOMessageAdapter.IsAllDownloadingSupported(dataType)

Включена ли для указанного загрузка всех финансовых инструментов.

dataType
Информация о типе данных.

Возвращает: Проверьте результат.

IsSecurityRequired
public override bool IsSecurityRequired(DataType dataType)
result = polygonIOMessageAdapter.IsSecurityRequired(dataType)

Поддержка фильтрации подписок (подписка/отмена подписки на определенный финансовый инструмент).

dataType
Информация о типе данных.

Возвращает: Проверьте результат.

Load
public override void Load(SettingsStorage storage)
polygonIOMessageAdapter.Load(storage)

Загрузить настройки.

storage
Хранилище настроек.
OnLevel1SubscriptionAsync
protected override ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)

Обрабатывает запрос на подписку для данных уровня 1. Переопределить, чтобы обеспечить реализацию обработки подписки уровня 1. Реализация по умолчанию выдает NotSupported.

mdMsg
Сообщение о подписке на рыночные данные.
cancellationToken
Токен отмены для отмены операции.

Возвращает: ValueTask, представляющий асинхронную операцию.

OnNewsSubscriptionAsync
protected override ValueTask OnNewsSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnNewsSubscriptionAsync(mdMsg, cancellationToken)

Обрабатывает запрос подписки на данные новостей. Переопределить, чтобы обеспечить реализацию обработки подписки на новости. Реализация по умолчанию выдает NotSupported.

mdMsg
Сообщение о подписке на рыночные данные.
cancellationToken
Токен отмены для отмены операции.

Возвращает: ValueTask, представляющий асинхронную операцию.

OnTFCandlesSubscriptionAsync
protected override ValueTask OnTFCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnTFCandlesSubscriptionAsync(mdMsg, cancellationToken)

Обрабатывает запрос на подписку на данные временных свечей (TF-свечи). Переопределить, чтобы обеспечить реализацию обработки подписки на свечи TF. Реализация по умолчанию выдает NotSupported.

mdMsg
Сообщение о подписке на рыночные данные.
cancellationToken
Токен отмены для отмены операции.

Возвращает: ValueTask, представляющий асинхронную операцию.

OnTicksSubscriptionAsync
protected override ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)

Обрабатывает запрос подписки на данные тиков. Переопределить, чтобы обеспечить реализацию обработки подписки на тики. Реализация по умолчанию выдает NotSupported.

mdMsg
Сообщение о подписке на рыночные данные.
cancellationToken
Токен отмены для отмены операции.

Возвращает: ValueTask, представляющий асинхронную операцию.

ResetAsync
protected override ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.ResetAsync(resetMsg, cancellationToken)
Save
public override void Save(SettingsStorage storage)
polygonIOMessageAdapter.Save(storage)

Сохраните настройки.

storage
Хранилище настроек.
SecurityLookupAsync
protected override ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)