aggregation

Documentation

Index

• Variables
• type ResultsSet
  • func GetResultSet(length int) *ResultsSet
  • func (rs *ResultsSet) Close() error
  • func (rs *ResultsSet) FillFromReader(reader bloomd.ResultReader) error
  • func (rs *ResultsSet) Length() int
  • func (rs *ResultsSet) MergeFromReader(reader bloomd.ResultReader) error
  • func (rs *ResultsSet) Next() (bool, error)
  • func (rs *ResultsSet) Read(p []bool) (int, error)

Variables

var ErrCursorOverLength = errors.New("ResultsSet:reader cursor is over length")

Types

type ResultsSet

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

ResultsSet is an aggregator for multiple filter result readers

func GetResultSet

func GetResultSet(length int) *ResultsSet

GetResultSet fetches results set of provided length from pool

func (*ResultsSet) Close

func (rs *ResultsSet) Close() error

Close returns result set into the pool

func (*ResultsSet) FillFromReader

func (rs *ResultsSet) FillFromReader(reader bloomd.ResultReader) error

FillFromReader makes initial load for result set from provided reader

func (*ResultsSet) Length

func (rs *ResultsSet) Length() int

func (*ResultsSet) MergeFromReader

func (rs *ResultsSet) MergeFromReader(reader bloomd.ResultReader) error

MergeFromReader merge results from reader with results that are already in set, merge is made for each corresponding pair using "or" logical operation

func (*ResultsSet) Next

func (rs *ResultsSet) Next() (bool, error)

Next returns value for current cursor position and increments internal cursor

func (*ResultsSet) Read

func (rs *ResultsSet) Read(p []bool) (int, error)

Read reads content of result set into provided array