BaseUdpDialect

StockSharp.Fix.Dialects

A classe base descreve o dialeto do protocolo UDP.

Herda de: BaseLogReceiver

Implementa: IUdpDialect, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable

Construtores

BaseUdpDialect
protected BaseUdpDialect()
baseUdpDialect = BaseUdpDialect()

Inicializa uma nova instância da classe BaseUdpDialect.

Propriedades

AssociatedBoards
public string[] AssociatedBoards { get; }
value = baseUdpDialect.AssociatedBoards

O adaptador só pode processar a subscrição com instrumentos associados à placa especificada.

CandlesBuildFrom
public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }
value = baseUdpDialect.CandlesBuildFrom

Possíveis opções para construção de velas.

Categories
public virtual MessageAdapterCategories Categories { get; }
value = baseUdpDialect.Categories

Categorias de adaptadores de mensagens.

CheckTimeFrameByRequest
public virtual bool CheckTimeFrameByRequest { get; }
value = baseUdpDialect.CheckTimeFrameByRequest

Verifique o prazo possível mediante pedido.

DisconnectTimeout
public virtual TimeSpan DisconnectTimeout { get; }
value = baseUdpDialect.DisconnectTimeout

Obtém o tempo para esperar por uma graciosa desconexão.

DumpPacketOnError
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.

EnqueueSubscriptions
public virtual bool EnqueueSubscriptions { get; set; }
value = baseUdpDialect.EnqueueSubscriptions
baseUdpDialect.EnqueueSubscriptions = value

Increva as assinaturas.

ExtraSetup
public virtual bool ExtraSetup { get; }
value = baseUdpDialect.ExtraSetup

O adaptador requer uma configuração extra.

FaultDelay
public TimeSpan FaultDelay { get; set; }
value = baseUdpDialect.FaultDelay
baseUdpDialect.FaultDelay = value

Obtém ou define o atraso aplicado entre iterações com defeito.

FeatureName
public virtual string FeatureName { get; }
value = baseUdpDialect.FeatureName

Nome da peça.

Feeds
public IList<IUdpNetworkFeed> Feeds { get; }
value = baseUdpDialect.Feeds

Alimenta-se.

HeartbeatMls
protected int HeartbeatMls { get; }
value = baseUdpDialect.HeartbeatMls

Intervalo cardíaco em milissegundos.

Icon
public virtual Uri Icon { get; }
value = baseUdpDialect.Icon

Ícone.

IsAutoReplyOnTransactonalUnsubscription
public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }
value = baseUdpDialect.IsAutoReplyOnTransactonalUnsubscription

Enviar resposta automática para OrderStatusMessage e PortfolioLookupMessagenunscribes.

IsFullCandlesOnly
public virtual bool IsFullCandlesOnly { get; }
value = baseUdpDialect.IsFullCandlesOnly

Traduz CandleMessage como apenas completamente preenchido.

IsNativeIdentifiers
public virtual bool IsNativeIdentifiers { get; }
value = baseUdpDialect.IsNativeIdentifiers

Identificar o instrumento financeiro nas mensagens por identificador nativo.

IsNativeIdentifiersPersistable
public virtual bool IsNativeIdentifiersPersistable { get; }
value = baseUdpDialect.IsNativeIdentifiersPersistable

O identificador nativo pode ser armazenado.

IsPositionsEmulationRequired
public virtual bool? IsPositionsEmulationRequired { get; }
value = baseUdpDialect.IsPositionsEmulationRequired

Emulação necessária do adaptador PositionChangeMessage.

IsReplaceCommandEditCurrent
public virtual bool IsReplaceCommandEditCurrent { get; }
value = baseUdpDialect.IsReplaceCommandEditCurrent

É o comando OrderReplaceMessage editar uma ordem atual.

IsSecurityNewsOnly
public virtual bool IsSecurityNewsOnly { get; }
value = baseUdpDialect.IsSecurityNewsOnly

Adaptador fornece notícias relacionadas com instrumento financeiro especificado.

IsSupportExecutionsPnL
public virtual bool IsSupportExecutionsPnL { get; }
value = baseUdpDialect.IsSupportExecutionsPnL

O adaptador preenche PnL.

