PolygonIOMessageAdapter
The message adapter for PolygonIO.
继承自: MessageAdapter
实现: ITokenAdapter, IKeySecretAdapter, IAddressAdapter<string>
构造函数
public PolygonIOMessageAdapter(IdGenerator transactionIdGenerator)
polygonIOMessageAdapter = PolygonIOMessageAdapter(transactionIdGenerator)
初始化了 & ##PolygonIOMessageAdapter+#的新实例.
- transactionIdGenerator
- 交易ID生成器。
属性
public string Address { get; set; }
value = polygonIOMessageAdapter.Address
polygonIOMessageAdapter.Address = value
服务器地址 。
public static IEnumerable<TimeSpan> AllTimeFrames { get; }
value = PolygonIOMessageAdapter.AllTimeFrames
可能的时限。
public PolygonIOConnectionTypes ConnectionType { get; set; }
value = polygonIOMessageAdapter.ConnectionType
polygonIOMessageAdapter.ConnectionType = value
连接类型 。
public override string FeatureName { get; }
value = polygonIOMessageAdapter.FeatureName
地物名相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相相
public string FlatFilesRepo { get; set; }
value = polygonIOMessageAdapter.FlatFilesRepo
polygonIOMessageAdapter.FlatFilesRepo = value
多边形平平文件(S3)桶名.
public IEnumerable<SecurityTypes> FlatFilesSections { get; set; }
value = polygonIOMessageAdapter.FlatFilesSections
polygonIOMessageAdapter.FlatFilesSections = value
多边形平面文件的仪器部分( 金融工具类型) 。 如果空出, 平面文件模式已关闭 。
public SecureString Key { get; set; }
value = polygonIOMessageAdapter.Key
polygonIOMessageAdapter.Key = value
AWS Polygon平面文件访问密钥 ID (S3).
public SecureString Secret { get; set; }
value = polygonIOMessageAdapter.Secret
polygonIOMessageAdapter.Secret = value
Polygon平面文件(S3)的 AWS 秘密访问密钥.
public SecureString Token { get; set; }
value = polygonIOMessageAdapter.Token
polygonIOMessageAdapter.Token = value
脚本规则,它与(例如规则ISubscriptionProvider)命令相关联。如果规则与任何事物无关,则将返回。
方法
protected override ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.ConnectAsync(connectMsg, cancellationToken)
protected override ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.DisconnectAsync(disconnectMsg, cancellationToken)
public override bool IsAllDownloadingSupported(DataType dataType)
result = polygonIOMessageAdapter.IsAllDownloadingSupported(dataType)
用于指定的所有金融工具下载启用。
- dataType
- 数据类型信息.
返回值: 检查结果。
public override bool IsSecurityRequired(DataType dataType)
result = polygonIOMessageAdapter.IsSecurityRequired(dataType)
支持过滤订阅(订阅/不订阅指定金融工具).
- dataType
- 数据类型信息.
返回值: 检查结果。
public override void Load(SettingsStorage storage)
polygonIOMessageAdapter.Load(storage)
装入设置 。
- storage
- 设置存储 。
protected override ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)
处理关卡1 的订阅请求。 覆盖以提供关卡1 的订阅处理。 默认执行会丢出 NotSupported 。
- mdMsg
- 市场数据订阅信息.
- cancellationToken
- 取消操作的代理 。
返回值: 代表同步操作的ValueTask.
protected override ValueTask OnNewsSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnNewsSubscriptionAsync(mdMsg, cancellationToken)
处理新闻数据的订阅请求。 覆盖以提供新闻订阅处理的执行。 默认执行会丢出 NotSupported 。
- mdMsg
- 市场数据订阅信息.
- cancellationToken
- 取消操作的代理 。
返回值: 代表同步操作的ValueTask.
protected override ValueTask OnTFCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnTFCandlesSubscriptionAsync(mdMsg, cancellationToken)
处理对时间范围蜡烛(TF clash) 数据的订阅请求。 覆盖为 TF 蜡烛订阅处理提供执行。 默认执行会丢出 NotSupported 。
- mdMsg
- 市场数据订阅信息.
- cancellationToken
- 取消操作的代理 。
返回值: 代表同步操作的ValueTask.
protected override ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)
处理对 勾选数据的订阅请求。 覆盖为 勾选订阅处理提供执行。 默认执行会丢出 NotSupported 。
- mdMsg
- 市场数据订阅信息.
- cancellationToken
- 取消操作的代理 。
返回值: 代表同步操作的ValueTask.
protected override ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.ResetAsync(resetMsg, cancellationToken)
public override void Save(SettingsStorage storage)
polygonIOMessageAdapter.Save(storage)
保存设置 。
- storage
- 设置存储 。
protected override ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = polygonIOMessageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)