Compare commits

...

1 Commits
v0.0.11 ... dev

Author SHA1 Message Date
lucas 34c2cb5d28 update 窗口创建原因 2 weeks ago
  1. 4
      cacheData.go

4
cacheData.go

@ -31,6 +31,7 @@ type CacheWindow struct {
windowLen int //窗体长度 windowLen int //窗体长度
WindowSize int //窗体大小 WindowSize int //窗体大小
MethodId int //滑窗方法 MethodId int //滑窗方法
CreatReason string //创建原因
LatestData any LatestData any
ring *ring.Ring ring *ring.Ring
Params FilterParams Params FilterParams
@ -74,7 +75,7 @@ func (c *CacheWindow) MarshalBinary() (data []byte, err error) {
func (c *CacheWindow) UnmarshalBinary(data []byte) error { func (c *CacheWindow) UnmarshalBinary(data []byte) error {
return json.Unmarshal(data, c) return json.Unmarshal(data, c)
} }
func NewCacheWindow(id string, size, methodId int, params FilterParams) CacheWindow { func NewCacheWindow(id string, size, methodId int, params FilterParams, creatReason string) CacheWindow {
limit := 10 limit := 10
if size > limit { if size > limit {
size = 10 size = 10
@ -85,6 +86,7 @@ func NewCacheWindow(id string, size, methodId int, params FilterParams) CacheWin
MethodId: methodId, MethodId: methodId,
ring: ring.New(size), ring: ring.New(size),
Params: params, Params: params,
CreatReason: creatReason,
Expire: expirationInfo{ Expire: expirationInfo{
UpdateTime: time.Now(), UpdateTime: time.Now(),
Duration: 60 * 2, Duration: 60 * 2,

Loading…
Cancel
Save