CsvSecurityMessageAdapterProvider

StockSharp.Algo.Storages

CSV implementation of ISecurityMessageAdapterProvider.

Implements: ISecurityMessageAdapterProvider, IMappingMessageAdapterProvider<ValueTuple<SecurityId, DataType>>

Constructors

CsvSecurityMessageAdapterProvider
public CsvSecurityMessageAdapterProvider(string fileName, ChannelExecutor executor)
csvSecurityMessageAdapterProvider = CsvSecurityMessageAdapterProvider(fileName, executor)

Initializes a new instance of the CsvSecurityMessageAdapterProvider.

fileName
File name.
executor
Sequential operation executor for disk access synchronization.
CsvSecurityMessageAdapterProvider
public CsvSecurityMessageAdapterProvider(IFileSystem fileSystem, string fileName, ChannelExecutor executor)
csvSecurityMessageAdapterProvider = CsvSecurityMessageAdapterProvider(fileSystem, fileName, executor)

Initializes a new instance of the CsvSecurityMessageAdapterProvider.

fileSystem
IFileSystem
fileName
File name.
executor
Sequential operation executor for disk access synchronization.

Properties

Adapters
public IEnumerable<KeyValuePair<ValueTuple<SecurityId, DataType>, Guid>> Adapters { get; }
value = csvSecurityMessageAdapterProvider.Adapters

All available adapters.

Methods

InitAsync
public ValueTask InitAsync(CancellationToken cancellationToken)
result = csvSecurityMessageAdapterProvider.InitAsync(cancellationToken)

Initialize the storage.

cancellationToken
CancellationToken
RemoveAssociation
public bool RemoveAssociation(ValueTuple<SecurityId, DataType> key)
result = csvSecurityMessageAdapterProvider.RemoveAssociation(key)
SetAdapter
public bool SetAdapter(ValueTuple<SecurityId, DataType> key, Guid adapterId)
result = csvSecurityMessageAdapterProvider.SetAdapter(key, adapterId)
SetAdapter
public bool SetAdapter(SecurityId securityId, DataType dataType, Guid adapterId)
result = csvSecurityMessageAdapterProvider.SetAdapter(securityId, dataType, adapterId)

Make association with adapter.

securityId
Security ID.
dataType
Data type.
adapterId
Adapter identifier.

Returns: if the association is successfully changed, otherwise, .

TryGetAdapter
public Guid? TryGetAdapter(ValueTuple<SecurityId, DataType> key)
result = csvSecurityMessageAdapterProvider.TryGetAdapter(key)
TryGetAdapter
public Guid? TryGetAdapter(SecurityId securityId, DataType dataType)
result = csvSecurityMessageAdapterProvider.TryGetAdapter(securityId, dataType)

Get adapter by the specified security id.

securityId
Security ID.
dataType
Data type.

Returns: Found adapter identifier or .

Events

Changed
public event Action<ValueTuple<SecurityId, DataType>, Guid, bool> Changed
csvSecurityMessageAdapterProvider.Changed += handler

Association changed.