bloombits

Feb 16, 2019

Changes in this version

+ type Generator struct

+ func NewGenerator(sections uint) (*Generator, error)

+ func (b *Generator) AddBloom(index uint, bloom types.Bloom) error

+ func (b *Generator) Bitset(idx uint) ([]byte, error)

+ type Matcher struct

+ func NewMatcher(sectionSize uint64, filters [][][]byte) *Matcher

+ func (m *Matcher) Start(ctx context.Context, begin, end uint64, results chan uint64) (*MatcherSession, error)

+ type MatcherSession struct

+ func (s *MatcherSession) AllocateRetrieval() (uint, bool)

+ func (s *MatcherSession) AllocateSections(bit uint, count int) []uint64

+ func (s *MatcherSession) Close()

+ func (s *MatcherSession) DeliverSections(bit uint, sections []uint64, bitsets [][]byte)

+ func (s *MatcherSession) Error() error

+ func (s *MatcherSession) Multiplex(batch int, wait time.Duration, mux chan chan *Retrieval)

+ func (s *MatcherSession) PendingSections(bit uint) int

+ type Retrieval struct

+ Bit uint

+ Bitsets [][]byte

+ Context context.Context

+ Error error

+ Sections []uint64