RemoteMarketDataDrive

RemoteMarketDataDrive

public RemoteMarketDataDrive()

remoteMarketDataDrive = RemoteMarketDataDrive()

Initializes a new instance of the RemoteMarketDataDrive.

RemoteMarketDataDrive

public RemoteMarketDataDrive(EndPoint address)

remoteMarketDataDrive = RemoteMarketDataDrive(address)

Initializes a new instance of the RemoteMarketDataDrive.

address

Server address.

RemoteMarketDataDrive

public RemoteMarketDataDrive(EndPoint address, IMessageAdapter adapter)

remoteMarketDataDrive = RemoteMarketDataDrive(address, adapter)

Initializes a new instance of the RemoteMarketDataDrive.

address

Server address.

adapter

Message adapter.

Address

public EndPoint Address { get; set; }

value = remoteMarketDataDrive.Address
remoteMarketDataDrive.Address = value

Server address.

Credentials

public ServerCredentials Credentials { get; }

value = remoteMarketDataDrive.Credentials

Information about the login and password for access to remote storage.

Logs

public ILogSource Logs { get; set; }

value = remoteMarketDataDrive.Logs
remoteMarketDataDrive.Logs = value

Logs.

Path

public override string Path { get; set; }

value = remoteMarketDataDrive.Path
remoteMarketDataDrive.Path = value

Path to market data.

SecurityBatchSize

public int SecurityBatchSize { get; set; }

value = remoteMarketDataDrive.SecurityBatchSize
remoteMarketDataDrive.SecurityBatchSize = value

The new instruments request block size. By default it does not exceed 1000 elements.

TargetCompId

public string TargetCompId { get; set; }

value = remoteMarketDataDrive.TargetCompId
remoteMarketDataDrive.TargetCompId = value

Target ID.

Timeout

public TimeSpan Timeout { get; set; }

value = remoteMarketDataDrive.Timeout
remoteMarketDataDrive.Timeout = value

Timeout

DisposeManaged

protected override void DisposeManaged()

remoteMarketDataDrive.DisposeManaged()

Release resources.

GetAvailableDataTypesAsync

public override IAsyncEnumerable<DataType> GetAvailableDataTypesAsync(SecurityId securityId, StorageFormats format)

result = remoteMarketDataDrive.GetAvailableDataTypesAsync(securityId, format)

Get all available data types.

securityId

Instrument identifier.

format

Format type.

Returns: Data types.

GetAvailableSecuritiesAsync

public override IAsyncEnumerable<SecurityId> GetAvailableSecuritiesAsync()

result = remoteMarketDataDrive.GetAvailableSecuritiesAsync()

Get all available instruments.

Returns: Available instruments.

GetStorageDrive

public override IMarketDataStorageDrive GetStorageDrive(SecurityId securityId, DataType dataType, StorageFormats format)

result = remoteMarketDataDrive.GetStorageDrive(securityId, dataType, format)

To get the storage for IMarketDataStorage.

securityId

Security ID.

dataType

Data type info.

format

Format type.

Returns: Storage for IMarketDataStorage.

Load

public override void Load(SettingsStorage storage)

remoteMarketDataDrive.Load(storage)

Load settings.

storage

Settings storage.

LookupSecuritiesAsync

public override IAsyncEnumerable<SecurityMessage> LookupSecuritiesAsync(SecurityLookupMessage criteria, ISecurityProvider securityProvider)

result = remoteMarketDataDrive.LookupSecuritiesAsync(criteria, securityProvider)

Download securities by the specified criteria.

criteria

Message security lookup for specified criteria.

securityProvider

The provider of information about instruments.

Returns: The sequence of found instruments.

Save

public override void Save(SettingsStorage storage)

remoteMarketDataDrive.Save(storage)

Save settings.

storage

Settings storage.

VerifyAsync

public override ValueTask VerifyAsync(CancellationToken cancellationToken)

result = remoteMarketDataDrive.VerifyAsync(cancellationToken)

Verify settings.

cancellationToken

CancellationToken

Returns: ValueTask

DefaultAddress

public static readonly EndPoint DefaultAddress

value = RemoteMarketDataDrive.DefaultAddress

Default value for Address.

DefaultTargetCompId

public static readonly string DefaultTargetCompId

value = RemoteMarketDataDrive.DefaultTargetCompId

Default value for TargetCompId.