(t *testing.T)
| 187 | } |
| 188 | |
| 189 | func TestMemoryStorage_CleanAll(t *testing.T) { |
| 190 | var storage = NewMemoryStorage(&serverconfigs.HTTPCachePolicy{}, nil) |
| 191 | var expiredAt = time.Now().Unix() + 60 |
| 192 | { |
| 193 | writer, err := storage.OpenWriter("abc", expiredAt, 200, -1, -1, -1, false) |
| 194 | if err != nil { |
| 195 | t.Fatal(err) |
| 196 | } |
| 197 | _, _ = writer.Write([]byte("Hello")) |
| 198 | err = writer.Close() |
| 199 | if err != nil { |
| 200 | t.Fatal(err) |
| 201 | } |
| 202 | storage.AddToList(&Item{ |
| 203 | Key: "abc", |
| 204 | BodySize: 5, |
| 205 | ExpiresAt: expiredAt, |
| 206 | }) |
| 207 | } |
| 208 | { |
| 209 | writer, err := storage.OpenWriter("abc1", expiredAt, 200, -1, -1, -1, false) |
| 210 | if err != nil { |
| 211 | t.Fatal(err) |
| 212 | } |
| 213 | _, _ = writer.Write([]byte("Hello")) |
| 214 | err = writer.Close() |
| 215 | if err != nil { |
| 216 | t.Fatal(err) |
| 217 | } |
| 218 | storage.AddToList(&Item{ |
| 219 | Key: "abc1", |
| 220 | BodySize: 5, |
| 221 | ExpiresAt: expiredAt, |
| 222 | }) |
| 223 | } |
| 224 | err := storage.CleanAll() |
| 225 | if err != nil { |
| 226 | t.Fatal(err) |
| 227 | } |
| 228 | total, _ := storage.list.Count() |
| 229 | t.Log(total, len(storage.valuesMap)) |
| 230 | } |
| 231 | |
| 232 | func TestMemoryStorage_Purge(t *testing.T) { |
| 233 | storage := NewMemoryStorage(&serverconfigs.HTTPCachePolicy{}, nil) |
nothing calls this directly
no test coverage detected