IsSupportOrderBookIncrements
public virtual bool IsSupportOrderBookIncrements { get; }
value = baseUdpDialect.IsSupportOrderBookIncrements

Adaptador traduz livros de ordem incremental.

IsSupportSubscriptions
public virtual bool IsSupportSubscriptions { get; }
value = baseUdpDialect.IsSupportSubscriptions

Apoie quaisquer assinaturas (fatos, livros de encomendas, etc.).

IsSupportTransactionLog
public virtual bool IsSupportTransactionLog { get; }
value = baseUdpDialect.IsSupportTransactionLog

Adaptador traduz alterações de ordens na resposta de OrderStatusMessage.

IterationInterval
public virtual TimeSpan IterationInterval { get; }
value = baseUdpDialect.IterationInterval

Intervalo entre iterações.

Login
protected string Login { get; }
value = baseUdpDialect.Login

Login.

LookupTimeout
public virtual TimeSpan? LookupTimeout { get; set; }
value = baseUdpDialect.LookupTimeout
baseUdpDialect.LookupTimeout = value

Tempo de procura.

MaxIncomingQueueSize
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.

MaxIncrementalWrongOrder
public int MaxIncrementalWrongOrder { get; set; }
value = baseUdpDialect.MaxIncrementalWrongOrder
baseUdpDialect.MaxIncrementalWrongOrder = value

Max mensagens incrementais com ordem errada antes de recuperar o início.

MaxParallelMessages
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.

MaxRestoreCount
public int MaxRestoreCount { get; set; }
value = baseUdpDialect.MaxRestoreCount
baseUdpDialect.MaxRestoreCount = value

Contagem máxima de mensagens que podem ser restauradas.

MaxRestores
public int MaxRestores { get; set; }
value = baseUdpDialect.MaxRestores
baseUdpDialect.MaxRestores = value

O máximo de restaurações possíveis.

MaxSuspended
public int MaxSuspended { get; set; }
value = baseUdpDialect.MaxSuspended
baseUdpDialect.MaxSuspended = value

Max suspendeu mensagens.

MaxUdpDatagramSize
public int MaxUdpDatagramSize { get; set; }
value = baseUdpDialect.MaxUdpDatagramSize
baseUdpDialect.MaxUdpDatagramSize = value

Tamanho máximo do datagram do UDP.

OrderConditionType
public virtual Type OrderConditionType { get; }
value = baseUdpDialect.OrderConditionType

Tipo de OrderCondition.

Password
protected SecureString Password { get; }
value = baseUdpDialect.Password

Senha.

PossibleSupportedMessages
public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; }
value = baseUdpDialect.PossibleSupportedMessages

Possíveis tipos de mensagens suportadas.

SecurityExtendedFields
public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }
value = baseUdpDialect.SecurityExtendedFields

Nomes dos campos de instrumentos financeiros estendidos em SecurityMessage.

StorageName
public virtual string StorageName { get; }
value = baseUdpDialect.StorageName

Nome do armazém.

SupportedOrderBookDepths
public virtual IEnumerable<int> SupportedOrderBookDepths { get; }
value = baseUdpDialect.SupportedOrderBookDepths

Opções disponíveis para MaxDepth.

UseInChannel
public virtual bool UseInChannel { get; }
value = baseUdpDialect.UseInChannel

Usar canais para as mensagens.

UseOutChannel
public virtual bool UseOutChannel { get; }
value = baseUdpDialect.UseOutChannel

Usar canais para mensagens de saída.

UseUdpResnapshot
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

AllocatePacket
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.

