Skip to content

Commit 8542596

Browse files
fix: caching deadline duration
1 parent db5ff83 commit 8542596

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

pkg/proxy/filter_caching.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,11 @@ func (f *CachingFilter) Post(c filter.Context) (statusCode int, err error) {
6767
}
6868

6969
f.cache.Add(id, genCachedValue(c))
70-
f.tw.Schedule(time.Second*time.Duration(c.DispatchNode().Cache.Deadline),
71-
f.removeCache, id)
70+
if c.DispatchNode().Cache.Deadline > 0 {
71+
f.tw.Schedule(time.Duration(c.DispatchNode().Cache.Deadline),
72+
f.removeCache, id)
73+
}
74+
7275
return f.BaseFilter.Post(c)
7376
}
7477

0 commit comments

Comments
 (0)