56 references to HybridCachePayload
Microsoft.Extensions.Caching.Hybrid (14)
Internal\DefaultHybridCache.L2.cs (3)
224int maxLength = HybridCachePayload.GetMaxBytes(key, cacheItem.Tags, payload.Length); 227int length = HybridCachePayload.Write(oversized, key, cacheItem.CreationTimestamp, GetL2AbsoluteExpirationRelativeToNow(options), 228HybridCachePayload.PayloadFlags.None, cacheItem.Tags, payload.AsSequence());
Internal\DefaultHybridCache.StampedeStateT.cs (10)
226HybridCachePayload.HybridCachePayloadParseResult parseResult = HybridCachePayload.TryParse( 227result.AsArraySegment(), Key.Key, CacheItem.Tags, Cache, out HybridCachePayload.ParsedPayload parsed, out Exception? fault); 230case HybridCachePayload.HybridCachePayloadParseResult.Success: 242case HybridCachePayload.HybridCachePayloadParseResult.ExpiredByEntry: 243case HybridCachePayload.HybridCachePayloadParseResult.ExpiredByWildcard: 244case HybridCachePayload.HybridCachePayloadParseResult.ExpiredByTag: 544int maxBytes = HybridCachePayload.Encoding.GetMaxByteCount(maxChars); 598byteBuffer = byteBuffer.Slice(0, HybridCachePayload.Encoding.GetBytes(value.AsSpan(), byteBuffer)); 599charBuffer = charBuffer.Slice(0, HybridCachePayload.Encoding.GetChars(byteBuffer, charBuffer));
Internal\Log.cs (1)
6using static Microsoft.Extensions.Caching.Hybrid.Internal.HybridCachePayload;
Microsoft.Extensions.Caching.Hybrid.Tests (42)
BufferReleaseTests.cs (4)
132var arr = ArrayPool<byte>.Shared.Rent(HybridCachePayload.GetMaxBytes(key, TagSet.Empty, writer.CommittedBytes)); 133var bytes = HybridCachePayload.Write(arr, key, cache.CurrentTimestamp(), TimeSpan.FromHours(1), 0, TagSet.Empty, writer.AsSequence()); 195var arr = ArrayPool<byte>.Shared.Rent(HybridCachePayload.GetMaxBytes(key, TagSet.Empty, writer.CommittedBytes)); 196var bytes = HybridCachePayload.Write(arr, key, cache.CurrentTimestamp(), TimeSpan.FromHours(1), 0, TagSet.Empty, writer.AsSequence());
PayloadTests.cs (38)
48var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length); 51int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 57var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out var parsed, out _); 59Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.Success, result); 78var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length); 81int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 86var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out var parsed, out _); 87Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.Success, result); 92result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out parsed, out _); 93Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.ExpiredByEntry, result); 112var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length); 115int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 122var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out var parsed, out _); 123Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.ExpiredByWildcard, result); 142var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length); 145int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 152var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out var parsed, out _); 153Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.Success, result); 158result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out parsed, out _); 159Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.ExpiredByTag, result); 178var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length); 182int actualLength = HybridCachePayload.Write(oversized, key, creation, TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 190var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, tags, cache, out var parsed, out _); 191Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.Success, result); 213var result = HybridCachePayload.TryParse(new(bytes), "whatever", TagSet.Empty, cache, out var parsed, out _); 214Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.FormatNotRecognized, result); 233var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length); 236int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 240var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength - 1), key, tags, cache, out var parsed, out _); 241Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.InvalidData, result); 260var maxLen = HybridCachePayload.GetMaxBytes(key, tags, bytes.Length) + 1; 263int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, tags, new(bytes)); 267var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength + 1), key, tags, cache, out var parsed, out _); 268Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.InvalidData, result); 346var maxLen = HybridCachePayload.GetMaxBytes(key, writeTags, bytes.Length); 349int actualLength = HybridCachePayload.Write(oversized, key, cache.CurrentTimestamp(), TimeSpan.FromMinutes(1), 0, writeTags, new(bytes)); 361var result = HybridCachePayload.TryParse(new(oversized, 0, actualLength), key, TagSet.Empty, cache, out var parsed, out _); 362Assert.Equal(HybridCachePayload.HybridCachePayloadParseResult.Success, result);