Show / Hide Table of Contents

Class ConnectorHydraTask<TMessageAdapter>

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

Inheritance
Object
BaseLogSource
BaseLogReceiver
BaseHydraTask
ConnectorHydraTask<TMessageAdapter>
Implements
IHydraTask
ILogReceiver
ILogSource
Ecng.Common.ICloneable<IHydraTask>
Ecng.Serialization.IPersistable
INotifyPropertyChanged
IScheduledTask
IMessageChannel
IDisposable
Ecng.Common.ICloneable<IMessageChannel>
ICloneable
IConnectorHydraTask
Inherited Members
BaseHydraTask.SaveSecurity(Security)
BaseHydraTask.Init(Guid)
BaseHydraTask.Start()
BaseHydraTask.HandleError(Exception)
BaseHydraTask.Stop()
BaseHydraTask.RaiseStarted()
BaseHydraTask.RaiseStopped()
BaseHydraTask.CanProcess()
BaseHydraTask.SaveTicks(HydraTaskSecurity, IEnumerable<ExecutionMessage>)
BaseHydraTask.SaveTicks(Security, IEnumerable<ExecutionMessage>)
BaseHydraTask.SaveDepths(HydraTaskSecurity, IEnumerable<QuoteChangeMessage>)
BaseHydraTask.SaveDepths(Security, IEnumerable<QuoteChangeMessage>)
BaseHydraTask.SaveOrderLog(HydraTaskSecurity, IEnumerable<ExecutionMessage>)
BaseHydraTask.SaveOrderLog(Security, IEnumerable<ExecutionMessage>)
BaseHydraTask.SaveLevel1Changes(HydraTaskSecurity, IEnumerable<Level1ChangeMessage>)
BaseHydraTask.SaveLevel1Changes(Security, IEnumerable<Level1ChangeMessage>)
BaseHydraTask.SavePositionChanges(Security, IEnumerable<PositionChangeMessage>)
BaseHydraTask.SaveCandles(HydraTaskSecurity, IEnumerable<CandleMessage>)
BaseHydraTask.SaveCandles(Security, IEnumerable<CandleMessage>)
BaseHydraTask.SaveNews(IEnumerable<NewsMessage>)
BaseHydraTask.SaveBoardStates(IEnumerable<BoardStateMessage>)
BaseHydraTask.SaveTransactions(Security, IEnumerable<ExecutionMessage>)
BaseHydraTask.RaiseDataLoaded(Security, DataType, Nullable<DateTimeOffset>, Int32)
BaseHydraTask.NotifyPropertyChanged(String)
BaseHydraTask.GetWorkingSecurities()
BaseHydraTask.GetSecurity(SecurityId)
BaseHydraTask.Clone()
BaseHydraTask.IsEnabled
BaseHydraTask.IScheduledTask.CanStart
BaseHydraTask.IScheduledTask.CanStop
BaseHydraTask.WorkingTime
BaseHydraTask.Interval
BaseHydraTask.Drive
BaseHydraTask.StorageFormat
BaseHydraTask.DependFrom
BaseHydraTask.MaxErrorCount
BaseHydraTask.SupportedLevel1Fields
BaseHydraTask.IsDefault
BaseHydraTask.Title
BaseHydraTask.Name
BaseHydraTask.Icon
BaseHydraTask.EntityRegistry
BaseHydraTask.StorageRegistry
BaseHydraTask.NativeIdStorage
BaseHydraTask.ExchangeInfoProvider
BaseHydraTask.State
BaseHydraTask.Securities
BaseHydraTask.Started
BaseHydraTask.Stopped
BaseHydraTask.DataLoaded
BaseHydraTask.PropertyChanged
BaseLogReceiver.ILogReceiver.AddLog(LogMessage)
BaseLogSource.RaiseLog(LogMessage)
BaseLogSource.ToString()
BaseLogSource.Id
BaseLogSource.Parent
BaseLogSource.LogLevel
BaseLogSource.CurrentTime
BaseLogSource.IsRoot
BaseLogSource.ParentRemoved
BaseLogSource.Log
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
BaseHydraTask.CandlesBuildFrom

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
BaseHydraTask.CanTestConnect

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
BaseHydraTask.SecurityLookupSupportType

SupportedDataTypes

Поддерживаемые типы данных.

Declaration
public override IEnumerable<DataType> SupportedDataTypes { get; }
Property Value
Type Description
IEnumerable<DataType>
Overrides
BaseHydraTask.SupportedDataTypes

SupportedDepths

Supported depths.

