TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-27 18:40:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加${cache.age}变量

Browse Source
This commit is contained in:
GoEdgeLab
2021-12-02 09:34:38 +08:00
parent 5a3869c18e
commit e8c647adf0
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/nodes/http_request_cache.go
View File

@@ -7,6 +7,7 @@ import (
"github.com/TeaOSLab/EdgeNode/internal/caches" "github.com/TeaOSLab/EdgeNode/internal/caches"
"github.com/TeaOSLab/EdgeNode/internal/remotelogs" "github.com/TeaOSLab/EdgeNode/internal/remotelogs"
"github.com/TeaOSLab/EdgeNode/internal/rpc" "github.com/TeaOSLab/EdgeNode/internal/rpc"
"github.com/TeaOSLab/EdgeNode/internal/utils"
"net/http" "net/http"
"path/filepath" "path/filepath"
"strconv" "strconv"
@@ -113,6 +114,8 @@ func (this *HTTPRequest) doCacheRead() (shouldStop bool) {
// 判断是否在Purge // 判断是否在Purge
if this.web.Cache.PurgeIsOn && strings.ToUpper(this.RawReq.Method) == "PURGE" && this.RawReq.Header.Get("X-Edge-Purge-Key") == this.web.Cache.PurgeKey { if this.web.Cache.PurgeIsOn && strings.ToUpper(this.RawReq.Method) == "PURGE" && this.RawReq.Header.Get("X-Edge-Purge-Key") == this.web.Cache.PurgeKey {
this.varMapping["cache.status"] = "PURGE"
err := storage.Delete(key) err := storage.Delete(key)
if err != nil { if err != nil {
remotelogs.Error("HTTP_REQUEST_CACHE", "purge failed: "+err.Error()) remotelogs.Error("HTTP_REQUEST_CACHE", "purge failed: "+err.Error())
@@ -204,6 +207,9 @@ func (this *HTTPRequest) doCacheRead() (shouldStop bool) {
return return
} }
// 设置cache.age变量
this.varMapping["cache.age"] = strconv.FormatInt(reader.ExpiresAt()-utils.UnixTime(), 10)
if addStatusHeader { if addStatusHeader {
this.writer.Header().Set("X-Cache", "HIT, "+refType+", "+reader.TypeName()) this.writer.Header().Set("X-Cache", "HIT, "+refType+", "+reader.TypeName())
} }