From 5a8ee343607d72447bbe6414293c6c38e603cb5d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Fri, 22 Mar 2024 09:21:45 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/api_stream.go | 2 +- internal/nodes/http_writer.go | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/nodes/api_stream.go b/internal/nodes/api_stream.go index 8a58a2f..56b1779 100644 --- a/internal/nodes/api_stream.go +++ b/internal/nodes/api_stream.go @@ -209,7 +209,7 @@ func (this *APIStream) handleWriteCache(message *pb.NodeStreamMessage) error { storage.AddToList(&caches.Item{ Type: writer.ItemType(), Key: msg.Key, - ExpiredAt: expiredAt, + ExpiresAt: expiredAt, HeaderSize: writer.HeaderSize(), BodySize: writer.BodySize(), }) diff --git a/internal/nodes/http_writer.go b/internal/nodes/http_writer.go index a91870f..16c57b1 100644 --- a/internal/nodes/http_writer.go +++ b/internal/nodes/http_writer.go @@ -1168,7 +1168,7 @@ func (this *HTTPWriter) finishWebP() { this.cacheStorage.AddToList(&caches.Item{ Type: webpCacheWriter.ItemType(), Key: webpCacheWriter.Key(), - ExpiredAt: webpCacheWriter.ExpiredAt(), + ExpiresAt: webpCacheWriter.ExpiredAt(), StaleAt: webpCacheWriter.ExpiredAt() + int64(this.calculateStaleLife()), HeaderSize: webpCacheWriter.HeaderSize(), BodySize: webpCacheWriter.BodySize(), @@ -1207,7 +1207,7 @@ func (this *HTTPWriter) finishCache() { this.cacheStorage.AddToList(&caches.Item{ Type: this.cacheWriter.ItemType(), Key: this.cacheWriter.Key(), - ExpiredAt: expiredAt, + ExpiresAt: expiredAt, StaleAt: expiredAt + int64(this.calculateStaleLife()), HeaderSize: this.cacheWriter.HeaderSize(), BodySize: this.cacheWriter.BodySize(), @@ -1228,7 +1228,7 @@ func (this *HTTPWriter) finishCache() { this.cacheStorage.AddToList(&caches.Item{ Type: this.cacheWriter.ItemType(), Key: this.cacheWriter.Key(), - ExpiredAt: expiredAt, + ExpiresAt: expiredAt, StaleAt: expiredAt + int64(this.calculateStaleLife()), HeaderSize: this.cacheWriter.HeaderSize(), BodySize: this.cacheWriter.BodySize(), @@ -1251,7 +1251,7 @@ func (this *HTTPWriter) finishCompression() { this.cacheStorage.AddToList(&caches.Item{ Type: this.compressionCacheWriter.ItemType(), Key: this.compressionCacheWriter.Key(), - ExpiredAt: expiredAt, + ExpiresAt: expiredAt, StaleAt: expiredAt + int64(this.calculateStaleLife()), HeaderSize: this.compressionCacheWriter.HeaderSize(), BodySize: this.compressionCacheWriter.BodySize(),