rotate

Documentation

Overview

Package rotate implements a sliding set of three BloomFilters: `previous`, `current` and `next` and the BloomFilter interface

Index

• func SetCompressor(c Compressor)
• type BloomFilter
  • func New(ctx context.Context, cfg Config) *BloomFilter
  • func (bs *BloomFilter) Add(elem []byte)
  • func (bs *BloomFilter) Check(elem []byte) bool
  • func (bs *BloomFilter) Close()
  • func (bs *BloomFilter) MarshalBinary() ([]byte, error)
  • func (bs *BloomFilter) Union(that interface{}) (float64, error)
  • func (bs *BloomFilter) UnmarshalBinary(data []byte) error
• type Compressor
• type Config
• type Gzip
  • func (g *Gzip) NewReader(r io.Reader) (io.Reader, error)
  • func (g *Gzip) NewWriter(w io.Writer) io.WriteCloser
• type SerializableBloomFilter

Functions

func SetCompressor

func SetCompressor(c Compressor)

Types

type BloomFilter

type BloomFilter struct {
	Previous, Current, Next *filter.BloomFilter
	Config                  Config
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, cfg Config) *BloomFilter

func (*BloomFilter) Add

func (bs *BloomFilter) Add(elem []byte)

func (*BloomFilter) Check

func (bs *BloomFilter) Check(elem []byte) bool

func (*BloomFilter) Close

func (bs *BloomFilter) Close()

func (*BloomFilter) MarshalBinary

func (bs *BloomFilter) MarshalBinary() ([]byte, error)

func (*BloomFilter) Union

func (bs *BloomFilter) Union(that interface{}) (float64, error)

func (*BloomFilter) UnmarshalBinary

func (bs *BloomFilter) UnmarshalBinary(data []byte) error

type Compressor

type Compressor interface {
	NewWriter(io.Writer) io.WriteCloser
	NewReader(io.Reader) (io.Reader, error)
}

type Config

type Config struct {
	go_bloom_filter.Config
	TTL uint
}

type Gzip

type Gzip int

func (*Gzip) NewReader

func (g *Gzip) NewReader(r io.Reader) (io.Reader, error)

func (*Gzip) NewWriter

func (g *Gzip) NewWriter(w io.Writer) io.WriteCloser

type SerializableBloomFilter

type SerializableBloomFilter struct {
	Previous, Current, Next *filter.BloomFilter
	Config                  Config
}