Versions in this module Expand all Collapse all v0 v0.22.3 Apr 17, 2024 Changes in this version + const ArrayMaxSize + const ContainerArray + const ContainerBitmap + const ContainerNil + const ContainerRun + const MagicNumber + const MaxContainerVal + var ContainerArchetypeNames = []string + var NewFileBitmap = NewBTreeBitmap + func ApplyFilterToIterator(filter BitmapFilter, iter ContainerIterator) error + func ArrayCountRange(array []uint16, start, end int32) (n int32) + func AsArray(c *Container) []uint16 + func AsBitmap(c *Container) []uint64 + func BinSearchRuns(v uint16, a []Interval16) (int32, bool) + func BitmapCountRange(bitmap []uint64, start, end int32) int32 + func BitmapsToRoaring(bitmaps []*Bitmap) []byte + func CompareBitmapMap(b *Bitmap, vals map[uint64]struct{}) (bool, error) + func CompareBitmapSlice(b *Bitmap, vals []uint64) (bool, error) + func ContainerCallback(a *Container, fn func(uint16)) + func ContainerType(c *Container) byte + func GetMatchingKeysFrom(source []uint64, key uint64) (matching []uint64, remaining []uint64, nextKey uint64) + func InitContainerArchetypes() ([][]*Container, error) + func IntersectionAny(a, b *Container) bool + func IntersectionCount(x, y *Container) int32 + func Merge(a, b []uint16) + func NewRepeatedRowContainerIterator(iter ContainerIterator) *repeatedRowIterator + func RunCountRange(runs []Interval16, start, end int32) (n int32) + type AdvisoryError interface + AdvisoryOnly func() + type Bitmap struct + Containers Containers + Flags byte + OpWriter io.Writer + func Add(x, y []*Bitmap) []*Bitmap + func InspectBinary(data []byte, mapped bool, info *BitmapInfo) (b *Bitmap, mappedAny bool, err error) + func NewBTreeBitmap(a ...uint64) *Bitmap + func NewBitMatrix(shardWidth uint64, rows ...[]uint64) *Bitmap + func NewBitmap(a ...uint64) *Bitmap + func NewSliceBitmap(a ...uint64) *Bitmap + func RoaringToBitmaps(data []byte, shardWidth uint64) ([]*Bitmap, []uint64) + func (b *Bitmap) Add(a ...uint64) (changed bool, err error) + func (b *Bitmap) AddN(a ...uint64) (changed int, err error) + func (b *Bitmap) Any() bool + func (b *Bitmap) AsContainerMatrixString() (r string) + func (b *Bitmap) BitwiseEqual(c *Bitmap) (bool, error) + func (b *Bitmap) Check() error + func (b *Bitmap) Clone() *Bitmap + func (b *Bitmap) Contains(v uint64) bool + func (b *Bitmap) Count() (n uint64) + func (b *Bitmap) CountRange(start, end uint64) (n uint64) + func (b *Bitmap) Difference(other ...*Bitmap) *Bitmap + func (b *Bitmap) DifferenceInPlace(others ...*Bitmap) + func (b *Bitmap) DirectAdd(v uint64) bool + func (b *Bitmap) DirectAddN(a ...uint64) (changed int) + func (b *Bitmap) DirectRemoveN(a ...uint64) (changed int) + func (b *Bitmap) Flip(start, end uint64) *Bitmap + func (b *Bitmap) ForEach(fn func(uint64) error) error + func (b *Bitmap) ForEachRange(start, end uint64, fn func(uint64) error) error + func (b *Bitmap) Freeze() *Bitmap + func (b *Bitmap) Hash(hash uint64) uint64 + func (b *Bitmap) ImportRoaringBits(data []byte, clear bool, log bool, rowSize uint64) (changed int, rowSet map[uint64]int, err error) + func (b *Bitmap) ImportRoaringRawIterator(itr RoaringIterator, clear bool, log bool, rowSize uint64) (changed int, rowSet map[uint64]int, err error) + func (b *Bitmap) Info(includeContainers bool) BitmapInfo + func (b *Bitmap) Intersect(other *Bitmap) *Bitmap + func (b *Bitmap) IntersectInPlace(others ...*Bitmap) + func (b *Bitmap) IntersectionCount(other *Bitmap) uint64 + func (b *Bitmap) Iterator() *Iterator + func (b *Bitmap) IteratorAt(start uint64) *Iterator + func (b *Bitmap) MarshalBinary() ([]byte, error) + func (b *Bitmap) Max() uint64 + func (b *Bitmap) MergeRoaringRawIteratorIntoExists(itr RoaringIterator, rowSize uint64) error + func (b *Bitmap) Min() (uint64, bool) + func (b *Bitmap) MinAt(start uint64) (uint64, bool) + func (b *Bitmap) OffsetRange(offset, start, end uint64) *Bitmap + func (b *Bitmap) Ops() (ops int, opN int) + func (b *Bitmap) Optimize() + func (b *Bitmap) PreferMapping(preferred bool) + func (b *Bitmap) Put(key uint64, c *Container) + func (b *Bitmap) RemapRoaringStorage(data []byte) (mappedAny bool, returnErr error) + func (b *Bitmap) Remove(a ...uint64) (changed bool, err error) + func (b *Bitmap) RemoveN(a ...uint64) (changed int, err error) + func (b *Bitmap) Roaring() []byte + func (b *Bitmap) SanityCheckMapping(from, to uintptr) (mappedIn int64, mappedOut int64, unmappedIn int64, errs int, err error) + func (b *Bitmap) SetOps(ops int, opN int) + func (b *Bitmap) Shift(n int) (*Bitmap, error) + func (b *Bitmap) Size() int + func (b *Bitmap) Slice() []uint64 + func (b *Bitmap) SliceRange(start, end uint64) []uint64 + func (b *Bitmap) String() (r string) + func (b *Bitmap) Union(others ...*Bitmap) *Bitmap + func (b *Bitmap) UnionInPlace(others ...*Bitmap) + func (b *Bitmap) UnmarshalBinary(data []byte) (err error) + func (b *Bitmap) WriteTo(w io.Writer) (n int64, err error) + func (b *Bitmap) Xor(other *Bitmap) *Bitmap + type BitmapBSICountFilter struct + func NewBitmapBSICountFilter(filter *Bitmap) *BitmapBSICountFilter + func (b *BitmapBSICountFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapBSICountFilter) ConsiderKey(key FilterKey, n int32) FilterResult + func (b *BitmapBSICountFilter) Total() (count int32, total int64) + type BitmapBitmapFilter struct + func NewBitmapBitmapFilter(filter *Bitmap, callback func(uint64) error) *BitmapBitmapFilter + func (b *BitmapBitmapFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapBitmapFilter) ConsiderKey(key FilterKey, n int32) FilterResult + func (b *BitmapBitmapFilter) SetCallback(cb func(uint64) error) + type BitmapBitmapTrimmer struct + func NewBitmapBitmapTrimmer(filter *Bitmap, ...) *BitmapBitmapTrimmer + func (b *BitmapBitmapTrimmer) ConsiderKey(key FilterKey, n int32) FilterResult + func (b *BitmapBitmapTrimmer) RewriteData(key FilterKey, data *Container, writeback ContainerWriteback) FilterResult + func (b *BitmapBitmapTrimmer) SetCallback(cb func(FilterKey, *Container, *Container, ContainerWriteback) error) + type BitmapColumnFilter struct + func (f *BitmapColumnFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (f *BitmapColumnFilter) ConsiderKey(key FilterKey, n int32) FilterResult + type BitmapFilter interface + ConsiderData func(key FilterKey, data *Container) FilterResult + ConsiderKey func(key FilterKey, n int32) FilterResult + func NewBitmapColumnFilter(col uint64) BitmapFilter + func NewBitmapRowFilter(callback func(uint64) error, filters ...BitmapFilter) BitmapFilter + func NewBitmapRowFilterMultiFilter(callback func(row uint64) error, filters ...BitmapFilter) BitmapFilter + func NewBitmapRowsFilter(rows []uint64) BitmapFilter + type BitmapInfo struct + BitCount uint64 + ContainerCount int + Containers []ContainerInfo + From uintptr + OpContainers []ContainerInfo + OpDetails []OpInfo + OpN int + Ops int + To uintptr + type BitmapMutexDupFilter struct + func NewBitmapMutexDupFilter(base uint64, details bool, limit int) *BitmapMutexDupFilter + func (b *BitmapMutexDupFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapMutexDupFilter) ConsiderKey(key FilterKey, n int32) FilterResult + func (b *BitmapMutexDupFilter) Report() map[uint64][]uint64 + type BitmapRangeFilter struct + func NewBitmapRangeFilter(min, max FilterKey, keyCallback func(FilterKey, int32) (bool, error), ...) *BitmapRangeFilter + func (b *BitmapRangeFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapRangeFilter) ConsiderKey(key FilterKey, n int32) FilterResult + type BitmapRewriter interface + ConsiderKey func(key FilterKey, n int32) FilterResult + RewriteData func(key FilterKey, data *Container, writeback ContainerWriteback) FilterResult + type BitmapRowFilterBase struct + func NewBitmapRowFilterBase(callback func(row uint64) error) *BitmapRowFilterBase + func (b *BitmapRowFilterBase) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapRowFilterBase) ConsiderKey(key FilterKey, n int32) FilterResult + func (b *BitmapRowFilterBase) DetermineByKey(key FilterKey) (FilterResult, bool) + func (b *BitmapRowFilterBase) SetResult(key FilterKey, result FilterResult) FilterResult + type BitmapRowFilterMultiFilter struct + func (b *BitmapRowFilterMultiFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapRowFilterMultiFilter) ConsiderKey(key FilterKey, n int32) FilterResult + type BitmapRowFilterSingleFilter struct + func NewBitmapRowFilterSingleFilter(callback func(row uint64) error, filter BitmapFilter) *BitmapRowFilterSingleFilter + func (b *BitmapRowFilterSingleFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapRowFilterSingleFilter) ConsiderKey(key FilterKey, n int32) FilterResult + type BitmapRowLimitFilter struct + func NewBitmapRowLimitFilter(limit uint64) *BitmapRowLimitFilter + func (b *BitmapRowLimitFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (b *BitmapRowLimitFilter) ConsiderKey(key FilterKey, n int32) FilterResult + type BitmapRowsFilter struct + func (f *BitmapRowsFilter) ConsiderData(key FilterKey, data *Container) FilterResult + func (f *BitmapRowsFilter) ConsiderKey(key FilterKey, n int32) FilterResult + type BitmapRowsUnion struct + func NewBitmapRowsUnion(rows []uint64) *BitmapRowsUnion + func (f *BitmapRowsUnion) ConsiderData(key FilterKey, data *Container) FilterResult + func (f *BitmapRowsUnion) ConsiderKey(key FilterKey, n int32) FilterResult + func (f *BitmapRowsUnion) Reset() + func (f *BitmapRowsUnion) Results(shard uint64) *Bitmap + type ClearAndSetRewriter struct + func NewClearAndSetRewriter(clear, set ContainerIterator) (*ClearAndSetRewriter, error) + func (csr *ClearAndSetRewriter) ConsiderKey(key FilterKey, n int32) FilterResult + func (csr *ClearAndSetRewriter) RewriteData(key FilterKey, data *Container, writeback ContainerWriteback) FilterResult + type Container struct + func ConvertArrayToBitmap(c *Container) *Container + func ConvertRunToBitmap(c *Container) *Container + func Difference(a, b *Container) *Container + func Intersect(x, y *Container) *Container + func NewContainer() *Container + func NewContainerArray(set []uint16) *Container + func NewContainerArrayCopy(set []uint16) *Container + func NewContainerArrayN(set []uint16, n int32) *Container + func NewContainerBitmap(n int, bitmap []uint64) *Container + func NewContainerBitmapN(bitmap []uint64, n int32) *Container + func NewContainerRun(set []Interval16) *Container + func NewContainerRunCopy(set []Interval16) *Container + func NewContainerRunN(set []Interval16, n int32) *Container + func Optimize(c *Container) *Container + func RemakeContainerArray(c *Container, array []uint16) *Container + func RemakeContainerBitmap(c *Container, bitmap []uint64) *Container + func RemakeContainerBitmapN(c *Container, bitmap []uint64, n int32) *Container + func RemakeContainerFrom(c *Container, source []uint64) (result *Container) + func RemakeContainerRun(c *Container, intervals []Interval16) *Container + func RemakeContainerRunN(c *Container, intervals []Interval16, n int32) *Container + func Union(a, b *Container) (c *Container) + func (c *Container) Add(v uint16) (newC *Container, added bool) + func (c *Container) AsBitmap(target []uint64) (out []uint64) + func (c *Container) BitwiseCompare(c2 *Container) error + func (c *Container) CheckN() + func (c *Container) Clone() (out *Container) + func (c *Container) Contains(v uint16) bool + func (c *Container) CountRange(start, end int32) (n int32) + func (c *Container) Difference(other *Container) *Container + func (c *Container) DifferenceInPlace(other *Container) *Container + func (c *Container) Freeze() *Container + func (c *Container) Mapped() bool + func (c *Container) Max() uint16 + func (c *Container) N() int32 + func (c *Container) Remove(v uint16) (c2 *Container, removed bool) + func (c *Container) Repair() + func (c *Container) SafeN() (int32, bool) + func (c *Container) SetMapped(mapped bool) + func (c *Container) Slice() (r []uint16) + func (c *Container) String() string + func (c *Container) Thaw() *Container + func (c *Container) UnionInPlace(other *Container) (r *Container) + func (c *Container) WriteTo(w io.Writer) (n int64, err error) + type ContainerInfo struct + Alloc int + Flags string + Key uint64 + Mapped bool + N int32 + Pointer uintptr + Type string + type ContainerIterator interface + Close func() + Next func() bool + Value func() (uint64, *Container) + func NewContainerIterator(data []byte) (ContainerIterator, error) + func NewRepeatedRowIteratorFromBytes(data []byte) (ContainerIterator, error) + func NewUnionContainerIterator(iters ...ContainerIterator) ContainerIterator + type ContainerWriteback func(key FilterKey, data *Container) error + type Containers interface + Clone func() Containers + Count func() uint64 + Freeze func() Containers + Get func(key uint64) *Container + GetOrCreate func(key uint64) *Container + Iterator func(key uint64) (citer ContainerIterator, found bool) + Last func() (key uint64, c *Container) + Put func(key uint64, c *Container) + Remove func(key uint64) + Repair func() + Reset func() + ResetN func(int) + Size func() int + Update func(key uint64, fn func(*Container, bool) (*Container, bool)) + UpdateEvery func(fn func(uint64, *Container, bool) (*Container, bool)) + type ErrorList []error + func (a *ErrorList) Append(err error) + func (a *ErrorList) AppendWithPrefix(err error, prefix string) + func (a ErrorList) Error() string + type FileShouldBeTruncatedError interface + SuggestedLength func() int64 + type FilterKey uint64 + const KEY_DONE + func (f FilterKey) Add(x uint64) FilterKey + func (f FilterKey) Done() FilterResult + func (f FilterKey) Fail(err error) FilterResult + func (f FilterKey) Failf(msg string, args ...interface{}) FilterResult + func (f FilterKey) MatchOne() FilterResult + func (f FilterKey) MatchOneRejectRow() FilterResult + func (f FilterKey) MatchOneUntilOffset(offset uint64) FilterResult + func (f FilterKey) MatchOneUntilSameOffset() FilterResult + func (f FilterKey) MatchReject(y, n FilterKey) FilterResult + func (f FilterKey) MatchRow() FilterResult + func (f FilterKey) MatchRowAndDone() FilterResult + func (f FilterKey) MatchRowUntilRow(rowID uint64) FilterResult + func (f FilterKey) NeedData() FilterResult + func (f FilterKey) Reject(n uint64) FilterResult + func (f FilterKey) RejectOne() FilterResult + func (f FilterKey) RejectRow() FilterResult + func (f FilterKey) RejectUntil(until FilterKey) FilterResult + func (f FilterKey) RejectUntilOffset(offset uint64) FilterResult + func (f FilterKey) RejectUntilRow(rowID uint64) FilterResult + func (f FilterKey) Row() uint64 + func (f FilterKey) Sub(o FilterKey) uint64 + type FilterResult struct + Err error + NoKey FilterKey + YesKey FilterKey + type Interval16 struct + Last uint16 + Start uint16 + func AsRuns(c *Container) []Interval16 + type Iterator struct + func (itr *Iterator) Close() + func (itr *Iterator) Next() (v uint64, eof bool) + func (itr *Iterator) Seek(seek uint64) + type OpInfo struct + OpN int + Size int + Type string + type RoaringIterator interface + Clone func() RoaringIterator + ContainerKeys func() (slc []uint64) + Data func() []byte + Len func() (count int64) + Next func() (key uint64, cType byte, n int, length int, pointer *uint16, err error) + NextContainer func() (key uint64, rc *Container) + Remaining func() ([]byte, int64) + Skip func() + func NewRoaringIterator(data []byte) (RoaringIterator, error) v0.22.2 Apr 17, 2024