dupemap

Documentation

Index

• type DupeMap
  • func NewDupeMap(expire int64, capacity uint32) *DupeMap
  • func NewDupeMapDefault() *DupeMap
  • func (d *DupeMap) HasAnywhere(payload *bytes.Buffer) bool
  • func (d *DupeMap) Size() int
• type TmpMap
  • func NewTmpMap(capacity uint32, expire int64) *TmpMap
  • func (t *TmpMap) Add(b *bytes.Buffer) bool
  • func (t *TmpMap) CleanExpired()
  • func (t *TmpMap) Has(b *bytes.Buffer) bool
  • func (t *TmpMap) IsExpired() bool
  • func (t *TmpMap) Size() int

Types

type DupeMap

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

TODO: DupeMap should deal with value bytes.Buffer rather than pointers as it is not supposed to mutate the struct.

func NewDupeMap

func NewDupeMap(expire int64, capacity uint32) *DupeMap

NewDupeMap creates new dupemap instance. Expire is number of seconds.

func NewDupeMapDefault

func NewDupeMapDefault() *DupeMap

NewDupeMapDefault returns a dupemap instance with default config.

func (*DupeMap) HasAnywhere

func (d *DupeMap) HasAnywhere(payload *bytes.Buffer) bool

HasAnywhere tests if any of Cuckoo Filters (a filter per round) knows already this payload. Similarly to Bloom Filters, False positive matches are possible, but false negatives are not. In addition, it also resets all expired items.

func (*DupeMap) Size

func (d *DupeMap) Size() int

Size returns the bytes count allocated by the underlying filter.

type TmpMap

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

func NewTmpMap

func NewTmpMap(capacity uint32, expire int64) *TmpMap

NewTmpMap creates a TmpMap instance.

func (*TmpMap) Add

func (t *TmpMap) Add(b *bytes.Buffer) bool

Add the hash of a buffer to the blacklist. Returns true if the element was added. False otherwise.

func (*TmpMap) CleanExpired

func (t *TmpMap) CleanExpired()

CleanExpired resets all cache instances that has expired.

func (*TmpMap) Has

func (t *TmpMap) Has(b *bytes.Buffer) bool

func (*TmpMap) IsExpired

func (t *TmpMap) IsExpired() bool

IsExpired returns true if TmpMap has expired.

func (*TmpMap) Size

func (t *TmpMap) Size() int

Size returns overall size of all filters.