aboutsummaryrefslogtreecommitdiff
path: root/libs/VNLib.Plugins.Sessions.Cache.Client
diff options
context:
space:
mode:
authorLibravatar vnugent <public@vaughnnugent.com>2023-01-28 13:41:09 -0500
committerLibravatar vnugent <public@vaughnnugent.com>2023-01-28 13:41:09 -0500
commit99952991919076bfe247d5e1a7677e414755cd56 (patch)
tree90c542ed7e65e13692d1510f340bde358abb9326 /libs/VNLib.Plugins.Sessions.Cache.Client
parentb8522ccf6c33f5605dbe6b491efae04c478d8d65 (diff)
Fix FBMMessageHeader default and session connection status
Diffstat (limited to 'libs/VNLib.Plugins.Sessions.Cache.Client')
-rw-r--r--libs/VNLib.Plugins.Sessions.Cache.Client/src/GlobalCacheStore.cs3
-rw-r--r--libs/VNLib.Plugins.Sessions.Cache.Client/src/IRemoteCacheStore.cs5
-rw-r--r--libs/VNLib.Plugins.Sessions.Cache.Client/src/SessionCacheClient.cs6
3 files changed, 14 insertions, 0 deletions
diff --git a/libs/VNLib.Plugins.Sessions.Cache.Client/src/GlobalCacheStore.cs b/libs/VNLib.Plugins.Sessions.Cache.Client/src/GlobalCacheStore.cs
index df3c564..55f5016 100644
--- a/libs/VNLib.Plugins.Sessions.Cache.Client/src/GlobalCacheStore.cs
+++ b/libs/VNLib.Plugins.Sessions.Cache.Client/src/GlobalCacheStore.cs
@@ -44,6 +44,9 @@ namespace VNLib.Plugins.Sessions.Cache.Client
}
///<inheritdoc/>
+ public bool IsConnected => _cache.IsConnected;
+
+ ///<inheritdoc/>
public Task AddOrUpdateObjectAsync<T>(string objectId, string? newId, T obj, CancellationToken cancellationToken = default)
{
return _cache.AddOrUpdateAsync(objectId, newId, obj, cancellationToken);
diff --git a/libs/VNLib.Plugins.Sessions.Cache.Client/src/IRemoteCacheStore.cs b/libs/VNLib.Plugins.Sessions.Cache.Client/src/IRemoteCacheStore.cs
index 2a8bd49..ce95a6b 100644
--- a/libs/VNLib.Plugins.Sessions.Cache.Client/src/IRemoteCacheStore.cs
+++ b/libs/VNLib.Plugins.Sessions.Cache.Client/src/IRemoteCacheStore.cs
@@ -44,5 +44,10 @@ namespace VNLib.Plugins.Sessions.Cache.Client
Task AddOrUpdateObjectAsync<T>(string objectId, string? newId, T obj, CancellationToken cancellationToken = default);
Task DeleteObjectAsync(string objectId, CancellationToken cancellationToken = default);
+
+ /// <summary>
+ /// Gets a value that determines if the remote cache store is available
+ /// </summary>
+ bool IsConnected { get; }
}
}
diff --git a/libs/VNLib.Plugins.Sessions.Cache.Client/src/SessionCacheClient.cs b/libs/VNLib.Plugins.Sessions.Cache.Client/src/SessionCacheClient.cs
index b729803..20ea947 100644
--- a/libs/VNLib.Plugins.Sessions.Cache.Client/src/SessionCacheClient.cs
+++ b/libs/VNLib.Plugins.Sessions.Cache.Client/src/SessionCacheClient.cs
@@ -102,6 +102,12 @@ namespace VNLib.Plugins.Sessions.Cache.Client
protected IRemoteCacheStore Store { get; }
/// <summary>
+ /// Gets a value that determines if the backing <see cref="IRemoteCacheStore"/> is connected
+ /// to a server
+ /// </summary>
+ public bool IsConnected => Store.IsConnected;
+
+ /// <summary>
/// Initializes a new <see cref="SessionCacheClient"/>
/// </summary>
/// <param name="client"></param>