12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- package bloom
- import (
- "testing"
- "git.i2edu.net/i2/go-zero/core/stores/redis/redistest"
- "github.com/stretchr/testify/assert"
- )
- func TestRedisBitSet_New_Set_Test(t *testing.T) {
- store, clean, err := redistest.CreateRedis()
- assert.Nil(t, err)
- defer clean()
- bitSet := newRedisBitSet(store, "test_key", 1024)
- isSetBefore, err := bitSet.check([]uint{0})
- if err != nil {
- t.Fatal(err)
- }
- if isSetBefore {
- t.Fatal("Bit should not be set")
- }
- err = bitSet.set([]uint{512})
- if err != nil {
- t.Fatal(err)
- }
- isSetAfter, err := bitSet.check([]uint{512})
- if err != nil {
- t.Fatal(err)
- }
- if !isSetAfter {
- t.Fatal("Bit should be set")
- }
- err = bitSet.expire(3600)
- if err != nil {
- t.Fatal(err)
- }
- err = bitSet.del()
- if err != nil {
- t.Fatal(err)
- }
- }
- func TestRedisBitSet_Add(t *testing.T) {
- store, clean, err := redistest.CreateRedis()
- assert.Nil(t, err)
- defer clean()
- filter := New(store, "test_key", 64)
- assert.Nil(t, filter.Add([]byte("hello")))
- assert.Nil(t, filter.Add([]byte("world")))
- ok, err := filter.Exists([]byte("hello"))
- assert.Nil(t, err)
- assert.True(t, ok)
- }
|