Method RebuildBloomFilter

pkg/cachep/bloom/cachebloom.go:125–143

RebuildBloomFilter 重建布隆过滤器 导出该方法以便外部调用

(ctx context.Context)

// RebuildBloomFilter 重建布隆过滤器
// 导出该方法以便外部调用
func (cb *CacheBloom) RebuildBloomFilter(ctx context.Context) error {
	if cb == nil {
		return errors.New("CacheBloom实例不能为空")
	}

	newBF := bloom.NewWithEstimates(1000000, 0.01)

	// 使用SCAN命令替代KEYS,避免阻塞Redis
	iter := cb.client.Scan(ctx, 0, "*", 0).Iterator()
	for iter.Next(ctx) {
		newBF.AddString(iter.Val())
	}
	if err := iter.Err(); err != nil {
		return err
	}

	cb.bf = newBF
	return nil
}

// isNil 使用反射检查值是否为 nil
func isNil(value interface{}) bool {