Class ConnectorHydraTask<TMessageAdapter>
Базовый источник, работающий через IMessageAdapter.
Implements
Inherited Members
Namespace: StockSharp.Hydra.Core
Assembly: StockSharp.Hydra.Core.dll
Syntax
public class ConnectorHydraTask<TMessageAdapter> : BaseHydraTask, IHydraTask, ILogReceiver, ILogSource, ICloneable<IHydraTask>, IPersistable, INotifyPropertyChanged, IScheduledTask, IMessageChannel, IDisposable, ICloneable<IMessageChannel>, ICloneable, IConnectorHydraTask where TMessageAdapter : class, IMessageAdapter
Type Parameters
Name | Description |
---|---|
TMessageAdapter | Тип подключения. |
Constructors
ConnectorHydraTask()
Создать ConnectorHydraTask<TMessageAdapter>.
Declaration
public ConnectorHydraTask()
Properties
Adapter
Адаптер сообщений.
Declaration
public TMessageAdapter Adapter { get; }
Property Value
Type | Description |
---|---|
TMessageAdapter |
CandlesBuildFrom
Поддерживаемые источники данных построения свечей.
Declaration
public override IEnumerable<Level1Fields> CandlesBuildFrom { get; }
Property Value
Type | Description |
---|---|
IEnumerable<Level1Fields> |
Overrides
CandlesFromDate
Стартовая дата закачки данных свечей.
Declaration
public Nullable<DateTime> CandlesFromDate { get; set; }
Property Value
Type | Description |
---|---|
Nullable<DateTime> |
CanTestConnect
Можно ли вызвать метод TestConnect(Action<Exception>).
Declaration
public override bool CanTestConnect { get; }
Property Value
Type | Description |
---|---|
Boolean |
Overrides
IsDownloadNews
Скачивать новости.
Declaration
public bool IsDownloadNews { get; set; }
Property Value
Type | Description |
---|---|
Boolean |
ResumeDownload
Resume download.
Declaration
public bool ResumeDownload { get; set; }
Property Value
Type | Description |
---|---|
Boolean |
SecurityLookupSupportType
Тип поиска инструмента.
Declaration
public override SecurityLookupSupportTypes SecurityLookupSupportType { get; }
Property Value
Type | Description |
---|---|
SecurityLookupSupportTypes |
Overrides
SupportedDataTypes
Поддерживаемые типы данных.
Declaration
public override IEnumerable<DataType> SupportedDataTypes { get; }
Property Value
Type | Description |
---|---|
IEnumerable<DataType> |
Overrides
SupportedDepths
Supported depths.
Declaration
public override IEnumerable<int> SupportedDepths { get; }
Property Value
Type | Description |
---|---|
IEnumerable<Int32> |
Overrides
TicksFromDate
Начальная дата загрузки тиков из подключения.
Declaration
public Nullable<DateTime> TicksFromDate { get; set; }
Property Value
Type | Description |
---|---|
Nullable<DateTime> |
UpdateSecurities
Обновлять инструменты при подключении.
Declaration
public bool UpdateSecurities { get; set; }
Property Value
Type | Description |
---|---|
Boolean |
Methods
DisposeManaged()
Освободить занятые ресурсы.
Declaration
protected override void DisposeManaged()
FinalizeTask()
Обработка окончания работы задачи.
Declaration
protected override void FinalizeTask()
Overrides
IsAllDownloadingSupported(DataType)
Доступно ли для указанного dataType
загрузка всех инструментов.
Declaration
public override bool IsAllDownloadingSupported(DataType dataType)
Parameters
Type | Name | Description |
---|---|---|
DataType | dataType | Тип данных. |
Returns
Type | Description |
---|---|
Boolean | Результат проверки. |
Overrides
Load(SettingsStorage)
Загрузить настройки.
Declaration
public override void Load(SettingsStorage storage)
Parameters
Type | Name | Description |
---|---|---|
Ecng.Serialization.SettingsStorage | storage | Хранилище настроек. |
Overrides
OnProcess()
Выполнить задачу.
Declaration
protected override TimeSpan OnProcess()
Returns
Type | Description |
---|---|
TimeSpan | Минимальный интервал, после окончания которого необходимо снова выполнить задачу. |
Overrides
OnStarting()
Действие при запуске загрузки данных.
Declaration
protected override void OnStarting()
Overrides
OnStopped()
Действие при остановке загрузки данных.
Declaration
protected override void OnStopped()
Overrides
Refresh(ISecurityStorage, SecurityLookupMessage, Action<Security>, Func<Boolean>)
Закачать новые инструменты.
Declaration
public override void Refresh(ISecurityStorage securityStorage, SecurityLookupMessage criteria, Action<Security> newSecurity, Func<bool> isCancelled)
Parameters
Type | Name | Description |
---|---|---|
ISecurityStorage | securityStorage | Хранилище информации об инструментах. |
SecurityLookupMessage | criteria | Сообщение поиска инструментов по заданному критерию. |
Action<Security> | newSecurity | Обработчик, через который будет передан новый инструмент. |
Func<Boolean> | isCancelled | Обработчик, возвращающий признак отмены поиска. |
Overrides
Save(SettingsStorage)
Сохранить настройки.
Declaration
public override void Save(SettingsStorage storage)
Parameters
Type | Name | Description |
---|---|---|
Ecng.Serialization.SettingsStorage | storage | Хранилище настроек. |
Overrides
TestConnect(Action<Exception>)
Произвести тестовое подключение.
Declaration
public override void TestConnect(Action<Exception> connectionChanged)
Parameters
Type | Name | Description |
---|---|---|
Action<Exception> | connectionChanged | Обработчик изменения состояния подключения. |
Overrides
Explicit Interface Implementations
IConnectorHydraTask.Adapter
Declaration
IMessageAdapter IConnectorHydraTask.Adapter { get; }
Returns
Type | Description |
---|---|
IMessageAdapter |
IMessageChannel.Clear()
Declaration
void IMessageChannel.Clear()
IMessageChannel.Close()
Declaration
void IMessageChannel.Close()
IMessageChannel.NewOutMessage
Declaration
event Action<Message> IMessageChannel.NewOutMessage
Returns
Type | Description |
---|---|
Action<Message> |
IMessageChannel.Open()
Declaration
void IMessageChannel.Open()
IMessageChannel.Resume()
Declaration
void IMessageChannel.Resume()
IMessageChannel.SendInMessage(Message)
Declaration
bool IMessageChannel.SendInMessage(Message message)
Parameters
Type | Name | Description |
---|---|---|
Message | message |
Returns
Type | Description |
---|---|
Boolean |
IMessageChannel.State
Declaration
ChannelStates IMessageChannel.State { get; }
Returns
Type | Description |
---|---|
ChannelStates |
IMessageChannel.StateChanged
Declaration
event Action IMessageChannel.StateChanged
Returns
Type | Description |
---|---|
Action |
IMessageChannel.Suspend()
Declaration
void IMessageChannel.Suspend()