Function TestMemoryStorage_Purge

internal/caches/storage_memory_test.go:232–273

(t *testing.T)

}

func TestMemoryStorage_Purge(t *testing.T) {
	storage := NewMemoryStorage(&serverconfigs.HTTPCachePolicy{}, nil)
	expiredAt := time.Now().Unix() + 60
	{
		writer, err := storage.OpenWriter("abc", expiredAt, 200, -1, -1, -1, false)
		if err != nil {
			t.Fatal(err)
		}
		_, _ = writer.Write([]byte("Hello"))
		err = writer.Close()
		if err != nil {
			t.Fatal(err)
		}
		storage.AddToList(&Item{
			Key:       "abc",
			BodySize:  5,
			ExpiresAt: expiredAt,
		})
	}
	{
		writer, err := storage.OpenWriter("abc1", expiredAt, 200, -1, -1, -1, false)
		if err != nil {
			t.Fatal(err)
		}
		_, _ = writer.Write([]byte("Hello"))
		err = writer.Close()
		if err != nil {
			t.Fatal(err)
		}
		storage.AddToList(&Item{
			Key:       "abc1",
			BodySize:  5,
			ExpiresAt: expiredAt,
		})
	}
	err := storage.Purge([]string{"abc", "abc1"}, "")
	if err != nil {
		t.Fatal(err)
	}
	total, _ := storage.list.Count()
	t.Log(total, len(storage.valuesMap))
}

func TestMemoryStorage_Expire(t *testing.T) {
	if !testutils.IsSingleTesting() {