Function TestMemoryStorage_Expire

internal/caches/storage_memory_test.go:275–307

(t *testing.T)

}

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

	var storage = NewMemoryStorage(&serverconfigs.HTTPCachePolicy{
		MemoryAutoPurgeInterval: 5,
	}, nil)
	err := storage.Init()
	if err != nil {
		t.Fatal(err)
	}

	for i := 0; i < 1000; i++ {
		expiredAt := time.Now().Unix() + int64(rands.Int(0, 60))
		key := "abc" + strconv.Itoa(i)
		writer, err := storage.OpenWriter(key, 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:       key,
			BodySize:  5,
			ExpiresAt: expiredAt,
		})
	}
	time.Sleep(70 * time.Second)
}

func TestMemoryStorage_Locker(t *testing.T) {
	var storage = NewMemoryStorage(&serverconfigs.HTTPCachePolicy{}, nil)