IClient.cs

using System;
using System.Threading.Tasks;
 
namespace Datalayer
{
    public interface IClient : INativeDisposable
    {
        IDatalayerSystem System { get; }
 
        bool IsConnected { get; }
 
        DLR_RESULT ConnectionStatus { get; }
 
        IVariant AuthToken { get; }
 
        DLR_RESULT SetTimeout(DLR_TIMEOUT_SETTING timeout, uint value);
 
        DLR_RESULT Ping();
 
        Task<IClientAsyncResult> PingAsync();
 
        (DLR_RESULT result, IVariant value) Read(string address);
 
        Task<IClientAsyncResult> ReadAsync(string address);
 
        Task<IClientAsyncResult> ReadAsync(string address, IVariant args);
 
        (DLR_RESULT result, IVariant value) Read(string address, IVariant args);
 
 
        //[Obsolete("Please use the corresponding bulk method.")]
        (DLR_RESULT[] result, IVariant[] value) ReadMulti(string[] addresses);
 
        (DLR_RESULT result, IBulkItem[] items) BulkRead(string[] addresses);
 
        (DLR_RESULT result, IBulkItem[] items) BulkRead(string[] addresses, IVariant[] args);
 
        Task<IClientAsyncBulkResult> BulkReadAsync(string[] addresses);
 
        Task<IClientAsyncBulkResult> BulkReadAsync(string[] addresses, IVariant[] args);
 
        //[Obsolete("Please use the corresponding bulk method.")]
        Task<IClientAsyncResult[]> ReadMultiAsync(string[] addresses);
 
        (DLR_RESULT result, IVariant value) ReadJson(string address, int indentStep = 0);
 
        (DLR_RESULT result, IVariant value) ReadJson(string address, IVariant args, int indentStep = 0);
 
        Task<IClientAsyncResult> ReadJsonAsync(string address, int indentStep = 0);
 
        Task<IClientAsyncResult> ReadJsonAsync(string address, IVariant args, int indentStep = 0);
 
        (DLR_RESULT result, IVariant value) ReadMetadata(string address);
 
        Task<IClientAsyncResult> ReadMetadataAsync(string address);
 
        (DLR_RESULT result, IBulkItem[] items) BulkReadMetadata(string[] addresses);
 
        Task<IClientAsyncBulkResult> BulkReadMetadataAsync(string[] addresses);
 
        DLR_RESULT Write(string address, IVariant writeValue);
 
        Task<IClientAsyncResult> WriteAsync(string address, IVariant writeValue);
 
        //[Obsolete("Please use the corresponding bulk method.")]
        DLR_RESULT[] WriteMulti(string[] addresses, IVariant[] writeValues);
 
        //[Obsolete("Please use the corresponding bulk method.")]
        Task<IClientAsyncResult[]> WriteMultiAsync(string[] addresses, IVariant[] writeValues);
 
        (DLR_RESULT result, IBulkItem[] items) BulkWrite(string[] addresses, IVariant[] writeValues);
 
        Task<IClientAsyncBulkResult> BulkWriteAsync(string[] addresses, IVariant[] writeValues);
 
        (DLR_RESULT, IVariant error) WriteJson(string address, string json);
 
        Task<IClientAsyncResult> WriteJsonAsync(string address, string json);
 
        (DLR_RESULT result, IVariant value) Browse(string address);
 
        Task<IClientAsyncResult> BrowseAsync(string address);
 
        (DLR_RESULT result, IBulkItem[] items) BulkBrowse(string[] addresses);
 
        Task<IClientAsyncBulkResult> BulkBrowseAsync(string[] addresses);
 
        (DLR_RESULT result, IVariant value) Create(string address, IVariant args);
 
        Task<IClientAsyncResult> CreateAsync(string address, IVariant args);
 
        (DLR_RESULT result, IBulkItem[] items) BulkCreate(string[] addresses, IVariant[] args);
 
        Task<IClientAsyncBulkResult> BulkCreateAsync(string[] addresses, IVariant[] args);
 
        DLR_RESULT Remove(string address);
 
        Task<IClientAsyncResult> RemoveAsync(string address);
 
        (DLR_RESULT result, IBulkItem[] items) BulkRemove(string[] addresses);
 
        Task<IClientAsyncBulkResult> BulkRemoveAsync(string[] addresses);
 
        (DLR_RESULT result, ISubscription subscription) CreateSubscription(IVariant subscriptionPropertiesFlatbuffers, object userData);
 
        Task<ISubscriptionAsyncResult> CreateSubscriptionAsync(IVariant subscriptionPropertiesFlatbuffers, object userData);
    }
}