BoardLookupAsync
protected virtual ValueTask BoardLookupAsync(BoardLookupMessage lookupMsg, CancellationToken cancellationToken)
result = baseUdpDialect.BoardLookupAsync(lookupMsg, cancellationToken)
CancelOrderAsync
protected virtual ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
result = baseUdpDialect.CancelOrderAsync(cancelMsg, cancellationToken)
CancelOrderGroupAsync
protected virtual ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)
result = baseUdpDialect.CancelOrderGroupAsync(cancelMsg, cancellationToken)
ChangePasswordAsync
protected virtual ValueTask ChangePasswordAsync(ChangePasswordMessage pwdMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ChangePasswordAsync(pwdMsg, cancellationToken)
Clone
public virtual IMessageAdapter Clone()
result = baseUdpDialect.Clone()

Cria uma cópia profunda de DataSeries

ConnectAsync
protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ConnectAsync(connectMsg, cancellationToken)
CreateOrderLogMarketDepthBuilder
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.

CreateParser
public abstract IUdpSettingsParser CreateParser()
result = baseUdpDialect.CreateParser()

Criar uma nova instância da classe IUdpSettingsParser.

Retorna: IUdpSettingsParser

DisconnectAsync
protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)
result = baseUdpDialect.DisconnectAsync(disconnectMsg, cancellationToken)
DisposeManaged
protected override void DisposeManaged()
baseUdpDialect.DisposeManaged()

Libertar recursos.

GetCandleArgs
public virtual IEnumerable<object> GetCandleArgs(Type candleType, SecurityId securityId, DateTime? from, DateTime? to)
result = baseUdpDialect.GetCandleArgs(candleType, securityId, from, to)
GetSupportedMarketDataTypesAsync
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.

IsAllDownloadingSupported
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.

IsSecurityRequired
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.

IsSupportCandlesPriceLevels
public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesPriceLevels(subscription)

Suporte a velas PriceLevels.

subscription
MarketDataMessage

Retorna: Verificar o resultado.

IsSupportCandlesUpdates
public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)
result = baseUdpDialect.IsSupportCandlesUpdates(subscription)

Suporte assinatura velas e atualizações ao vivo.

subscription
MarketDataMessage

Retorna: Verificar o resultado.

Load
public override void Load(SettingsStorage storage)
baseUdpDialect.Load(storage)

Carregar as configurações.

storage
Configuração do armazenamento.
LoadSettingsFromFile
public abstract void LoadSettingsFromFile(IDictionary<string, UdpFeedGroup> feeds)
baseUdpDialect.LoadSettingsFromFile(feeds)

Carregar as configurações do arquivo especificado.

feeds
Configuração do UDP.
MarketDataAsync
protected virtual ValueTask MarketDataAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = baseUdpDialect.MarketDataAsync(mdMsg, cancellationToken)
OrderStatusAsync
protected virtual ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)
result = baseUdpDialect.OrderStatusAsync(statusMsg, cancellationToken)
PortfolioLookupAsync
protected virtual ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)
result = baseUdpDialect.PortfolioLookupAsync(lookupMsg, cancellationToken)
RegisterOrderAsync
protected virtual ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
result = baseUdpDialect.RegisterOrderAsync(regMsg, cancellationToken)
ReplaceOrderAsync
protected virtual ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ReplaceOrderAsync(replaceMsg, cancellationToken)
ResetAsync
protected virtual ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)
result = baseUdpDialect.ResetAsync(resetMsg, cancellationToken)
Save
public override void Save(SettingsStorage storage)
baseUdpDialect.Save(storage)

Gravar as definições.

storage
Configuração do armazenamento.
SecurityLookupAsync
protected virtual ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = baseUdpDialect.SecurityLookupAsync(lookupMsg, cancellationToken)
SendInMessageAsync
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
SendOutErrorAsync
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
SendOutMessageAsync
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = baseUdpDialect.SendOutMessageAsync(message, cancellationToken)

Chamar o evento NewOutMessageAsync.

message
A mensagem.
cancellationToken
CancellationToken
SendSubscriptionReplyAsync
protected ValueTask SendSubscriptionReplyAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionReplyAsync(message, cancellationToken)

Enviar SubscriptionResponseMessage.

message
A mensagem de pedido.
cancellationToken
CancellationToken
SendSubscriptionResultAsync
protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)
result = baseUdpDialect.SendSubscriptionResultAsync(message, cancellationToken)

Enviar SubscriptionFinishedMessage@ ou SubscriptionOnlineMessage.

message
A mensagem de pedido.
cancellationToken
CancellationToken
TimeAsync
protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = baseUdpDialect.TimeAsync(timeMsg, cancellationToken)

Eventos

NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
baseUdpDialect.NewOutMessageAsync += handler

Novo evento de mensagem.