diff options
5 files changed, 14 insertions, 16 deletions
diff --git a/lib/VNLib.Data.Caching.Extensions/src/FBMDataCacheExtensions.cs b/lib/VNLib.Data.Caching.Extensions/src/FBMDataCacheExtensions.cs index 32f9a0e..4f79caf 100644 --- a/lib/VNLib.Data.Caching.Extensions/src/FBMDataCacheExtensions.cs +++ b/lib/VNLib.Data.Caching.Extensions/src/FBMDataCacheExtensions.cs @@ -46,6 +46,7 @@ using VNLib.Net.Rest.Client; using VNLib.Net.Messaging.FBM; using VNLib.Net.Messaging.FBM.Client; +using ContentType = VNLib.Net.Http.ContentType; namespace VNLib.Data.Caching.Extensions { diff --git a/lib/VNLib.Data.Caching.Extensions/src/VNLib.Data.Caching.Extensions.csproj b/lib/VNLib.Data.Caching.Extensions/src/VNLib.Data.Caching.Extensions.csproj index 5f86263..88a8ce3 100644 --- a/lib/VNLib.Data.Caching.Extensions/src/VNLib.Data.Caching.Extensions.csproj +++ b/lib/VNLib.Data.Caching.Extensions/src/VNLib.Data.Caching.Extensions.csproj @@ -32,7 +32,7 @@ <PrivateAssets>all</PrivateAssets> <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets> </PackageReference> - <PackageReference Include="RestSharp" Version="108.0.3" /> + <PackageReference Include="RestSharp" Version="109.0.1" /> </ItemGroup> <ItemGroup> diff --git a/lib/VNLib.Data.Caching/src/WaitForChangeResult.cs b/lib/VNLib.Data.Caching/src/WaitForChangeResult.cs index 76cc002..fe4f22f 100644 --- a/lib/VNLib.Data.Caching/src/WaitForChangeResult.cs +++ b/lib/VNLib.Data.Caching/src/WaitForChangeResult.cs @@ -1,5 +1,5 @@ /* -* Copyright (c) 2022 Vaughn Nugent +* Copyright (c) 2023 Vaughn Nugent * * Library: VNLib * Package: VNLib.Data.Caching @@ -27,19 +27,14 @@ namespace VNLib.Data.Caching /// <summary> /// The result of a cache server change event /// </summary> - public readonly struct WaitForChangeResult + /// <param name="Status">The operation status code</param> + /// <param name="CurrentId">The current (or old) id of the element that changed</param> + /// <param name="NewId">The new id of the element that changed</param> + public readonly record struct WaitForChangeResult( + string Status, + string CurrentId, + string NewId) { - /// <summary> - /// The operation status code - /// </summary> - public readonly string Status { get; init; } - /// <summary> - /// The current (or old) id of the element that changed - /// </summary> - public readonly string CurrentId { get; init; } - /// <summary> - /// The new id of the element that changed - /// </summary> - public readonly string NewId { get; init; } + } } diff --git a/plugins/CacheBroker/src/Endpoints/BrokerRegistrationEndpoint.cs b/plugins/CacheBroker/src/Endpoints/BrokerRegistrationEndpoint.cs index 61540b9..b350e73 100644 --- a/plugins/CacheBroker/src/Endpoints/BrokerRegistrationEndpoint.cs +++ b/plugins/CacheBroker/src/Endpoints/BrokerRegistrationEndpoint.cs @@ -51,6 +51,8 @@ using VNLib.Plugins.Extensions.Loading.Events; using VNLib.Plugins.Extensions.Loading.Routing; using VNLib.Net.Rest.Client; +using ContentType = VNLib.Net.Http.ContentType; + #nullable enable namespace VNLib.Plugins.Cache.Broker.Endpoints diff --git a/plugins/ObjectCacheServer/src/ObjectCacheServerEntry.cs b/plugins/ObjectCacheServer/src/ObjectCacheServerEntry.cs index 5a748ef..2fa6220 100644 --- a/plugins/ObjectCacheServer/src/ObjectCacheServerEntry.cs +++ b/plugins/ObjectCacheServer/src/ObjectCacheServerEntry.cs @@ -524,7 +524,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server return; case "deleted": //Delete the object from the store - _ = cacheStore.DeleteItemAsync(changedObject.CurrentId).ConfigureAwait(false); + await cacheStore.DeleteItemAsync(changedObject.CurrentId); break; case "modified": //Reload the record from the store |