|
@ -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, |
|
|