BaseUdpDialect
La clase base que describe el dialecto del protocolo UDP.
Hereda de: BaseLogReceiver
Implementa: IUdpDialect, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
Constructores
protected BaseUdpDialect()
baseUdpDialect = BaseUdpDialect()
Inicia una nueva instancia de la clase BaseUdpDialect.
Propiedades
public string[] AssociatedBoards { get; }
value = baseUdpDialect.AssociatedBoards
El adaptador puede procesar la suscripción sólo con instrumentos asociados con la tabla especificada.
public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = baseUdpDialect.CandlesBuildFrom
Opciones posibles para la construcción de velas.
public virtual MessageAdapterCategories Categories { get; }
value = baseUdpDialect.Categories
Categorías de adaptador de mensajes.
public virtual bool CheckTimeFrameByRequest { get; }
value = baseUdpDialect.CheckTimeFrameByRequest
Compruebe el posible plazo por solicitud.
public virtual TimeSpan DisconnectTimeout { get; }
value = baseUdpDialect.DisconnectTimeout
Consigue el tiempo para esperar una desconexión agraciada.
public bool DumpPacketOnError { get; set; }
value = baseUdpDialect.DumpPacketOnError
baseUdpDialect.DumpPacketOnError = value
Cuando es cierto, registra la carga útil completa de UDP como Base64 cuando el procesamiento falla. Intended for diagnostics/deserialization of problematic packets.
public virtual bool EnqueueSubscriptions { get; set; }
value = baseUdpDialect.EnqueueSubscriptions
baseUdpDialect.EnqueueSubscriptions = value
Suscripciones de alquiler.
public virtual bool ExtraSetup { get; }
value = baseUdpDialect.ExtraSetup
El adaptador requiere una configuración extra.
public TimeSpan FaultDelay { get; set; }
value = baseUdpDialect.FaultDelay
baseUdpDialect.FaultDelay = value
Obtiene o establece el retraso aplicado entre las iteraciones defectuadas.
public virtual string FeatureName { get; }
value = baseUdpDialect.FeatureName
Nombre de la característica.
protected int HeartbeatMls { get; }
value = baseUdpDialect.HeartbeatMls
Intervalo de latido cardíaco en milisegundos.
public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }
value = baseUdpDialect.IsAutoReplyOnTransactonalUnsubscription
Enviar respuesta automática para OrderStatusMessage y PortfolioLookupMessageunsubscribes.
public virtual bool IsFullCandlesOnly { get; }
value = baseUdpDialect.IsFullCandlesOnly
Traduce CandleMessage como solamente completamente llenado.
public virtual bool IsNativeIdentifiers { get; }
value = baseUdpDialect.IsNativeIdentifiers
Identificar el instrumento financiero en mensajes por identificador nativo Nativo.
public virtual bool IsNativeIdentifiersPersistable { get; }
value = baseUdpDialect.IsNativeIdentifiersPersistable
Se puede almacenar identificador nativo.
public virtual bool? IsPositionsEmulationRequired { get; }
value = baseUdpDialect.IsPositionsEmulationRequired
Adaptador necesario emulación PositionChangeMessage.
public virtual bool IsReplaceCommandEditCurrent { get; }
value = baseUdpDialect.IsReplaceCommandEditCurrent
Es el comando OrderReplaceMessage edita un orden actual.
public virtual bool IsSecurityNewsOnly { get; }
value = baseUdpDialect.IsSecurityNewsOnly
Adaptador proporciona noticias relacionadas con un instrumento financiero especificado.
public virtual bool IsSupportExecutionsPnL { get; }
value = baseUdpDialect.IsSupportExecutionsPnL
Adaptador llena PnL.
public virtual bool IsSupportOrderBookIncrements { get; }
value = baseUdpDialect.IsSupportOrderBookIncrements
Adaptador traduce libros de orden incremental.
public virtual bool IsSupportSubscriptions { get; }
value = baseUdpDialect.IsSupportSubscriptions
Soporta cualquier suscripción (ticks, libros de pedidos, etc.).
public virtual bool IsSupportTransactionLog { get; }
value = baseUdpDialect.IsSupportTransactionLog
Adaptador traduce los cambios de pedidos en respuesta de OrderStatusMessage.
public virtual TimeSpan IterationInterval { get; }
value = baseUdpDialect.IterationInterval
Intervalo entre iteraciones.
public virtual TimeSpan? LookupTimeout { get; set; }
value = baseUdpDialect.LookupTimeout
baseUdpDialect.LookupTimeout = value
Cuidado con el tiempo.
public int MaxIncomingQueueSize { get; set; }
value = baseUdpDialect.MaxIncomingQueueSize
baseUdpDialect.MaxIncomingQueueSize = value
Paquetes UDP de entrada máxima por alimento antes de que se dejen caer nuevos paquetes.
public int MaxIncrementalWrongOrder { get; set; }
value = baseUdpDialect.MaxIncrementalWrongOrder
baseUdpDialect.MaxIncrementalWrongOrder = value
Max mensajes incrementales con el orden incorrecto antes de recuperar el comienzo.
public int MaxParallelMessages { get; set; }
value = baseUdpDialect.MaxParallelMessages
baseUdpDialect.MaxParallelMessages = value
Obtiene o establece el número máximo de mensajes paralelos (no control) que pueden ser procesados. Debe ser mayor o igual a 1.
public int MaxRestoreCount { get; set; }
value = baseUdpDialect.MaxRestoreCount
baseUdpDialect.MaxRestoreCount = value
Max cuenta de mensaje que se puede restaurar.
public int MaxRestores { get; set; }
value = baseUdpDialect.MaxRestores
baseUdpDialect.MaxRestores = value
Máximo posible restaura.
public int MaxSuspended { get; set; }
value = baseUdpDialect.MaxSuspended
baseUdpDialect.MaxSuspended = value
Max suspendió mensajes.
public int MaxUdpDatagramSize { get; set; }
value = baseUdpDialect.MaxUdpDatagramSize
baseUdpDialect.MaxUdpDatagramSize = value
Tamaño máximo de los datagramas UDP.
public virtual Type OrderConditionType { get; }
value = baseUdpDialect.OrderConditionType
Tipo de OrderCondition@.
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }
value = baseUdpDialect.PossibleSupportedMessages
Posibles tipos de mensajes apoyados.
public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }
value = baseUdpDialect.SecurityExtendedFields
Nombres de los campos de instrumentos financieros ampliados en SecurityMessage.
public virtual string StorageName { get; }
value = baseUdpDialect.StorageName
Nombre de almacenamiento.
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = baseUdpDialect.SupportedOrderBookDepths
Opciones disponibles para MaxDepth.
public virtual bool UseInChannel { get; }
value = baseUdpDialect.UseInChannel
Utilice canales para mensajes.
public virtual bool UseOutChannel { get; }
value = baseUdpDialect.UseOutChannel
Usar canales para mensajes fuera.
public bool UseUdpResnapshot { get; set; }
value = baseUdpDialect.UseUdpResnapshot
baseUdpDialect.UseUdpResnapshot = value
Use UDP re-snapshot en lugar de la repetición TCP para restaurar las brechas.
Métodos
public IMemoryOwner<byte> AllocatePacket(ILogReceiver logs, int size)
result = baseUdpDialect.AllocatePacket(logs, size)
Para asignar un paquete del tamaño especificado.
- logs
- El receptor de registro para registrar información sobre el estado de la piscina de memoria.
- size
- El tamaño del paquete para asignar.
Devuelve: El paquete.
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()
Crea una copia profunda de un DataSeries
protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ConnectAsync(connectMsg, cancellationToken)
public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)
result = baseUdpDialect.CreateOrderLogMarketDepthBuilder(securityId)
Crear un constructor de profundidad de mercado.
- securityId
- identificación de instrumentos financieros.
Devuelve: Ordene registro a la construcción de profundidad de mercado.
public abstract IUdpSettingsParser CreateParser()
result = baseUdpDialect.CreateParser()
Crear un nuevo ejemplo de la clase IUdpSettingsParser.
Devuelve: IUdpSettingsParser
protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.DisconnectAsync(disconnectMsg, cancellationToken)
protected override void DisposeManaged()
baseUdpDialect.DisposeManaged()
Libera recursos.
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)
Consiga soporte por tipos de mensaje de adaptador.
- securityId
- SecurityId
- from
- Fecha de inicio para solicitar. Si , entonces todos los mensajes disponibles serán devueltos.
- to
- Fecha final para solicitar. Si , entonces todos los mensajes disponibles serán devueltos.
Devuelve: Apoyado por tipos de datos del mercado de adaptadores.
public virtual bool IsAllDownloadingSupported(DataType dataType)
result = baseUdpDialect.IsAllDownloadingSupported(dataType)
Es para los instrumentos financieros especificados que se descargan habilitados.
- dataType
- Datos tipo info.
Devuelve: Resultado de la comprobación.
public virtual bool IsSecurityRequired(DataType dataType)
result = baseUdpDialect.IsSecurityRequired(dataType)
Suscripciones de filtrado de soporte (subscribe/sin suscripción para un instrumento financiero especificado).
- dataType
- Datos tipo info.
Devuelve: Resultado de la comprobación.
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesPriceLevels(subscription)
Soporta velas PriceLevels.
- subscription
- MarketDataMessage@
Devuelve: Resultado de la comprobación.
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesUpdates(subscription)
Soporta la suscripción de velas y actualizaciones en vivo.
- subscription
- MarketDataMessage@
Devuelve: Resultado de la comprobación.
public override void Load(SettingsStorage storage)
baseUdpDialect.Load(storage)
Ajustes de carga.
- storage
- Configuración de almacenamiento.
public abstract void LoadSettingsFromFile(IDictionary<string, UdpFeedGroup> feeds)
baseUdpDialect.LoadSettingsFromFile(feeds)
Ajustes de carga desde el archivo especificado.
- feeds
- Ajustes 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)
Guardar configuración.
- storage
- Configuración de almacenamiento.
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)
Procesa un mensaje genérico asincrónicamente.
- message
- El mensaje para procesar.
- cancellationToken
- CancellationToken
protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutErrorAsync(error, cancellationToken)
Inicia un nuevo mensaje ErrorMessage y pasalo al método CancellationToken.
- error
- Detalles del error.
- cancellationToken
- CancellationToken
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutMessageAsync(message, cancellationToken)
Para llamar al evento NewOutMessageAsync.
- message
- El mensaje.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionReplyAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionReplyAsync(message, cancellationToken)
Enviar SubscriptionResponseMessage.
- message
- El mensaje de solicitud.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionResultAsync(message, cancellationToken)
Enviar SubscriptionFinishedMessage o SubscriptionOnlineMessage.
- message
- El mensaje de solicitud.
- cancellationToken
- CancellationToken
protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = baseUdpDialect.TimeAsync(timeMsg, cancellationToken)
Eventos
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
baseUdpDialect.NewOutMessageAsync += handler
Nuevo evento de mensaje.