Class ConnectorHydraTask<TMessageAdapter>

Базовый источник, работающий через IMessageAdapter.

Inheritance
Object
BaseLogSource
BaseLogReceiver
BaseHydraTask
ConnectorHydraTask<TMessageAdapter>
Implements
Ecng.Common.ICloneable<IHydraTask>
Ecng.Serialization.IPersistable
Ecng.Common.ICloneable<IMessageChannel>
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()

Implements

Ecng.Common.ICloneable<>
Ecng.Serialization.IPersistable
Ecng.Common.ICloneable<>

Extension Methods