Declaration
public override IEnumerable<int> SupportedDepths { get; }
Property Value
Type Description
IEnumerable<Int32>
Overrides
BaseHydraTask.SupportedDepths

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
BaseHydraTask.FinalizeTask()

IsAllDownloadingSupported(DataType)

Доступно ли для указанного dataType загрузка всех инструментов.

Declaration
public override bool IsAllDownloadingSupported(DataType dataType)
Parameters
Type Name Description
DataType dataType

Тип данных.

Returns
Type Description
Boolean

Результат проверки.

Overrides
BaseHydraTask.IsAllDownloadingSupported(DataType)

Load(SettingsStorage)

Загрузить настройки.

Declaration
public override void Load(SettingsStorage storage)
Parameters
Type Name Description
Ecng.Serialization.SettingsStorage storage

Хранилище настроек.

Overrides
BaseHydraTask.Load(SettingsStorage)

OnProcess()

Выполнить задачу.

Declaration
protected override TimeSpan OnProcess()
Returns
Type Description
TimeSpan

Минимальный интервал, после окончания которого необходимо снова выполнить задачу.

Overrides
BaseHydraTask.OnProcess()

OnStarting()

Действие при запуске загрузки данных.

Declaration
protected override void OnStarting()
Overrides
BaseHydraTask.OnStarting()

OnStopped()

Действие при остановке загрузки данных.

Declaration
protected override void OnStopped()
Overrides
BaseHydraTask.OnStopped()

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
BaseHydraTask.Refresh(ISecurityStorage, SecurityLookupMessage, Action<Security>, Func<Boolean>)

Save(SettingsStorage)

Сохранить настройки.

Declaration
public override void Save(SettingsStorage storage)
Parameters
Type Name Description
Ecng.Serialization.SettingsStorage storage

Хранилище настроек.

Overrides
BaseHydraTask.Save(SettingsStorage)

TestConnect(Action<Exception>)

Произвести тестовое подключение.

Declaration
public override void TestConnect(Action<Exception> connectionChanged)
Parameters
Type Name Description
Action<Exception> connectionChanged

Обработчик изменения состояния подключения.

Overrides
BaseHydraTask.TestConnect(Action<Exception>)

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

IHydraTask
ILogReceiver
ILogSource
Ecng.Common.ICloneable<>
Ecng.Serialization.IPersistable
System.ComponentModel.INotifyPropertyChanged
IScheduledTask
IMessageChannel
System.IDisposable
Ecng.Common.ICloneable<>
System.ICloneable
IConnectorHydraTask

Extension Methods

Paths.Serialize<T>(T, String)
Paths.Serialize<T>(T)
Extensions.TryGet<TMessage, TChange>(TMessage, TChange)
Extensions.TryGetDecimal<TMessage, TChange>(TMessage, TChange)
Extensions.Add<TMessage, TChange>(TMessage, TChange, Object)
Extensions.Add<TMessage, TChange>(TMessage, TChange, Decimal)
Extensions.Add<TMessage, TChange>(TMessage, TChange, Int32)
Extensions.Add<TMessage, TChange>(TMessage, TChange, Int64)
Extensions.Add<TMessage, TChange>(TMessage, TChange, SecurityStates)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<SecurityStates>)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, String)
Extensions.Add<TMessage, TChange>(TMessage, TChange, Sides)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<Sides>)
Extensions.Add<TMessage, TChange>(TMessage, TChange, CurrencyTypes)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<CurrencyTypes>)
Extensions.Add<TMessage, TChange>(TMessage, TChange, PortfolioStates)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<PortfolioStates>)
Extensions.Add<TMessage, TChange>(TMessage, TChange, DateTimeOffset)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<DateTimeOffset>)
Extensions.Add<TMessage, TChange>(TMessage, TChange, Boolean)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<Boolean>)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Decimal, Boolean)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<Decimal>, Boolean)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Int32, Boolean)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<Int32>, Boolean)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Int64, Boolean)
Extensions.TryAdd<TMessage, TChange>(TMessage, TChange, Nullable<Int64>, Boolean)
EditorExtensions.ToItemsSource(Object, Type, Nullable<Boolean>, Nullable<ListSortDirection>, Func<IItemsSourceItem, Boolean>, Func<Object, String>, Func<Object, String>)
XamlHelper.WpfCast<T>(Object)
XamlHelper.CopyToClipboard<T>(T)
XamlHelper.EnsureUIThread(Object)
☀
☾
In This Article
Back to top
Copyright © StockSharp.
☀
☾