diff options
Diffstat (limited to 'lib/VNLib.Data.Caching.Extensions/src/ApiModel/CacheSiteAdapter.cs')
-rw-r--r-- | lib/VNLib.Data.Caching.Extensions/src/ApiModel/CacheSiteAdapter.cs | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/lib/VNLib.Data.Caching.Extensions/src/ApiModel/CacheSiteAdapter.cs b/lib/VNLib.Data.Caching.Extensions/src/ApiModel/CacheSiteAdapter.cs new file mode 100644 index 0000000..99acfd5 --- /dev/null +++ b/lib/VNLib.Data.Caching.Extensions/src/ApiModel/CacheSiteAdapter.cs @@ -0,0 +1,65 @@ +/* +* Copyright (c) 2023 Vaughn Nugent +* +* Library: VNLib +* Package: VNLib.Data.Caching.Extensions +* File: CacheSiteAdapter.cs +* +* CacheSiteAdapter.cs is part of VNLib.Data.Caching.Extensions which is part of the larger +* VNLib collection of libraries and utilities. +* +* VNLib.Data.Caching.Extensions is free software: you can redistribute it and/or modify +* it under the terms of the GNU Affero General Public License as +* published by the Free Software Foundation, either version 3 of the +* License, or (at your option) any later version. +* +* VNLib.Data.Caching.Extensions is distributed in the hope that it will be useful, +* but WITHOUT ANY WARRANTY; without even the implied warranty of +* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +* GNU Affero General Public License for more details. +* +* You should have received a copy of the GNU Affero General Public License +* along with this program. If not, see https://www.gnu.org/licenses/. +*/ + +using System.Net; +using System.Text; +using System.Threading; +using System.Threading.Tasks; + +using RestSharp; + +using VNLib.Net.Rest.Client; +using VNLib.Net.Rest.Client.Construction; + +namespace VNLib.Data.Caching.Extensions.ApiModel +{ + /// <summary> + /// A site adapter for cache REST api requests + /// </summary> + internal sealed class CacheSiteAdapter : RestSiteAdapterBase + { + protected override RestClientPool Pool { get; } + + public CacheSiteAdapter(int maxClients) + { + //Configure connection pool + Pool = new(maxClients, new RestClientOptions() + { + MaxTimeout = 10 * 1000, + FollowRedirects = false, + Encoding = Encoding.UTF8, + AutomaticDecompression = DecompressionMethods.All, + ThrowOnAnyError = true + }); + } + + public override void OnResponse(RestResponse response) + { } + + public override Task WaitAsync(CancellationToken cancellation = default) + { + return Task.CompletedTask; + } + } +} |