store

Aug 11, 2021

Changes in this version

+ var DefaultProvider = Provider(BufferedPaginatedStoreConstructor)

Jul 29, 2021

Changes in this version

+ var BufferedPaginatedStoreConstructor = Provider(func() Store { ... })

+ var DenseStoreConstructor = Provider(func() Store { ... })

+ var SparseStoreConstructor = Provider(func() Store { ... })

+ func DecodeAndMergeWith(s Store, b *[]byte, binEncodingMode enc.SubFlag) error

+ func MergeWithProto(store Store, pb *sketchpb.Store)

+ type BufferedPaginatedStore struct

+ func NewBufferedPaginatedStore() *BufferedPaginatedStore

+ func (s *BufferedPaginatedStore) Add(index int)

+ func (s *BufferedPaginatedStore) AddBin(bin Bin)

+ func (s *BufferedPaginatedStore) AddWithCount(index int, count float64)

+ func (s *BufferedPaginatedStore) Bins() <-chan Bin

+ func (s *BufferedPaginatedStore) Clear()

+ func (s *BufferedPaginatedStore) Copy() Store

+ func (s *BufferedPaginatedStore) DecodeAndMergeWith(b *[]byte, encodingMode enc.SubFlag) error

+ func (s *BufferedPaginatedStore) Encode(b *[]byte, t enc.FlagType)

+ func (s *BufferedPaginatedStore) ForEach(f func(index int, count float64) (stop bool))

+ func (s *BufferedPaginatedStore) IsEmpty() bool

+ func (s *BufferedPaginatedStore) KeyAtRank(rank float64) int

+ func (s *BufferedPaginatedStore) MaxIndex() (int, error)

+ func (s *BufferedPaginatedStore) MergeWith(other Store)

+ func (s *BufferedPaginatedStore) MergeWithProto(pb *sketchpb.Store)

+ func (s *BufferedPaginatedStore) MinIndex() (int, error)

+ func (s *BufferedPaginatedStore) Reweight(w float64) error

+ func (s *BufferedPaginatedStore) ToProto() *sketchpb.Store

+ func (s *BufferedPaginatedStore) TotalCount() float64

type CollapsingHighestDenseStore

+ func (s *CollapsingHighestDenseStore) Clear()

+ func (s *CollapsingHighestDenseStore) DecodeAndMergeWith(r *[]byte, encodingMode enc.SubFlag) error

type CollapsingLowestDenseStore

+ func (s *CollapsingLowestDenseStore) Clear()

+ func (s *CollapsingLowestDenseStore) DecodeAndMergeWith(r *[]byte, encodingMode enc.SubFlag) error

type DenseStore

+ func (s *DenseStore) Clear()

+ func (s *DenseStore) DecodeAndMergeWith(b *[]byte, encodingMode enc.SubFlag) error

+ func (s *DenseStore) Encode(b *[]byte, t enc.FlagType)

+ func (s *DenseStore) ForEach(f func(index int, count float64) (stop bool))

+ func (s *DenseStore) Reweight(w float64) error

+ type Provider func() Store

+ type SparseStore struct

+ func NewSparseStore() *SparseStore

+ func (s *SparseStore) Add(index int)

+ func (s *SparseStore) AddBin(bin Bin)

+ func (s *SparseStore) AddWithCount(index int, count float64)

+ func (s *SparseStore) Bins() <-chan Bin

+ func (s *SparseStore) Clear()

+ func (s *SparseStore) Copy() Store

+ func (s *SparseStore) DecodeAndMergeWith(b *[]byte, encodingMode enc.SubFlag) error

+ func (s *SparseStore) Encode(b *[]byte, t enc.FlagType)

+ func (s *SparseStore) ForEach(f func(index int, count float64) (stop bool))

+ func (s *SparseStore) IsEmpty() bool

+ func (s *SparseStore) KeyAtRank(rank float64) int

+ func (s *SparseStore) MaxIndex() (int, error)

+ func (s *SparseStore) MergeWith(store Store)

+ func (s *SparseStore) MinIndex() (int, error)

+ func (s *SparseStore) Reweight(w float64) error

+ func (s *SparseStore) ToProto() *sketchpb.Store

+ func (s *SparseStore) TotalCount() float64

type Store

+ Clear func()

+ DecodeAndMergeWith func(b *[]byte, binEncodingMode enc.SubFlag) error

+ Encode func(b *[]byte, t enc.FlagType)

+ ForEach func(f func(index int, count float64) (stop bool))

+ Reweight func(w float64) error

Dec 14, 2020

Changes in this version

+ type Bin struct

+ func NewBin(index int, count float64) (*Bin, error)

+ func (b *Bin) Count() float64

+ func (b *Bin) Index() int

+ type CollapsingHighestDenseStore struct

+ func NewCollapsingHighestDenseStore(maxNumBins int) *CollapsingHighestDenseStore

+ func (s *CollapsingHighestDenseStore) Add(index int)

+ func (s *CollapsingHighestDenseStore) AddBin(bin Bin)

+ func (s *CollapsingHighestDenseStore) AddWithCount(index int, count float64)

+ func (s *CollapsingHighestDenseStore) Copy() Store

+ func (s *CollapsingHighestDenseStore) MergeWith(other Store)

+ type CollapsingLowestDenseStore struct

+ func NewCollapsingLowestDenseStore(maxNumBins int) *CollapsingLowestDenseStore

+ func (s *CollapsingLowestDenseStore) Add(index int)

+ func (s *CollapsingLowestDenseStore) AddBin(bin Bin)

+ func (s *CollapsingLowestDenseStore) AddWithCount(index int, count float64)

+ func (s *CollapsingLowestDenseStore) Copy() Store

+ func (s *CollapsingLowestDenseStore) MergeWith(other Store)

+ type DenseStore struct

+ func FromProto(pb *sketchpb.Store) *DenseStore

+ func NewDenseStore() *DenseStore

+ func (s *DenseStore) Add(index int)

+ func (s *DenseStore) AddBin(bin Bin)

+ func (s *DenseStore) AddWithCount(index int, count float64)

+ func (s *DenseStore) Bins() <-chan Bin

+ func (s *DenseStore) Copy() Store

+ func (s *DenseStore) IsEmpty() bool

+ func (s *DenseStore) KeyAtRank(rank float64) int

+ func (s *DenseStore) MaxIndex() (int, error)

+ func (s *DenseStore) MergeWith(other Store)

+ func (s *DenseStore) MinIndex() (int, error)

+ func (s *DenseStore) ToProto() *sketchpb.Store

+ func (s *DenseStore) TotalCount() float64

+ type Store interface

+ Add func(index int)

+ AddBin func(bin Bin)

+ AddWithCount func(index int, count float64)

+ Bins func() <-chan Bin

+ Copy func() Store

+ IsEmpty func() bool

+ KeyAtRank func(rank float64) int

+ MaxIndex func() (int, error)

+ MergeWith func(store Store)

+ MinIndex func() (int, error)

+ ToProto func() *sketchpb.Store

+ TotalCount func() float64