Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.

filter

package

v1.8.0 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BloomFilter struct {
	// contains filtered or unexported fields
}

BloomFilter implements a thread-safe Bloom Filter for high-speed deduplication.

func NewBloomFilter(m, k uint) *BloomFilter

NewBloomFilter creates a new Bloom Filter with m bits and k hash functions.

func (f *BloomFilter) Add(data []byte)

Add adds data to the filter.

func (f *BloomFilter) Reset()

Reset clears the filter.

func (f *BloomFilter) Test(data []byte) bool

Test returns true if data might be in the filter.

type Filter interface {
	Add(data []byte)
	Test(data []byte) bool
	Reset()
}

Filter defines a generic interface for probabilistic data filters.

type RotatingBloomFilter struct {
	// contains filtered or unexported fields
}

RotatingBloomFilter uses two Bloom Filters to provide a sliding window of deduplication.

func NewRotatingBloomFilter(m, k, limit uint) *RotatingBloomFilter

NewRotatingBloomFilter creates a new RotatingBloomFilter that rotates after limit additions.

func (f *RotatingBloomFilter) Add(data []byte)

Add adds data to the current filter and rotates if limit is reached.

func (f *RotatingBloomFilter) Reset()

Reset clears both filters.

func (f *RotatingBloomFilter) Test(data []byte) bool

Test checks both current and previous filters.