BaseUdpDialect
Die Basisklasse, die den Dialekt des UDP-Protokolls beschreibt.
Erbt von: BaseLogReceiver
Implementiert: IUdpDialect, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
Konstruktoren
protected BaseUdpDialect()
baseUdpDialect = BaseUdpDialect()
Initialisiert eine neue Instanz der BaseUdpDialect Klasse.
Eigenschaften
public string[] AssociatedBoards { get; }
value = baseUdpDialect.AssociatedBoards
Der Adapter kann Abonnements nur mit Instrumenten verarbeiten, die mit der angegebenen Platine verbunden sind.
public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = baseUdpDialect.CandlesBuildFrom
Mögliche Optionen für Kerzen Gebäude.
public virtual MessageAdapterCategories Categories { get; }
value = baseUdpDialect.Categories
Kategorien von Nachrichtenadaptern.
public virtual bool CheckTimeFrameByRequest { get; }
value = baseUdpDialect.CheckTimeFrameByRequest
Überprüfen Sie den möglichen Zeitrahmen auf Anfrage.
public virtual TimeSpan DisconnectTimeout { get; }
value = baseUdpDialect.DisconnectTimeout
Bekommt die Timeout, um auf eine anmutige Trennung zu warten.
public bool DumpPacketOnError { get; set; }
value = baseUdpDialect.DumpPacketOnError
baseUdpDialect.DumpPacketOnError = value
Wenn dies wahr ist, protokolliert die vollständige UDP-Paketnutzlast als Base64, wenn die Verarbeitung fehlschlägt.
public virtual bool EnqueueSubscriptions { get; set; }
value = baseUdpDialect.EnqueueSubscriptions
baseUdpDialect.EnqueueSubscriptions = value
Warteschlange Abonnements.
public virtual bool ExtraSetup { get; }
value = baseUdpDialect.ExtraSetup
Der Adapter erfordert eine zusätzliche Einrichtung.
public TimeSpan FaultDelay { get; set; }
value = baseUdpDialect.FaultDelay
baseUdpDialect.FaultDelay = value
Bekommt oder setzt die zwischen fehlerhaften Iterationen angewendete Verzögerung.
public virtual string FeatureName { get; }
value = baseUdpDialect.FeatureName
Name des Merkmals.
protected int HeartbeatMls { get; }
value = baseUdpDialect.HeartbeatMls
Herzschlag-Intervall in Millisekunden.
public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }
value = baseUdpDialect.IsAutoReplyOnTransactonalUnsubscription
Senden Sie Auto-Antwort für OrderStatusMessage und PortfolioLookupMessage Abmelder.
public virtual bool IsFullCandlesOnly { get; }
value = baseUdpDialect.IsFullCandlesOnly
Übersetzt CandleMessage als nur vollständig ausgefüllt.
public virtual bool IsNativeIdentifiers { get; }
value = baseUdpDialect.IsNativeIdentifiers
Identifizieren Sie das Finanzinstrument in Nachrichten nach nativer Kennung Native.
public virtual bool IsNativeIdentifiersPersistable { get; }
value = baseUdpDialect.IsNativeIdentifiersPersistable
Native Identifier kann gespeichert werden.
public virtual bool? IsPositionsEmulationRequired { get; }
value = baseUdpDialect.IsPositionsEmulationRequired
Adapter benötigt Emulation PositionChangeMessage.
public virtual bool IsReplaceCommandEditCurrent { get; }
value = baseUdpDialect.IsReplaceCommandEditCurrent
Bearbeitet der Befehl OrderReplaceMessage eine aktuelle Bestellung?
public virtual bool IsSecurityNewsOnly { get; }
value = baseUdpDialect.IsSecurityNewsOnly
Adapter liefert Nachrichten zu einem bestimmten Finanzinstrument.
public virtual bool IsSupportExecutionsPnL { get; }
value = baseUdpDialect.IsSupportExecutionsPnL
Adapter füllt PnL.
public virtual bool IsSupportOrderBookIncrements { get; }
value = baseUdpDialect.IsSupportOrderBookIncrements
Adapter übersetzt inkrementelle Auftragsbücher.
public virtual bool IsSupportSubscriptions { get; }
value = baseUdpDialect.IsSupportSubscriptions
Unterstützen Sie alle Abonnements (Ticks, Bestellbücher usw.).
public virtual bool IsSupportTransactionLog { get; }
value = baseUdpDialect.IsSupportTransactionLog
Adapter übersetzt Bestellungsänderungen auf Antwort von OrderStatusMessage.
public virtual TimeSpan IterationInterval { get; }
value = baseUdpDialect.IterationInterval
Intervall zwischen Iterationen.
public virtual TimeSpan? LookupTimeout { get; set; }
value = baseUdpDialect.LookupTimeout
baseUdpDialect.LookupTimeout = value
Lookup Timeout.
public int MaxIncomingQueueSize { get; set; }
value = baseUdpDialect.MaxIncomingQueueSize
baseUdpDialect.MaxIncomingQueueSize = value
Maximale gepufferte eingehende UDP-Pakete pro Feed, bevor neue Pakete fallen gelassen werden.
public int MaxIncrementalWrongOrder { get; set; }
value = baseUdpDialect.MaxIncrementalWrongOrder
baseUdpDialect.MaxIncrementalWrongOrder = value
Max inkrementelle Nachrichten mit falscher Reihenfolge vor dem Wiederherstellen Start.
public int MaxParallelMessages { get; set; }
value = baseUdpDialect.MaxParallelMessages
baseUdpDialect.MaxParallelMessages = value
Die maximale Anzahl von parallelen (nicht kontrollierbaren) Nachrichten, die verarbeitet werden können, wird ermittelt oder festgelegt.
public int MaxRestoreCount { get; set; }
value = baseUdpDialect.MaxRestoreCount
baseUdpDialect.MaxRestoreCount = value
Max Nachrichtenzahl, die wiederhergestellt werden kann.
public int MaxRestores { get; set; }
value = baseUdpDialect.MaxRestores
baseUdpDialect.MaxRestores = value
Max mögliche Wiederherstellungen.
public int MaxSuspended { get; set; }
value = baseUdpDialect.MaxSuspended
baseUdpDialect.MaxSuspended = value
Max suspendierte Nachrichten.
public int MaxUdpDatagramSize { get; set; }
value = baseUdpDialect.MaxUdpDatagramSize
baseUdpDialect.MaxUdpDatagramSize = value
Maximale UDP-Datagrammgröße.
public virtual Type OrderConditionType { get; }
value = baseUdpDialect.OrderConditionType
Typ von OrderCondition.
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }
value = baseUdpDialect.PossibleSupportedMessages
Mögliche unterstützte Nachrichtentypen.
public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }
value = baseUdpDialect.SecurityExtendedFields
Namen von erweiterten Finanzinstrument Felder in SecurityMessage.
public virtual string StorageName { get; }
value = baseUdpDialect.StorageName
Speichername.
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = baseUdpDialect.SupportedOrderBookDepths
Verfügbare Optionen für MaxDepth.
public virtual bool UseInChannel { get; }
value = baseUdpDialect.UseInChannel
Verwenden Sie Kanäle für in Nachrichten.
public virtual bool UseOutChannel { get; }
value = baseUdpDialect.UseOutChannel
Verwenden Sie Kanäle für unsere Nachrichten.
public bool UseUdpResnapshot { get; set; }
value = baseUdpDialect.UseUdpResnapshot
baseUdpDialect.UseUdpResnapshot = value
Verwenden Sie UDP Re-Snapshot anstelle von TCP Replay zum Wiederherstellen von Lücken.
Methoden
public IMemoryOwner<byte> AllocatePacket(ILogReceiver logs, int size)
result = baseUdpDialect.AllocatePacket(logs, size)
Um ein Paket der angegebenen Größe zuzuordnen.
- logs
- Der Protokollempfänger, um Informationen über den Speicherpoolstatus zu protokollieren.
- size
- Die Größe des zuzuteilenden Pakets.
Rückgabe: Das Paket.
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()
Erstellt eine tiefe Kopie eines DataSeries
protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ConnectAsync(connectMsg, cancellationToken)
public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)
result = baseUdpDialect.CreateOrderLogMarketDepthBuilder(securityId)
Erstellen Sie Markttiefe Builder.
- securityId
- Kennung des Finanzinstruments.
Rückgabe: Order Log to Market Deep Builder.
public abstract IUdpSettingsParser CreateParser()
result = baseUdpDialect.CreateParser()
Erstellen Sie eine neue Instanz der Klasse IUdpSettingsParser @.
Rückgabe: IUdpSettingsParser
protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.DisconnectAsync(disconnectMsg, cancellationToken)
protected override void DisposeManaged()
baseUdpDialect.DisposeManaged()
Ressourcen freigeben.
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)
Unterstützt werden sie von adapter-nachrichtentypen.
- securityId
- SecurityId
- from
- Startdatum für die Anfrage. Wenn , werden alle verfügbaren Nachrichten zurückgegeben.
- to
- Enddatum der Anfrage: Wenn , werden alle verfügbaren Nachrichten zurückgegeben.
Rückgabe: Unterstützt durch Adapter-Marktdatentypen.
public virtual bool IsAllDownloadingSupported(DataType dataType)
result = baseUdpDialect.IsAllDownloadingSupported(dataType)
Ist für die angegebenen alle Finanzinstrumente Download aktiviert.
- dataType
- Datenart-Info.
Rückgabe: Prüfergebnis.
public virtual bool IsSecurityRequired(DataType dataType)
result = baseUdpDialect.IsSecurityRequired(dataType)
Unterstützen Sie das Filtern von Abonnements (Abonnement/Abonnement für ein bestimmtes Finanzinstrument).
- dataType
- Datenart-Info.
Rückgabe: Prüfergebnis.
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesPriceLevels(subscription)
Unterstützen Kerzen PriceLevels.
- subscription
- MarketDataMessage
Rückgabe: Prüfergebnis.
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesUpdates(subscription)
Unterstützen Sie Kerzen-Abonnement und Live-Updates.
- subscription
- MarketDataMessage
Rückgabe: Prüfergebnis.
public override void Load(SettingsStorage storage)
baseUdpDialect.Load(storage)
Lasteinstellungen.
- storage
- Einstellungen Lagerung.
public abstract void LoadSettingsFromFile(IDictionary<string, UdpFeedGroup> feeds)
baseUdpDialect.LoadSettingsFromFile(feeds)
Laden Sie Einstellungen aus einer bestimmten Datei.
- feeds
- UDP-Einstellungen.
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)
Einstellungen speichern.
- storage
- Einstellungen Lagerung.
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)
Verarbeitet eine generische Nachricht asynchron.
- message
- Die Botschaft zum Prozess.
- cancellationToken
- CancellationToken
protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutErrorAsync(error, cancellationToken)
Initialisieren Sie eine neue Nachricht ErrorMessage und übergeben Sie sie an die Methode CancellationToken.
- error
- Angaben zu Fehlern.
- cancellationToken
- CancellationToken
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutMessageAsync(message, cancellationToken)
Um das Ereignis NewOutMessageAsync aufzurufen.
- message
- Die Botschaft.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionReplyAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionReplyAsync(message, cancellationToken)
Senden Sie SubscriptionResponseMessage.
- message
- Die Anfragenachricht.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionResultAsync(message, cancellationToken)
Senden Sie SubscriptionFinishedMessage oder SubscriptionOnlineMessage.
- message
- Die Anfragenachricht.
- cancellationToken
- CancellationToken
protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = baseUdpDialect.TimeAsync(timeMsg, cancellationToken)
Ereignisse
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
baseUdpDialect.NewOutMessageAsync += handler
Neues Nachrichtenereignis.