dedup

Documentation

Index

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

Types

type DeduplicateMessage

type DeduplicateMessage struct {
	DedupID []byte           `json:"id"`
	Message *whisper.Message `json:"message"`
}

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) AddMessageByID

func (d *Deduplicator) AddMessageByID(messageIDs [][]byte) error

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

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) []DeduplicateMessage

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