Versions in this module Expand all Collapse all v1 v1.0.0 Aug 24, 2023 Changes in this version + func MakeRedisClient(options RedisConnOptions) + type AbstractBucket struct + func (bucket *AbstractBucket) Size() uint64 + type AbstractCountMinSketch struct + func (cms *AbstractCountMinSketch) GetColumns() uint + func (cms *AbstractCountMinSketch) GetRows() uint + type AbstractCuckooFilter struct + func (cuckooFilter *AbstractCuckooFilter) BucketSize() uint64 + func (cuckooFilter *AbstractCuckooFilter) CellSize() uint64 + func (cuckooFilter *AbstractCuckooFilter) CuckooPositiveRate() float64 + func (cuckooFilter *AbstractCuckooFilter) FingerPrintLength() uint64 + func (cuckooFilter *AbstractCuckooFilter) Retries() uint64 + func (cuckooFilter *AbstractCuckooFilter) Size() uint64 + type AbstractHyperLogLog struct + func (h *AbstractHyperLogLog) Accuracy() float64 + func (h *AbstractHyperLogLog) NumRegisters() uint64 + type BaseBucket interface + Size func() uint64 + type BaseCountMinSketch interface + Count func(data []byte) uint64 + CountString func(data string) uint64 + GetColumns func() uint + GetRows func() uint + Update func(data []byte, count uint64) + UpdateOnce func(data []byte) + UpdateString func(data string, count uint64) + type BaseCuckooFilter interface + BucketSize func() uint64 + CellSize func() uint64 + FingerPrintLength func() uint64 + Length func() uint64 + Retries func() uint64 + Size func() uint64 + type BaseFilter interface + Insert func(element T) (bool, error) + Lookup func(element T) (bool, error) + type BaseHyperLogLog interface + Accuracy func() float64 + Count func(withCorrection bool, withRoundingOff bool) uint64 + Equals func(g *HyperLogLog) bool + NumRegisters func() uint64 + Update func(data []byte) + type BitSetMem struct + type BitSetRedis struct + type BloomFilter struct + func NewBloomFilterWithBitSet(size, numHashes uint, filter IBitSet, metadataKey string) (*BloomFilter, error) + func NewMemBloomFilterFromBitSet(data []uint64, numHashes uint) *BloomFilter + func NewMemBloomFilterWithParameters(numItems uint, errorRate float64) (*BloomFilter, error) + func NewRedisBloomFilterFromBitSet(data []uint64, numHashes uint) (*BloomFilter, error) + func NewRedisBloomFilterFromKey(metadataKey string) (*BloomFilter, error) + func NewRedisBloomFilterWithParameters(numItems uint, errorRate float64) (*BloomFilter, error) + func (aFilter *BloomFilter) Equals(bFilter *BloomFilter) (bool, error) + func (bloomFilter *BloomFilter) BloomPositiveRate() float64 + func (bloomFilter *BloomFilter) Export() ([]byte, error) + func (bloomFilter *BloomFilter) GetBitSet() *IBitSet + func (bloomFilter *BloomFilter) GetCap() uint + func (bloomFilter *BloomFilter) GetMetadataKey() string + func (bloomFilter *BloomFilter) GetNumHashes() uint + func (bloomFilter *BloomFilter) Import(data []byte) error + func (bloomFilter *BloomFilter) Insert(data []byte) *BloomFilter + func (bloomFilter *BloomFilter) InsertString(data string) *BloomFilter + func (bloomFilter *BloomFilter) Lookup(data []byte) bool + func (bloomFilter *BloomFilter) LookupString(data string) bool + func (bloomFilter *BloomFilter) ReadFrom(stream io.Reader) (int64, error) + func (bloomFilter *BloomFilter) WriteTo(stream io.Writer) (int64, error) + type BucketMem struct + type BucketRedis struct + type CountMinSketch struct + func NewCountMinSketch(rows, columns uint) (*CountMinSketch, error) + func NewCountMinSketchFromEstimates(errorRate, delta float64) (*CountMinSketch, error) + func (cms *CountMinSketch) Count(data []byte) uint64 + func (cms *CountMinSketch) CountString(data string) uint64 + func (cms *CountMinSketch) Equals(cms1 *CountMinSketch) bool + func (cms *CountMinSketch) Export() ([]byte, error) + func (cms *CountMinSketch) Import(data []byte) error + func (cms *CountMinSketch) Merge(cms1 *CountMinSketch) error + func (cms *CountMinSketch) ReadFrom(stream io.Reader) (int64, error) + func (cms *CountMinSketch) Update(data []byte, count uint64) + func (cms *CountMinSketch) UpdateOnce(data []byte) + func (cms *CountMinSketch) UpdateString(data string, count uint64) + func (cms *CountMinSketch) WriteTo(stream io.Writer) (int64, error) + type CountMinSketchRedis struct + func NewCountMinSketchRedis(rows, columns uint) (*CountMinSketchRedis, error) + func NewCountMinSketchRedisFromEstimates(errorRate, delta float64) (*CountMinSketchRedis, error) + func NewCountMinSketchRedisFromKey(metadataKey string) (*CountMinSketchRedis, error) + func (cms *CountMinSketchRedis) Count(data []byte) (uint64, error) + func (cms *CountMinSketchRedis) CountString(data string) (uint64, error) + func (cms *CountMinSketchRedis) Equals(cms1 *CountMinSketchRedis) (bool, error) + func (cms *CountMinSketchRedis) Export() ([]byte, error) + func (cms *CountMinSketchRedis) Import(data []byte, withNewKey bool) error + func (cms *CountMinSketchRedis) Merge(cms1 *CountMinSketchRedis) error + func (cms *CountMinSketchRedis) MetadataKey() string + func (cms *CountMinSketchRedis) Update(data []byte, count uint64) error + func (cms *CountMinSketchRedis) UpdateOnce(data []byte) + func (cms *CountMinSketchRedis) UpdateString(data string, count uint64) error + type CuckooFilter struct + func NewCuckooFilter(size, bucketSize, fingerPrintLength uint64) *CuckooFilter + func NewCuckooFilterWithErrorRate(size, bucketSize, retries uint64, errorRate float64) *CuckooFilter + func NewCuckooFilterWithRetries(size, bucketSize, fingerPrintLength, retries uint64) *CuckooFilter + func (aFilter *CuckooFilter) Equals(bFilter *CuckooFilter) bool + func (cuckooFilter *CuckooFilter) Export() ([]byte, error) + func (cuckooFilter *CuckooFilter) Import(data []byte) error + func (cuckooFilter *CuckooFilter) Insert(data []byte, destructive bool) bool + func (cuckooFilter *CuckooFilter) Length() uint64 + func (cuckooFilter *CuckooFilter) Lookup(data []byte) bool + func (cuckooFilter *CuckooFilter) ReadFrom(stream io.Reader) (int64, error) + func (cuckooFilter *CuckooFilter) Remove(data []byte) bool + func (cuckooFilter *CuckooFilter) WriteTo(stream io.Writer) (int64, error) + type CuckooFilterRedis struct + func NewCuckooFilterRedis(size, bucketSize, fingerPrintLength uint64) (*CuckooFilterRedis, error) + func NewCuckooFilterRedisFromKey(metadataKey string) (*CuckooFilterRedis, error) + func NewCuckooFilterRedisWithErrorRate(size, bucketSize, retries uint64, errorRate float64) (*CuckooFilterRedis, error) + func NewCuckooFilterRedisWithRetries(size, bucketSize, fingerPrintLength, retries uint64) (*CuckooFilterRedis, error) + func (aFilter CuckooFilterRedis) Equals(bFilter CuckooFilterRedis) (bool, error) + func (cuckooFilter *CuckooFilterRedis) Insert(data []byte, destructive bool) bool + func (cuckooFilter *CuckooFilterRedis) Length() uint64 + func (cuckooFilter *CuckooFilterRedis) Lookup(data []byte) (bool, error) + func (cuckooFilter *CuckooFilterRedis) Remove(data []byte) (bool, error) + func (cuckooFilter CuckooFilterRedis) Key() string + func (cuckooFilter CuckooFilterRedis) MetadataKey() string + func (filter *CuckooFilterRedis) Export() ([]byte, error) + func (filter *CuckooFilterRedis) Import(data []byte, withNewRedisKey bool) error + type HyperLogLog struct + func NewHyperLogLog(numRegisters uint64) (*HyperLogLog, error) + func (h *HyperLogLog) Count(withCorrection, withRoundingOff bool) uint64 + func (h *HyperLogLog) Equals(g *HyperLogLog) bool + func (h *HyperLogLog) Export() ([]byte, error) + func (h *HyperLogLog) Import(data []byte) error + func (h *HyperLogLog) Merge(g *HyperLogLog) error + func (h *HyperLogLog) ReadFrom(stream io.Reader) (int64, error) + func (h *HyperLogLog) Reset() + func (h *HyperLogLog) Update(data []byte) + func (h *HyperLogLog) WriteTo(stream io.Writer) (int64, error) + type HyperLogLogRedis struct + func NewHyperLogLogRedis(numRegisters uint64) (*HyperLogLogRedis, error) + func NewHyperLogLogRedisFromKey(metadataKey string) (*HyperLogLogRedis, error) + func (h *HyperLogLogRedis) Count(withCorrection bool, withRoundingOff bool) (uint64, error) + func (h *HyperLogLogRedis) Equals(g *HyperLogLogRedis) (bool, error) + func (h *HyperLogLogRedis) Export() ([]byte, error) + func (h *HyperLogLogRedis) Import(data []byte, withNewKey bool) error + func (h *HyperLogLogRedis) Merge(g *HyperLogLogRedis) error + func (h *HyperLogLogRedis) MetadataKey() string + func (h *HyperLogLogRedis) Update(data []byte) error + type IBitSet interface + type RedisConnOptions struct + Address string + ConnectionTimeout time.Duration + DB int + Network string + Password string + PoolSize int + ReadTimeout time.Duration + TLSConfig *tls.Config + Username string + WriteTimeout time.Duration + func ParseRedisURI(uri string) (*RedisConnOptions, error) + type TopK struct + func NewTopK(k uint, errorRate, accuracy float64) *TopK + func (t *TopK) Equals(u *TopK) (bool, error) + func (t *TopK) Export() ([]byte, error) + func (t *TopK) Import(data []byte) error + func (t *TopK) Insert(data []byte, count uint64) + func (t *TopK) ReadFrom(stream io.Reader) (int64, error) + func (t *TopK) Values() []TopKElement + func (t *TopK) WriteTo(stream io.Writer) (int64, error) + type TopKElement struct + type TopKRedis struct + func NewTopKRedis(k uint, errorRate, accuracy float64) *TopKRedis + func NewTopKRedisFromKey(metadataKey string) *TopKRedis + func (t *TopKRedis) Equals(u *TopKRedis) (bool, error) + func (t *TopKRedis) Export() ([]byte, error) + func (t *TopKRedis) Import(data []byte, withNewKey bool) error + func (t *TopKRedis) Insert(data []byte, count uint64) error + func (t *TopKRedis) MetadataKey() string + func (t *TopKRedis) Values() ([]TopKElement, error)