BaseUdpDialect
UDPプロトコルのダイヤルを記述するベースクラス。
継承元: BaseLogReceiver
実装: IUdpDialect, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
コンストラクター
protected BaseUdpDialect()
baseUdpDialect = BaseUdpDialect()
BaseUdpDialectクラスの新しいインスタンスを初期化します。
プロパティ
public string[] AssociatedBoards { get; }
value = baseUdpDialect.AssociatedBoards
アダプターは、指定されたボードに関連付けられている機器のみでサブスクリプションを処理できます。
public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = baseUdpDialect.CandlesBuildFrom
キャンドルビルのオプションもご用意しています。
public virtual MessageAdapterCategories Categories { get; }
value = baseUdpDialect.Categories
メッセージアダプタのカテゴリ。
public virtual bool CheckTimeFrameByRequest { get; }
value = baseUdpDialect.CheckTimeFrameByRequest
リクエストに応じて時間枠を確認できます。
public virtual TimeSpan DisconnectTimeout { get; }
value = baseUdpDialect.DisconnectTimeout
優雅な接続を待ちますようにタイムアウトを取得します。
public bool DumpPacketOnError { get; set; }
value = baseUdpDialect.DumpPacketOnError
baseUdpDialect.DumpPacketOnError = value
真の場合、処理が失敗したときに、フルUDPパケットペイロードをBase64としてログアウトします。問題のあるパケットの診断/デシリアライズのために意図されています。
public virtual bool EnqueueSubscriptions { get; set; }
value = baseUdpDialect.EnqueueSubscriptions
baseUdpDialect.EnqueueSubscriptions = value
サブスクリプションをエンキューします。
public virtual bool ExtraSetup { get; }
value = baseUdpDialect.ExtraSetup
アダプターは、追加のセットアップが必要です。
public TimeSpan FaultDelay { get; set; }
value = baseUdpDialect.FaultDelay
baseUdpDialect.FaultDelay = value
障害のある反復の間に適用される遅延を得られるか、またはセットします。
protected int HeartbeatMls { get; }
value = baseUdpDialect.HeartbeatMls
ミリ秒単位のハートビート間隔。
public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }
value = baseUdpDialect.IsAutoReplyOnTransactonalUnsubscription
OrderStatusMessageとPortfolioLookupMessageのサブスクリプションのオートレスポンスを送信します。
public virtual bool IsFullCandlesOnly { get; }
value = baseUdpDialect.IsFullCandlesOnly
Translates CandleMessage as only fully filled.
public virtual bool IsNativeIdentifiers { get; }
value = baseUdpDialect.IsNativeIdentifiers
ネイティブ識別子ネイティブでメッセージ内の金融商品を特定します。
public virtual bool IsNativeIdentifiersPersistable { get; }
value = baseUdpDialect.IsNativeIdentifiersPersistable
ネイティブ識別子を保存できます。
public virtual bool? IsPositionsEmulationRequired { get; }
value = baseUdpDialect.IsPositionsEmulationRequired
アダプターはエミュレーションPositionChangeMessageを要求しました。
public virtual bool IsReplaceCommandEditCurrent { get; }
value = baseUdpDialect.IsReplaceCommandEditCurrent
コマンドは@OrderReplaceMessage@です。
public virtual bool IsSecurityNewsOnly { get; }
value = baseUdpDialect.IsSecurityNewsOnly
アダプターは、特定金融商品に関連するニュースを提供します。
public virtual bool IsSupportExecutionsPnL { get; }
value = baseUdpDialect.IsSupportExecutionsPnL
アダプターは@PnL@に記入します。
public virtual bool IsSupportOrderBookIncrements { get; }
value = baseUdpDialect.IsSupportOrderBookIncrements
アダプターは、増分注文書を翻訳します。
public virtual bool IsSupportSubscriptions { get; }
value = baseUdpDialect.IsSupportSubscriptions
サブスクリプション(ticks、オーダーブックなど)をサポート
public virtual bool IsSupportTransactionLog { get; }
value = baseUdpDialect.IsSupportTransactionLog
アダプターは、OrderStatusMessage@の返信に注文の変更を翻訳します。
public virtual TimeSpan IterationInterval { get; }
value = baseUdpDialect.IterationInterval
反復との間のインターバル。
public virtual TimeSpan? LookupTimeout { get; set; }
value = baseUdpDialect.LookupTimeout
baseUdpDialect.LookupTimeout = value
タイムアウトを調べる。
public int MaxIncomingQueueSize { get; set; }
value = baseUdpDialect.MaxIncomingQueueSize
baseUdpDialect.MaxIncomingQueueSize = value
フィードごとのフィードごとの最大バッファ受信 UDP パケットを新しいパケットがドロップされる前に最大バッファします。
public int MaxIncrementalWrongOrder { get; set; }
value = baseUdpDialect.MaxIncrementalWrongOrder
baseUdpDialect.MaxIncrementalWrongOrder = value
スタートを回復する前に、間違った順序で最大の増分メッセージ。
public int MaxParallelMessages { get; set; }
value = baseUdpDialect.MaxParallelMessages
baseUdpDialect.MaxParallelMessages = value
処理できるパラレル(非制御)メッセージの最大数を取得またはセットします。 以上または等しい1でなければなりません。
public int MaxRestoreCount { get; set; }
value = baseUdpDialect.MaxRestoreCount
baseUdpDialect.MaxRestoreCount = value
復元できるメッセージ数の最大値。
public int MaxRestores { get; set; }
value = baseUdpDialect.MaxRestores
baseUdpDialect.MaxRestores = value
復元可能。
public int MaxSuspended { get; set; }
value = baseUdpDialect.MaxSuspended
baseUdpDialect.MaxSuspended = value
最大の中断されたメッセージ。
public int MaxUdpDatagramSize { get; set; }
value = baseUdpDialect.MaxUdpDatagramSize
baseUdpDialect.MaxUdpDatagramSize = value
UDP の最大データグラムサイズ。
public virtual Type OrderConditionType { get; }
value = baseUdpDialect.OrderConditionType
型式:OrderCondition@
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }
value = baseUdpDialect.PossibleSupportedMessages
対応可能なメッセージタイプ。
public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }
value = baseUdpDialect.SecurityExtendedFields
金融商品分野名をSecurityMessage@に拡張。
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = baseUdpDialect.SupportedOrderBookDepths
Available options for MaxDepth.
public virtual bool UseInChannel { get; }
value = baseUdpDialect.UseInChannel
メッセージを入力するためのチャンネルを使用します。
public virtual bool UseOutChannel { get; }
value = baseUdpDialect.UseOutChannel
メッセージを発信するためのチャンネルを使用します。
public bool UseUdpResnapshot { get; set; }
value = baseUdpDialect.UseUdpResnapshot
baseUdpDialect.UseUdpResnapshot = value
ギャップを回復するためにTCP再生の代わりにUDP再スナップショットを使用してください。
メソッド
public IMemoryOwner<byte> AllocatePacket(ILogReceiver logs, int size)
result = baseUdpDialect.AllocatePacket(logs, size)
指定したサイズのパケットを割り当てる。
- logs
- ログ受信機でメモリプールの状態に関する情報をログに記録します。
- size
- パケットのサイズを割り当てる。
戻り値: パケット。
protected virtual ValueTask BoardLookupAsync(BoardLookupMessage lookupMsg, CancellationToken cancellationToken)
result = baseUdpDialect.BoardLookupAsync(lookupMsg, cancellationToken)
protected virtual ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
result = baseUdpDialect.CancelOrderAsync(cancelMsg, cancellationToken)
protected virtual ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)
result = baseUdpDialect.CancelOrderGroupAsync(cancelMsg, cancellationToken)
protected virtual ValueTask ChangePasswordAsync(ChangePasswordMessage pwdMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ChangePasswordAsync(pwdMsg, cancellationToken)
public virtual IMessageAdapter Clone()
result = baseUdpDialect.Clone()
DataSeriesの深いコピーを作成します。
protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ConnectAsync(connectMsg, cancellationToken)
public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)
result = baseUdpDialect.CreateOrderLogMarketDepthBuilder(securityId)
マーケットデプスビルダーを作成します。
- securityId
- 金融商品ID
戻り値: ログをマーケットデプスビルダーに注文する。
public abstract IUdpSettingsParser CreateParser()
result = baseUdpDialect.CreateParser()
IUdpSettingsParserクラスの新しいインスタンスを作成します。
戻り値: 担当: 佐藤 宏
protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.DisconnectAsync(disconnectMsg, cancellationToken)
public virtual IEnumerable<object> GetCandleArgs(Type candleType, SecurityId securityId, DateTime? from, DateTime? to)
result = baseUdpDialect.GetCandleArgs(candleType, securityId, from, to)
public virtual IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)
result = baseUdpDialect.GetSupportedMarketDataTypesAsync(securityId, from, to)
アダプターメッセージタイプでサポートを受ける
- securityId
- 担当: 佐藤 宏
- from
- リクエストの開始日。 場合は、利用可能なすべてのメッセージが返されます。
- to
- リクエストの終了日。 場合、利用可能なすべてのメッセージが返されます。
戻り値: アダプター市場データ型で対応
public virtual bool IsAllDownloadingSupported(DataType dataType)
result = baseUdpDialect.IsAllDownloadingSupported(dataType)
対象となる全ての金融商品のダウンロードは有効です。
- dataType
- データ型情報。
戻り値: 結果をチェックする。
public virtual bool IsSecurityRequired(DataType dataType)
result = baseUdpDialect.IsSecurityRequired(dataType)
サブスクリプションのフィルタリング(指定された金融商品のサブスクリプション/サブスクリプションの購読/サブスクリプションの購読)をサポート。
- dataType
- データ型情報。
戻り値: 結果をチェックする。
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesPriceLevels(subscription)
キャンドルPriceLevels@を応援します。
- subscription
- 担当: 佐藤 宏
戻り値: 結果をチェックする。
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesUpdates(subscription)
キャンドルのサブスクリプションとライブ更新をサポート。
- subscription
- 担当: 佐藤 宏
戻り値: 結果をチェックする。
public override void Load(SettingsStorage storage)
baseUdpDialect.Load(storage)
設定をロードします。
- storage
- 設定ストレージ。
public abstract void LoadSettingsFromFile(IDictionary<string, UdpFeedGroup> feeds)
baseUdpDialect.LoadSettingsFromFile(feeds)
指定したファイルから設定をロードします。
- feeds
- UDP の設定。
protected virtual ValueTask MarketDataAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = baseUdpDialect.MarketDataAsync(mdMsg, cancellationToken)
protected virtual ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)
result = baseUdpDialect.OrderStatusAsync(statusMsg, cancellationToken)
protected virtual ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)
result = baseUdpDialect.PortfolioLookupAsync(lookupMsg, cancellationToken)
protected virtual ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
result = baseUdpDialect.RegisterOrderAsync(regMsg, cancellationToken)
protected virtual ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ReplaceOrderAsync(replaceMsg, cancellationToken)
protected virtual ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ResetAsync(resetMsg, cancellationToken)
public override void Save(SettingsStorage storage)
baseUdpDialect.Save(storage)
設定を保存します。
- storage
- 設定ストレージ。
protected virtual ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = baseUdpDialect.SecurityLookupAsync(lookupMsg, cancellationToken)
public virtual ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = baseUdpDialect.SendInMessageAsync(message, cancellationToken)
一般的なメッセージを非同期に処理します。
- message
- 処理するメッセージ。
- cancellationToken
- 担当: 佐藤 宏
protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutErrorAsync(error, cancellationToken)
新規のメッセージErrorMessageを初期化し、CancellationTokenに渡します。
- error
- エラーの詳細。
- cancellationToken
- 担当: 佐藤 宏
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutMessageAsync(message, cancellationToken)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- message
- メッセージを送信する
- cancellationToken
- 担当: 佐藤 宏
protected ValueTask SendSubscriptionReplyAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionReplyAsync(message, cancellationToken)
Send SubscriptionResponseMessage.
- message
- リクエスト
- cancellationToken
- 担当: 佐藤 宏
protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionResultAsync(message, cancellationToken)
SubscriptionFinishedMessage または SubscriptionOnlineMessage を 送信 します。
- message
- リクエスト
- cancellationToken
- 担当: 佐藤 宏
protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = baseUdpDialect.TimeAsync(timeMsg, cancellationToken)
イベント
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
baseUdpDialect.NewOutMessageAsync += handler
新規メッセージイベント