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(),