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) AddMessagesByID(messageIDs [][]byte) error
  • func (d *Deduplicator) Deduplicate(messages []*DeduplicateMessage) []*DeduplicateMessage
• type Metadata

Types

type DeduplicateMessage

type DeduplicateMessage struct {
	Message  *whisper.Message `json:"message"`
	Metadata Metadata         `json:"metadata"`
}

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

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

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

func (*Deduplicator) Deduplicate

func (d *Deduplicator) Deduplicate(messages []*DeduplicateMessage) []*DeduplicateMessage

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

type Metadata

type Metadata struct {
	DedupID      []byte        `json:"dedupId"`
	EncryptionID hexutil.Bytes `json:"encryptionId"`
	MessageID    hexutil.Bytes `json:"messageId"`
}