Connector
Класс для создания подключений к торговым системам.
Наследует: BaseLogReceiver
Реализует: IConnector, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, IMarketDataProvider, ITransactionProvider, ISecurityProvider, ISecurityMessageProvider, ISubscriptionProvider, ITimeProvider, IPortfolioProvider, IPositionProvider
Конструкторы
public Connector(ISecurityStorage securityStorage, IPositionStorage positionStorage, IExchangeInfoProvider exchangeInfoProvider, IStorageRegistry storageRegistry, ISnapshotRegistry snapshotRegistry, IStorageBuffer buffer, bool initAdapter, bool initChannels)
connector = Connector(securityStorage, positionStorage, exchangeInfoProvider, storageRegistry, snapshotRegistry, buffer, initAdapter, initChannels)
Инициализирует новый экземпляр Connector.
- securityStorage
- Хранение метаинформации о финансовых инструментах.
- positionStorage
- Хранение позиций.
- exchangeInfoProvider
- Поставщик бирж и торговых площадок.
- storageRegistry
- Хранение рыночных данных.
- snapshotRegistry
- Реестр хранилища снимков.
- buffer
- Буфер хранения.
- initAdapter
- Инициализируйте адаптер корзины.
- initChannels
- Инициализируйте каналы.
Свойства
public BasketMessageAdapter Adapter { get; protected set; }
value = connector.Adapter
connector.Adapter = value
Адаптер сообщений.
public IBasketSecurityProcessorProvider BasketSecurityProcessorProvider { get; set; }
value = connector.BasketSecurityProcessorProvider
connector.BasketSecurityProcessorProvider = value
Поставщик процессоров финансовых инструментов корзины.
public Subscription BoardLookup { get; }
value = connector.BoardLookup
Получить глобальную подписку на ExchangeBoard lookup.
public bool CanConnect { get; }
value = connector.CanConnect
Определяет, что connector готов к установлению соединения.
public bool CheckSteps { get; set; }
value = connector.CheckSteps
connector.CheckSteps = value
Проверить цену и объем они умножают на шаг.
public ICommissionManager CommissionManager { get; set; }
value = connector.CommissionManager
connector.CommissionManager = value
Менеджер по расчету комиссионных.
public ConnectionStates ConnectionState { get; private set; }
value = connector.ConnectionState
connector.ConnectionState = value
Состояние соединения.
public Subscription DataTypeLookup { get; }
value = connector.DataTypeLookup
Получить глобальную подписку на DataTypeInfoMessage lookup.
public int ErrorCount { get; private set; }
value = connector.ErrorCount
connector.ErrorCount = value
Количество ошибок, которые были допущены в результате ошибки.
public IEnumerable<ExchangeBoard> ExchangeBoards { get; }
value = connector.ExchangeBoards
Список фондовых досок.
public IExchangeInfoProvider ExchangeInfoProvider { get; }
value = connector.ExchangeInfoProvider
Поставщик бирж и торговых площадок.
public IMessageChannel InMessageChannel { get; protected set; }
value = connector.InMessageChannel
connector.InMessageChannel = value
Введите канал сообщений.
public IMessageAdapterWrapper InnerAdapter { get; set; }
value = connector.InnerAdapter
connector.InnerAdapter = value
Внутренний адаптер сообщений.
public bool IsAutoUnSubscribeOnDisconnect { get; set; }
value = connector.IsAutoUnSubscribeOnDisconnect
connector.IsAutoUnSubscribeOnDisconnect = value
Отправьте отписаться по команде отключения.
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }
value = connector.IsRestoreSubscriptionOnNormalReconnect
connector.IsRestoreSubscriptionOnNormalReconnect = value
Восстановить подписку на Reconnect.
public ILatencyManager LatencyManager { get; set; }
value = connector.LatencyManager
connector.LatencyManager = value
Менеджер расчета задержки регистрации заказов.
public ISet<MessageTypes> LookupMessagesOnConnect { get; }
value = connector.LookupMessagesOnConnect
public IMessageAdapter MarketDataAdapter { get; private set; }
value = connector.MarketDataAdapter
connector.MarketDataAdapter = value
Адаптер рыночных данных.
public virtual TimeSpan MarketTimeChangedInterval { get; set; }
value = connector.MarketTimeChangedInterval
connector.MarketTimeChangedInterval = value
TimeMessage сообщение генерирует Интервал. По умолчанию 10 миллисекунд.
public Subscription OrderLookup { get; }
value = connector.OrderLookup
Получить глобальную подписку на поиск заказа.
public int OrdersKeepCount { get; set; }
value = connector.OrdersKeepCount
connector.OrdersKeepCount = value
Количество заказов на хранение. По умолчанию 1000. Если значение установлено на MaxValue, то заказы удаляться не будут. Если значение установлено на 0, то заказы храниться не будут.
public IMessageChannel OutMessageChannel { get; protected set; }
value = connector.OutMessageChannel
connector.OutMessageChannel = value
Канал исходящих сообщений.
public bool OverrideSecurityData { get; set; }
value = connector.OverrideSecurityData
connector.OverrideSecurityData = value
Переопределить предыдущие данные финансового инструмента новыми значениями.
public IPnLManager PnLManager { get; set; }
value = connector.PnLManager
connector.PnLManager = value
Менеджер прибылей-убытков.
public Subscription PortfolioLookup { get; }
value = connector.PortfolioLookup
Получить глобальную подписку на поиск портфолио.
public virtual IEnumerable<Portfolio> Portfolios { get; }
value = connector.Portfolios
Список портфелей.
public IEnumerable<Position> Positions { get; }
value = connector.Positions
Список позиций.
public IPositionStorage PositionStorage { get; }
value = connector.PositionStorage
Хранение позиций.
public virtual IRiskManager RiskManager { get; set; }
value = connector.RiskManager
connector.RiskManager = value
Менеджер по контролю рисков.
public IEnumerable<Security> Securities { get; }
value = connector.Securities
Список инструментов.
public SecurityIdGenerator SecurityIdGenerator { get; set; }
value = connector.SecurityIdGenerator
connector.SecurityIdGenerator = value
Генератор идентификаторов инструментов Id.
public Subscription SecurityLookup { get; }
value = connector.SecurityLookup
Получить глобальную подписку на поиск финансовых инструментов.
public ISecurityStorage SecurityStorage { get; }
value = connector.SecurityStorage
Хранение метаинформации о финансовых инструментах.
public ISlippageManager SlippageManager { get; set; }
value = connector.SlippageManager
connector.SlippageManager = value
Менеджер проскальзывания.
public ISnapshotRegistry SnapshotRegistry { get; private set; }
value = connector.SnapshotRegistry
connector.SnapshotRegistry = value
Реестр хранилища снимков.
public StorageMetaInfoMessageAdapter StorageAdapter { get; private set; }
value = connector.StorageAdapter
connector.StorageAdapter = value
Адаптер для хранения.
public IStorageRegistry StorageRegistry { get; }
value = connector.StorageRegistry
Хранение рыночных данных.
public IEnumerable<Subscription> Subscriptions { get; }
value = connector.Subscriptions
Список подписок.
public ISet<Subscription> SubscriptionsOnConnect { get; }
value = connector.SubscriptionsOnConnect
Отправляйте подписки на Connect.
public bool SupportAssociatedSecurity { get; set; }
value = connector.SupportAssociatedSecurity
connector.SupportAssociatedSecurity = value
Используйте AssociatedSecurityAdapter.
public bool SupportBasketSecurities { get; set; }
value = connector.SupportBasketSecurities
connector.SupportBasketSecurities = value
Используйте BasketSecurityMessageAdapter.
public bool SupportFilteredMarketDepth { get; set; }
value = connector.SupportFilteredMarketDepth
connector.SupportFilteredMarketDepth = value
Используйте FilteredMarketDepthAdapter.
public bool SupportLevel1DepthBuilder { get; set; }
value = connector.SupportLevel1DepthBuilder
connector.SupportLevel1DepthBuilder = value
Используйте Level1DepthBuilderAdapter.
public virtual bool SupportSnapshots { get; set; }
value = connector.SupportSnapshots
connector.SupportSnapshots = value
Используйте SnapshotHolderMessageAdapter.
public bool TimeChange { get; set; }
value = connector.TimeChange
connector.TimeChange = value
Периодически добавляем MarketTimeChangedInterval значение CurrentTime.
public IMessageAdapter TransactionAdapter { get; private set; }
value = connector.TransactionAdapter
connector.TransactionAdapter = value
Трансакционный адаптер.
public IdGenerator TransactionIdGenerator { get; set; }
value = connector.TransactionIdGenerator
connector.TransactionIdGenerator = value
Генератор идентификаторов транзакций, используемый для внутренней маршрутизации подписки на ребенка, должен быть синхронизирован с генератором родительского адаптера.
public virtual bool UnsubscribeOnDisconnect { get; }
value = connector.UnsubscribeOnDisconnect
Отправьте отписаться на отключении.
public bool UpdatePortfolioByChange { get; set; }
value = connector.UpdatePortfolioByChange
connector.UpdatePortfolioByChange = value
Обновлять поля Портфолио при появлении сообщения PositionChangeMessage. По умолчанию включен.
public bool UpdateSecurityByDefinition { get; set; }
value = connector.UpdateSecurityByDefinition
connector.UpdateSecurityByDefinition = value
Обновлять поля финансовых инструментов при появлении сообщения SecurityMessage. По умолчанию включен.
public bool UpdateSecurityByLevel1 { get; set; }
value = connector.UpdateSecurityByLevel1
connector.UpdateSecurityByLevel1 = value
Обновлять поля финансовых инструментов при появлении сообщения Level1ChangeMessage. По умолчанию включен.
public bool UpdateSecurityLastQuotes { get; set; }
value = connector.UpdateSecurityLastQuotes
connector.UpdateSecurityLastQuotes = value
Обновлять LastTick, BestBid, BestAsk при каждом обновлении книги заказов и/или сделок. По умолчанию включен.
Методы
public void CancelOrder(Order order)
connector.CancelOrder(order)
Отмените заказ.
- order
- Заказ, который следует отменить.
public ValueTask CancelOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.CancelOrderAsync(order, cancellationToken)
Отмените заказ асинхронно.
- order
- Приказ об отмене.
- cancellationToken
- CancellationToken
public void CancelOrders(bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType, long? transactionId)
connector.CancelOrders(isStopOrder, portfolio, direction, board, security, securityType, transactionId)
Отмена заказов по фильтру.
- isStopOrder
- , если отменить только стоп-ордеры, - если обычные ордера, - оба.
- portfolio
- Портфолио. Если значение равно , то портфель не соответствует фильтру отмены ордеров.
- direction
- Сторона заказа. Если значение равно , направление не используется.
- board
- Торговая доска. Если значение равно , то доска не соответствует фильтру отмены ордеров.
- security
- Инструмент. Если значение равно , то инструмент не соответствует фильтру отмены ордеров.
- securityType
- тип финансового инструмента. Если значение равно , тип не используется.
- transactionId
- Идентификатор транзакции отмены заказа.
public ValueTask CancelOrdersAsync(bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType, long? transactionId, CancellationToken cancellationToken)
result = connector.CancelOrdersAsync(isStopOrder, portfolio, direction, board, security, securityType, transactionId, cancellationToken)
Отменяйте заказы по фильтру асинхронно.
- isStopOrder
- , если отменить только стоп-ордеры, - если обычные ордера, - оба.
- portfolio
- Портфолио. Если значение равно , то портфель не соответствует фильтру отмены ордеров.
- direction
- Сторона заказа. Если значение равно , направление не используется.
- board
- Торговая доска. Если значение равно , то доска не соответствует фильтру отмены ордеров.
- security
- Инструмент. Если значение равно , то инструмент не соответствует фильтру отмены ордеров.
- securityType
- тип финансового инструмента. Если значение равно , тип не используется.
- transactionId
- Идентификатор транзакции отмены заказа.
- cancellationToken
- CancellationToken
public ValueTask ChangePasswordAsync(SecureString newPassword, CancellationToken cancellationToken)
result = connector.ChangePasswordAsync(newPassword, cancellationToken)
Сменить пароль.
- newPassword
- Новый пароль.
- cancellationToken
- CancellationToken
public virtual ValueTask ClearCacheAsync(CancellationToken cancellationToken)
result = connector.ClearCacheAsync(cancellationToken)
Очистить кэш.
protected string CreateSecurityId(string secCode, string boardCode)
result = connector.CreateSecurityId(secCode, boardCode)
Создайте финансовый инструмент Id.
- secCode
- SecurityCode.
- boardCode
- BoardCode.
Возвращает: Идентификатор финансового инструмента.
protected override void DisposeManaged()
connector.DisposeManaged()
Освободить выделенные ресурсы. В частности, отключиться от торговой системы через Disconnect.
public void EditOrder(Order order, Order changes)
connector.EditOrder(order, changes)
Отредактируйте заказ.
- order
- Заказ.
- changes
- Изменения в заказе.
public ValueTask EditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.EditOrderAsync(order, changes, cancellationToken)
Отредактируйте заказ асинхронно.
- order
- Заказ на редактирование.
- changes
- Порядок изменения с новыми значениями.
- cancellationToken
- CancellationToken
public IEnumerable<Level1Fields> GetLevel1Fields(Security security)
result = connector.GetLevel1Fields(security)
Получить набор доступных полей Level1Fields, по которым есть рыночные данные по инструменту.
- security
- финансовый инструмент.
Возвращает: Возможные поля.
public Portfolio GetPortfolio(string name)
result = connector.GetPortfolio(name)
Получить портфолио по кодовому имени.
- name
- Кодовое название портфеля.
Возвращает: Приобретенное портфолио. Если портфолио по заданным критериям отсутствует, возвращается.
public Position GetPosition(Portfolio portfolio, Security security, string strategyId, Sides? side, string clientCode, string depoName, TPlusLimits? limitType)
result = connector.GetPosition(portfolio, security, strategyId, side, clientCode, depoName, limitType)
Получить позицию по портфелю и инструменту.
- portfolio
- Портфель, в котором должна быть найдена позиция.
- security
- Инструмент, на котором должна быть найдена позиция.
- strategyId
- Идентификатор стратегии.
- side
- Сторона.
- clientCode
- Клиентский код.
- depoName
- Название депозитария, в котором физически расположены акции. По умолчанию передается пустая строка, означающая суммарную позицию по всем депозитариям.
- limitType
- Limit type for Т+ market.
Возвращает: Позиция.
public Security GetSecurity(SecurityId securityId)
result = connector.GetSecurity(securityId)
Получить финансовый инструмент по идентификатору.
- securityId
- идентификатор финансового инструмента.
Возвращает: финансовый инструмент.
private ValueTask<Security> GetSecurityAsync(SecurityId id, Func<Security, bool> changeSecurity, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(id, changeSecurity, cancellationToken)
Получить прибор по коду.
- id
- идентификатор финансового инструмента.
- changeSecurity
- Хендлер меняет инструмент. Он возвращается, если инструмент был изменен и необходимо вызвать SecurityReceived.
- cancellationToken
- CancellationToken
Возвращает: финансовый инструмент.
public ValueTask<Security> GetSecurityAsync(SecurityId securityId, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(securityId, cancellationToken)
Получить финансовый инструмент по идентификатору.
- securityId
- идентификатор финансового инструмента.
- cancellationToken
- CancellationToken
Возвращает: финансовый инструмент.
public SecurityId GetSecurityId(Security security)
result = connector.GetSecurityId(security)
Получите SecurityId.
- security
- финансовый инструмент.
Возвращает: идентификатор финансового инструмента.
public object GetSecurityValue(Security security, Level1Fields field)
result = connector.GetSecurityValue(security, field)
Получить стоимость рыночных данных по инструменту.
- security
- финансовый инструмент.
- field
- Поле рыночных данных.
Возвращает: Значение поля. Если данных нет, они будут возвращены.
private ValueTask InitNewOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.InitNewOrderAsync(order, cancellationToken)
Инициализируйте заказ на регистрацию (идентификатор транзакции и т. д.).
- order
- Новый заказ.
- cancellationToken
- CancellationToken
public bool? IsOrderEditable(Order order)
result = connector.IsOrderEditable(order)
Определяет указанный заказ, можно редактировать с помощью Order).
- order
- Заказ.
Возвращает: если заказ доступен для редактирования, порядок не может быть изменен, что означает отсутствие информации.
public bool? IsOrderReplaceable(Order order)
result = connector.IsOrderReplaceable(order)
Определяет указанный порядок, может быть заменен на Order).
- order
- Заказ.
Возвращает: если заказ сменный, заказ не может быть заменен, значит нет информации.
public override void Load(SettingsStorage storage)
connector.Load(storage)
Загрузить настройки.
- storage
- Хранилище настроек.
public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
result = connector.LookupByIdAsync(id, cancellationToken)
Получить инструмент по идентификатору.
- id
- идентификатор финансового инструмента.
- cancellationToken
- CancellationToken
Возвращает: Приобретенный инструмент. Если нет инструмента по заданным критериям, возвращается.
public Portfolio LookupByPortfolioName(string name)
result = connector.LookupByPortfolioName(name)
Получить портфолио по кодовому имени.
- name
- Кодовое название портфеля.
Возвращает: Приобретенное портфолио. Если портфолио по заданным критериям отсутствует, возвращается.
protected ValueTask OnCancelOrderAsync(Order order, long transactionId, CancellationToken cancellationToken)
result = connector.OnCancelOrderAsync(order, transactionId, cancellationToken)
Отмените заказ.
- order
- Приказ об отмене.
- transactionId
- Идентификатор транзакции отмены заказа.
- cancellationToken
- CancellationToken
protected ValueTask OnCancelOrdersAsync(long transactionId, CancellationToken cancellationToken, bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType)
result = connector.OnCancelOrdersAsync(transactionId, cancellationToken, isStopOrder, portfolio, direction, board, security, securityType)
Отмена заказов по фильтру.
- transactionId
- Идентификатор транзакции отмены заказа.
- cancellationToken
- Токен отмены.
- isStopOrder
- , если отменить только стоп-ордеры, - если обычные ордера, - оба.
- portfolio
- Портфолио. Если значение равно , то портфель не соответствует фильтру отмены ордеров.
- direction
- Сторона заказа. Если значение равно , направление не используется.
- board
- Торговая доска. Если значение равно , то доска не соответствует фильтру отмены ордеров.
- security
- Инструмент. Если значение равно , то инструмент не соответствует фильтру отмены ордеров.
- securityType
- тип финансового инструмента. Если значение равно , тип не используется.
protected virtual ValueTask OnConnectAsync(CancellationToken cancellationToken)
result = connector.OnConnectAsync(cancellationToken)
Подключитесь к торговой системе.
protected virtual ValueTask OnDisconnectAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectAsync(cancellationToken)
Отключиться от торговой системы.
protected ValueTask OnEditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.OnEditOrderAsync(order, changes, cancellationToken)
Отредактируйте заказ.
- order
- Заказ.
- changes
- Изменения в заказе.
- cancellationToken
- CancellationToken
protected virtual ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)
result = connector.OnProcessMessage(message, cancellationToken)
Обработать сообщение.
- message
- Сообщение.
- cancellationToken
- CancellationToken
protected ValueTask OnRegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.OnRegisterOrderAsync(order, cancellationToken)
Зарегистрируйте новый заказ.
- order
- Детали регистрации.
- cancellationToken
- CancellationToken
protected ValueTask OnReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.OnReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Перерегистрируйте заказ.
- oldOrder
- Отмена заказа.
- newOrder
- Новый порядок регистрации.
- cancellationToken
- CancellationToken
private void RaiseConnected()
connector.RaiseConnected()
Чтобы вызвать событие Connected.
private void RaiseConnectedEx(IMessageAdapter adapter)
connector.RaiseConnectedEx(adapter)
Чтобы вызвать событие ConnectedEx.
- adapter
- Адаптер, инициированное событие.
private void RaiseConnectionError(Exception exception)
connector.RaiseConnectionError(exception)
Чтобы вызвать событие ConnectionError.
- exception
- Ошибка подключения.
private void RaiseConnectionErrorEx(IMessageAdapter adapter, Exception exception)
connector.RaiseConnectionErrorEx(adapter, exception)
Чтобы вызвать событие ConnectionErrorEx.
- adapter
- Адаптер, инициированное событие.
- exception
- Ошибка подключения.
private void RaiseCurrentTimeChanged(TimeSpan diff)
connector.RaiseCurrentTimeChanged(diff)
Чтобы вызвать событие CurrentTimeChanged.
- diff
- Разница во времени с момента последнего вызова события. В первый раз событие передает нулевое значение.
private void RaiseDisconnected()
connector.RaiseDisconnected()
Чтобы вызвать событие Disconnected.
private void RaiseDisconnectedEx(IMessageAdapter adapter)
connector.RaiseDisconnectedEx(adapter)
Чтобы вызвать событие DisconnectedEx.
- adapter
- Адаптер, инициированное событие.
protected void RaiseError(Exception exception)
connector.RaiseError(exception)
Чтобы вызвать событие Error.
- exception
- Ошибка обработки данных.
private void RaiseLookupPortfoliosResult(PortfolioLookupMessage message, Exception error, Portfolio[] newPortfolios)
connector.RaiseLookupPortfoliosResult(message, error, newPortfolios)
Чтобы вызвать событие LookupPortfoliosResult.
- message
- Сообщение.
- error
- Ошибка операции поиска. Значение будет таким, если операция завершится успешно.
- newPortfolios
- Нашел портфолио.
private void RaiseLookupSecuritiesResult(SecurityLookupMessage message, Exception error, Security[] newSecurities)
connector.RaiseLookupSecuritiesResult(message, error, newSecurities)
Чтобы вызвать событие LookupSecuritiesResult.
- message
- Сообщение.
- error
- Ошибка операции поиска. Значение будет таким, если операция завершится успешно.
- newSecurities
- Найдены инструменты.
protected virtual void RaiseSubscriptionFailed(Subscription subscription, Exception error, bool isSubscribe)
connector.RaiseSubscriptionFailed(subscription, error, isSubscribe)
public void RegisterOrder(Order order)
connector.RegisterOrder(order)
Зарегистрируйте новый заказ.
- order
- Детали регистрации.
public ValueTask RegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.RegisterOrderAsync(order, cancellationToken)
Зарегистрируйте новый заказ асинхронно.
- order
- Детали регистрации.
- cancellationToken
- CancellationToken
public void ReRegisterOrder(Order oldOrder, Order newOrder)
connector.ReRegisterOrder(oldOrder, newOrder)
Перерегистрируйте заказ.
- oldOrder
- Отмена заказа.
- newOrder
- Новый порядок регистрации.
public ValueTask ReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.ReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Перерегистрируйте заказ асинхронно.
- oldOrder
- Отмена заказа.
- newOrder
- Новый порядок регистрации.
- cancellationToken
- CancellationToken
public override void Save(SettingsStorage storage)
connector.Save(storage)
Сохраните настройки.
- storage
- Хранилище настроек.
public void SendInMessage(Message message)
connector.SendInMessage(message)
Отправьте сообщение из серверного модуля подключенным клиентам.
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendInMessageAsync(message, cancellationToken)
Обрабатывает общее сообщение асинхронно.
- message
- Сообщение для обработки.
- cancellationToken
- CancellationToken
public void SendOutError(Exception error)
connector.SendOutError(error)
Отправить сообщение об ошибке.
- error
- Подробности ошибки.
public ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = connector.SendOutErrorAsync(error, cancellationToken)
Отправить сообщение об ошибке.
- error
- Подробности ошибки.
- cancellationToken
- CancellationToken
public void SendOutMessage(Message message)
connector.SendOutMessage(message)
Отправить исходящее сообщение.
- message
- Сообщение.
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendOutMessageAsync(message, cancellationToken)
Отправка исходящего сообщения (изменение состояния, заказа и т.п.).
- message
- Сообщение.
- cancellationToken
- CancellationToken
public void Subscribe(Subscription subscription)
connector.Subscribe(subscription)
Подпишитесь.
- subscription
- Подписка.
public void UnSubscribe(Subscription subscription)
connector.UnSubscribe(subscription)
Отписаться.
- subscription
- Подписка.
События
public event Action<Subscription, ExchangeBoard> BoardReceived
connector.BoardReceived += handler
ExchangeBoard получено.
public event Action<Subscription, ICandleMessage> CandleReceived
connector.CandleReceived += handler
ICandleMessage получено.
public event Action<long, Exception> ChangePasswordResult
connector.ChangePasswordResult += handler
Результат смены пароля.
public event Action<IMessageAdapter> ConnectedEx
connector.ConnectedEx += handler
Подключено.
public event Action<Exception> ConnectionError
connector.ConnectionError += handler
Ошибка подключения (например, соединение было прервано сервером).
public event Action<IMessageAdapter, Exception> ConnectionErrorEx
connector.ConnectionErrorEx += handler
Ошибка подключения (например, соединение было прервано сервером).
public event Action<IMessageAdapter> ConnectionLost
connector.ConnectionLost += handler
Соединение потеряно.
public event Action<IMessageAdapter> ConnectionRestored
connector.ConnectionRestored += handler
Соединение восстановлено.
public event Action<TimeSpan> CurrentTimeChanged
connector.CurrentTimeChanged += handler
Время сервера изменилось CurrentTime. Прошла разница во времени с момента последнего вызова события. В первый раз событие передает значение Zero.
public event Action<Subscription, DataType> DataTypeReceived
connector.DataTypeReceived += handler
DataType получено.
public event Action<IMessageAdapter> DisconnectedEx
connector.DisconnectedEx += handler
Отключено.
public event Action<Subscription, Level1ChangeMessage> Level1Received
connector.Level1Received += handler
Level1ChangeMessage получено.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult
connector.LookupPortfoliosResult += handler
Результат поиска PortfolioLookupMessage получен.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult2
connector.LookupPortfoliosResult2 += handler
Результат поиска PortfolioLookupMessage получен.
public event Action<SecurityLookupMessage, IEnumerable<Security>, Exception> LookupSecuritiesResult
connector.LookupSecuritiesResult += handler
Результат поиска SecurityLookupMessage получен.
public event Action<SecurityLookupMessage, IEnumerable<Security>, IEnumerable<Security>, Exception> LookupSecuritiesResult2
connector.LookupSecuritiesResult2 += handler
Результат поиска SecurityLookupMessage получен.
public event Action<long> MassOrderCanceled
connector.MassOrderCanceled += handler
Событие массовой отмены заказов.
public event Action<long, DateTime> MassOrderCanceled2
connector.MassOrderCanceled2 += handler
Событие массовой отмены заказов.
public event Action<long, Exception> MassOrderCancelFailed
connector.MassOrderCancelFailed += handler
Событие ошибок массовой отмены заказов.
public event Action<long, Exception, DateTime> MassOrderCancelFailed2
connector.MassOrderCancelFailed2 += handler
Событие ошибок массовой отмены заказов.
public event Action<MyTrade> NewMyTrade
connector.NewMyTrade += handler
Собственная торговля получена.
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
connector.NewOutMessageAsync += handler
Новое событие сообщения.
public event Action<Portfolio> NewPortfolio
connector.NewPortfolio += handler
Получено новое портфолио.
public event Action<Position> NewPosition
connector.NewPosition += handler
Получена новая должность.
public event Action<Subscription, News> NewsReceived
connector.NewsReceived += handler
Новости получены.
public event Action<Subscription, IOrderBookMessage> OrderBookReceived
connector.OrderBookReceived += handler
IOrderBookMessage получено.
public event Action<OrderFail> OrderCancelFailed
connector.OrderCancelFailed += handler
Событие ошибки отмены заказа.
public event Action<Subscription, OrderFail> OrderCancelFailReceived
connector.OrderCancelFailReceived += handler
OrderFail событие отмены.
public event Action<Order> OrderChanged
connector.OrderChanged += handler
Заказ изменен (отменен, сопоставлен).
public event Action<long, Order> OrderEdited
connector.OrderEdited += handler
Заказ) событие результата успеха.
public event Action<long, OrderFail> OrderEditFailed
connector.OrderEditFailed += handler
Заказ) событие результата ошибки.
public event Action<Subscription, OrderFail> OrderEditFailReceived
connector.OrderEditFailReceived += handler
OrderFail событие издания.
public event Action<Subscription, IOrderLogMessage> OrderLogReceived
connector.OrderLogReceived += handler
IOrderLogMessage получено.
public event Action<Subscription, Order> OrderReceived
connector.OrderReceived += handler
Заказ получен.
public event Action<OrderFail> OrderRegisterFailed
connector.OrderRegisterFailed += handler
Событие ошибки регистрации заказа.
public event Action<Subscription, OrderFail> OrderRegisterFailReceived
connector.OrderRegisterFailReceived += handler
OrderFail событие регистрации.
public event Action<Subscription, MyTrade> OwnTradeReceived
connector.OwnTradeReceived += handler
MyTrade получено.
public event Action<Portfolio> PortfolioChanged
connector.PortfolioChanged += handler
Портфолио изменено.
public event Action<Subscription, Portfolio> PortfolioReceived
connector.PortfolioReceived += handler
Портфолио получено.
public event Action<Position> PositionChanged
connector.PositionChanged += handler
Позиция изменилась.
public event Action<Subscription, Position> PositionReceived
connector.PositionReceived += handler
Должность получена.
public event Action<Subscription, Security> SecurityReceived
connector.SecurityReceived += handler
финансовый инструмент получен.
public event Action<Subscription, Exception, bool> SubscriptionFailed
connector.SubscriptionFailed += handler
Подписка не удалась.
public event Action<Subscription> SubscriptionOnline
connector.SubscriptionOnline += handler
Подписка онлайн.
public event Action<Subscription, object> SubscriptionReceived
connector.SubscriptionReceived += handler
Полученная ценность.
public event Action<Subscription> SubscriptionStarted
connector.SubscriptionStarted += handler
Подписка запущена.
public event Action<Subscription, Exception> SubscriptionStopped
connector.SubscriptionStopped += handler
Подписка остановлена.
public event Action<Subscription, ITickTradeMessage> TickTradeReceived
connector.TickTradeReceived += handler
ITickTradeMessage получено.
public event Action<Security, IEnumerable<KeyValuePair<Level1Fields, object>>, DateTime, DateTime> ValuesChanged
connector.ValuesChanged += handler
финансовый инструмент изменился.