filter

Documentation

Index

• type Filter
• type ShardedBloomFilter
  • func NewShardedBFilter(n uint, p float64, nfb uint, flush time.Duration) (*ShardedBloomFilter, error)
  • func (f *ShardedBloomFilter) Contains(key []byte) bool
  • func (f *ShardedBloomFilter) ContainsOrUpdate(key []byte) bool
  • func (f *ShardedBloomFilter) Update(key []byte)

Types

type Filter

type Filter interface {
	Update([]byte)
	Contains([]byte) bool
	ContainsOrUpdate([]byte) bool
}

type ShardedBloomFilter

type ShardedBloomFilter struct {
	sync.Mutex
	Filters []*bloom.BloomFilter
	Timer   *time.Ticker
	// contains filtered or unexported fields
}

func NewShardedBFilter

func NewShardedBFilter(n uint, p float64, nfb uint, flush time.Duration) (*ShardedBloomFilter, error)

func (*ShardedBloomFilter) Contains

func (f *ShardedBloomFilter) Contains(key []byte) bool

func (*ShardedBloomFilter) ContainsOrUpdate

func (f *ShardedBloomFilter) ContainsOrUpdate(key []byte) bool

func (*ShardedBloomFilter) Update

func (f *ShardedBloomFilter) Update(key []byte)