filter

Documentation

Index

• func Hash(bys []byte) uint64
• type Filter
  • func NewBigFilter(n int, m uint, fpRate float64, redisServerCluster []string, pass *string, ...) (Filter, error)

Functions

func Hash

func Hash(bys []byte) uint64

todo: 测试这样分片是否均匀,已测试，很均匀

Types

type Filter

type Filter interface {
	// Add a key to filter
	Add(key []byte) error

	// Check more keys is/not exist
	ExistMult(arr [][]byte) []bool

	// Check key is/not exist
	Exist(key []byte) (bool, error)

	// Add more key to filter
	AddMult(arr [][]byte) error

	// Save last point to server
	SaveLastPoint(pointK string, pointV string) error

	// get last point to server
	GetLastPoint(pointK string) ([]string, error)
}

Filter support add key , check key is/not exist

func NewBigFilter

func NewBigFilter(n int, m uint, fpRate float64, redisServerCluster []string, pass *string,
	name string, logger protocol.Logger) (
	Filter, error)

创建一个 bigFilter args: n 子过滤器个数，m 每个子过滤器容量，fpRate 过滤器误判概率