dedup

Documentation

Index

• type Deduplicator
  • func NewDeduplicator(keyPairProvider keyPairProvider, db *leveldb.DB) *Deduplicator
  • func (d *Deduplicator) AddMessages(messages []*whisper.Message) error
  • func (d *Deduplicator) Deduplicate(messages []*whisper.Message) []*whisper.Message

Types

type Deduplicator

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

Deduplicator filters out already received messages for a current filter. It keeps a limited cache of the messages.

func NewDeduplicator

func NewDeduplicator(keyPairProvider keyPairProvider, db *leveldb.DB) *Deduplicator

NewDeduplicator creates a new deduplicator

func (*Deduplicator) AddMessages

func (d *Deduplicator) AddMessages(messages []*whisper.Message) error

AddMessages adds a message to the deduplicator DB, so it will be filtered out.

func (*Deduplicator) Deduplicate

func (d *Deduplicator) Deduplicate(messages []*whisper.Message) []*whisper.Message

Deduplicate receives a list of whisper messages and returns the list of the messages that weren't filtered previously for the specified filter.