BaseUdpDialect
A classe base descreve o dialeto do protocolo UDP.
Herda de: BaseLogReceiver
Implementa: IUdpDialect, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
Construtores
protected BaseUdpDialect()
baseUdpDialect = BaseUdpDialect()
Inicializa uma nova instância da classe BaseUdpDialect.
Propriedades
public string[] AssociatedBoards { get; }
value = baseUdpDialect.AssociatedBoards
O adaptador só pode processar a subscrição com instrumentos associados à placa especificada.
public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = baseUdpDialect.CandlesBuildFrom
Possíveis opções para construção de velas.
public virtual MessageAdapterCategories Categories { get; }
value = baseUdpDialect.Categories
Categorias de adaptadores de mensagens.
public virtual bool CheckTimeFrameByRequest { get; }
value = baseUdpDialect.CheckTimeFrameByRequest
Verifique o prazo possível mediante pedido.
public virtual TimeSpan DisconnectTimeout { get; }
value = baseUdpDialect.DisconnectTimeout
Obtém o tempo para esperar por uma graciosa desconexão.
public bool DumpPacketOnError { get; set; }
value = baseUdpDialect.DumpPacketOnError
baseUdpDialect.DumpPacketOnError = value
Quando true, registra a carga de pacote UDP completa como Base64 quando o processamento falha. Destinado para diagnósticos/desserialização de pacotes problemáticos.
public virtual bool EnqueueSubscriptions { get; set; }
value = baseUdpDialect.EnqueueSubscriptions
baseUdpDialect.EnqueueSubscriptions = value
Increva as assinaturas.
public virtual bool ExtraSetup { get; }
value = baseUdpDialect.ExtraSetup
O adaptador requer uma configuração extra.
public TimeSpan FaultDelay { get; set; }
value = baseUdpDialect.FaultDelay
baseUdpDialect.FaultDelay = value
Obtém ou define o atraso aplicado entre iterações com defeito.
public virtual string FeatureName { get; }
value = baseUdpDialect.FeatureName
Nome da peça.
protected int HeartbeatMls { get; }
value = baseUdpDialect.HeartbeatMls
Intervalo cardíaco em milissegundos.
public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }
value = baseUdpDialect.IsAutoReplyOnTransactonalUnsubscription
Enviar resposta automática para OrderStatusMessage e PortfolioLookupMessagenunscribes.
public virtual bool IsFullCandlesOnly { get; }
value = baseUdpDialect.IsFullCandlesOnly
Traduz CandleMessage como apenas completamente preenchido.
public virtual bool IsNativeIdentifiers { get; }
value = baseUdpDialect.IsNativeIdentifiers
Identificar o instrumento financeiro nas mensagens por identificador nativo.
public virtual bool IsNativeIdentifiersPersistable { get; }
value = baseUdpDialect.IsNativeIdentifiersPersistable
O identificador nativo pode ser armazenado.
public virtual bool? IsPositionsEmulationRequired { get; }
value = baseUdpDialect.IsPositionsEmulationRequired
Emulação necessária do adaptador PositionChangeMessage.
public virtual bool IsReplaceCommandEditCurrent { get; }
value = baseUdpDialect.IsReplaceCommandEditCurrent
É o comando OrderReplaceMessage editar uma ordem atual.
public virtual bool IsSecurityNewsOnly { get; }
value = baseUdpDialect.IsSecurityNewsOnly
Adaptador fornece notícias relacionadas com instrumento financeiro especificado.
public virtual bool IsSupportExecutionsPnL { get; }
value = baseUdpDialect.IsSupportExecutionsPnL
O adaptador preenche PnL.
public virtual bool IsSupportOrderBookIncrements { get; }
value = baseUdpDialect.IsSupportOrderBookIncrements
Adaptador traduz livros de ordem incremental.
public virtual bool IsSupportSubscriptions { get; }
value = baseUdpDialect.IsSupportSubscriptions
Apoie quaisquer assinaturas (fatos, livros de encomendas, etc.).
public virtual bool IsSupportTransactionLog { get; }
value = baseUdpDialect.IsSupportTransactionLog
Adaptador traduz alterações de ordens na resposta de OrderStatusMessage.
public virtual TimeSpan IterationInterval { get; }
value = baseUdpDialect.IterationInterval
Intervalo entre iterações.
public virtual TimeSpan? LookupTimeout { get; set; }
value = baseUdpDialect.LookupTimeout
baseUdpDialect.LookupTimeout = value
Tempo de procura.
public int MaxIncomingQueueSize { get; set; }
value = baseUdpDialect.MaxIncomingQueueSize
baseUdpDialect.MaxIncomingQueueSize = value
Pacotes UDP de entrada de buffer máximo por feed antes de novos pacotes serem deixados cair.
public int MaxIncrementalWrongOrder { get; set; }
value = baseUdpDialect.MaxIncrementalWrongOrder
baseUdpDialect.MaxIncrementalWrongOrder = value
Max mensagens incrementais com ordem errada antes de recuperar o início.
public int MaxParallelMessages { get; set; }
value = baseUdpDialect.MaxParallelMessages
baseUdpDialect.MaxParallelMessages = value
Obtém ou define o número máximo de mensagens paralelas (não- controlo) que podem ser processadas. Deve ser maior ou igual a 1.
public int MaxRestoreCount { get; set; }
value = baseUdpDialect.MaxRestoreCount
baseUdpDialect.MaxRestoreCount = value
Contagem máxima de mensagens que podem ser restauradas.
public int MaxRestores { get; set; }
value = baseUdpDialect.MaxRestores
baseUdpDialect.MaxRestores = value
O máximo de restaurações possíveis.
public int MaxSuspended { get; set; }
value = baseUdpDialect.MaxSuspended
baseUdpDialect.MaxSuspended = value
Max suspendeu mensagens.
public int MaxUdpDatagramSize { get; set; }
value = baseUdpDialect.MaxUdpDatagramSize
baseUdpDialect.MaxUdpDatagramSize = value
Tamanho máximo do datagram do UDP.
public virtual Type OrderConditionType { get; }
value = baseUdpDialect.OrderConditionType
Tipo de OrderCondition.
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }
value = baseUdpDialect.PossibleSupportedMessages
Possíveis tipos de mensagens suportadas.
public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }
value = baseUdpDialect.SecurityExtendedFields
Nomes dos campos de instrumentos financeiros estendidos em SecurityMessage.
public virtual string StorageName { get; }
value = baseUdpDialect.StorageName
Nome do armazém.
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = baseUdpDialect.SupportedOrderBookDepths
Opções disponíveis para MaxDepth.
public virtual bool UseInChannel { get; }
value = baseUdpDialect.UseInChannel
Usar canais para as mensagens.
public virtual bool UseOutChannel { get; }
value = baseUdpDialect.UseOutChannel
Usar canais para mensagens de saída.
public bool UseUdpResnapshot { get; set; }
value = baseUdpDialect.UseUdpResnapshot
baseUdpDialect.UseUdpResnapshot = value
Use o re-snapshot UDP em vez de TCP replay para restaurar lacunas.
Métodos
public IMemoryOwner<byte> AllocatePacket(ILogReceiver logs, int size)
result = baseUdpDialect.AllocatePacket(logs, size)
Para alocar um pacote do tamanho especificado.
- logs
- O receptor de log para registrar informações sobre o status do pool de memória.
- size
- O tamanho do pacote para alocar.
Retorna: O pacote.
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()
Cria uma cópia profunda de DataSeries
protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ConnectAsync(connectMsg, cancellationToken)
public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)
result = baseUdpDialect.CreateOrderLogMarketDepthBuilder(securityId)
Criar construtor de profundidade de mercado.
- securityId
- ID do instrumento financeiro.
Retorna: Ordem log para construtor de profundidade de mercado.
public abstract IUdpSettingsParser CreateParser()
result = baseUdpDialect.CreateParser()
Criar uma nova instância da classe IUdpSettingsParser.
Retorna: IUdpSettingsParser
protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.DisconnectAsync(disconnectMsg, cancellationToken)
protected override void DisposeManaged()
baseUdpDialect.DisposeManaged()
Libertar 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)
Seja suportado por tipos de mensagem adaptador.
- securityId
- SecurityId
- from
- Data de início para solicitação. Se , em seguida, todas as mensagens disponíveis serão devolvidos.
- to
- Data de fim para a solicitação. Se , então todas as mensagens disponíveis serão devolvidas.
Retorna: Suportado por tipos de dados de mercado adaptador.
public virtual bool IsAllDownloadingSupported(DataType dataType)
result = baseUdpDialect.IsAllDownloadingSupported(dataType)
É para os instrumentos financeiros especificados que são descarregados habilitados.
- dataType
- Informação do tipo de dados.
Retorna: Verificar o resultado.
public virtual bool IsSecurityRequired(DataType dataType)
result = baseUdpDialect.IsSecurityRequired(dataType)
Apoio à filtragem de assinaturas (assinatura/desassinatura para o instrumento financeiro especificado).
- dataType
- Informação do tipo de dados.
Retorna: Verificar o resultado.
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesPriceLevels(subscription)
Suporte a velas PriceLevels.
- subscription
- MarketDataMessage
Retorna: Verificar o resultado.
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesUpdates(subscription)
Suporte assinatura velas e atualizações ao vivo.
- subscription
- MarketDataMessage
Retorna: Verificar o resultado.
public override void Load(SettingsStorage storage)
baseUdpDialect.Load(storage)
Carregar as configurações.
- storage
- Configuração do armazenamento.
public abstract void LoadSettingsFromFile(IDictionary<string, UdpFeedGroup> feeds)
baseUdpDialect.LoadSettingsFromFile(feeds)
Carregar as configurações do arquivo especificado.
- feeds
- Configuração do 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)
Gravar as definições.
- storage
- Configuração do armazenamento.
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)
Processa uma mensagem genérica de forma assíncrona.
- message
- A mensagem para processar.
- cancellationToken
- CancellationToken
protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutErrorAsync(error, cancellationToken)
Inicialize uma nova mensagem ErrorMessage e passe-a para o método CancellationToken@).
- error
- Detalhes do erro.
- cancellationToken
- CancellationToken
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutMessageAsync(message, cancellationToken)
Chamar o evento NewOutMessageAsync.
- message
- A mensagem.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionReplyAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionReplyAsync(message, cancellationToken)
Enviar SubscriptionResponseMessage.
- message
- A mensagem de pedido.
- cancellationToken
- CancellationToken
protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionResultAsync(message, cancellationToken)
Enviar SubscriptionFinishedMessage@ ou SubscriptionOnlineMessage.
- message
- A mensagem de pedido.
- 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
Novo evento de mensagem.