Class HydraTaskStorage
- Namespace
- StockSharp.Hydra.Core
- Assembly
- StockSharp.Hydra.Core.dll
Hydra tasks settings storage.
public class HydraTaskStorage : BaseLogReceiver, IPersistable, ILogReceiver, ILogSource, IDisposable
- Inheritance
-
HydraTaskStorage
- Implements
-
IPersistable
- Inherited Members
- Extension Methods
Constructors
HydraTaskStorage(string)
Initializes a new instance of the HydraTaskStorage.
public HydraTaskStorage(string path)
Parameters
path
stringPath to storage.
Properties
DelayAction
The time delayed action.
public DelayAction DelayAction { get; set; }
Property Value
- DelayAction
Methods
Add(Guid, IEnumerable<HydraTaskSecurity>)
Add securities into the task.
public void Add(Guid taskId, IEnumerable<HydraTaskSecurity> securities)
Parameters
taskId
GuidTask id.
securities
IEnumerable<HydraTaskSecurity>Securities.
Delete(Guid)
Delete task settings.
public void Delete(Guid taskId)
Parameters
taskId
GuidTask id.
Delete(Guid, IEnumerable<HydraTaskSecurity>)
Delete securities from the task.
public void Delete(Guid taskId, IEnumerable<HydraTaskSecurity> securities)
Parameters
taskId
GuidTask id.
securities
IEnumerable<HydraTaskSecurity>Securities.
DeleteAll(Guid)
Delete all securities from the task.
public void DeleteAll(Guid taskId)
Parameters
taskId
GuidTask id.
Init()
Initialize the storage.
public void Init()
Load(ILogReceiver, CancellationToken)
Load all tasks.
public Task<IDictionary<HydraTaskInfo, HydraTaskSecurity[]>> Load(ILogReceiver logs, CancellationToken cancellationToken)
Parameters
logs
ILogReceiverLogs.
cancellationToken
CancellationToken
Returns
- Task<IDictionary<HydraTaskInfo, HydraTaskSecurity[]>>
Tasks.
Reset()
Reset all settings.
public void Reset()
Save(HydraTaskInfo)
Update task settings.
public void Save(HydraTaskInfo info)
Parameters
info
HydraTaskInfoTask settings.
Update(Guid, IEnumerable<HydraTaskSecurity>)
Update securities info.
public void Update(Guid taskId, IEnumerable<HydraTaskSecurity> securities)
Parameters
taskId
GuidTask id.
securities
IEnumerable<HydraTaskSecurity>Securities.
WaitUpdated()
public void WaitUpdated()