Versions in this module Expand all Collapse all v1 v1.0.1 Mar 1, 2020 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
Go to main page