Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeduplicateMessage ¶ added in v0.35.0
type DeduplicateMessage struct { Message *whispertypes.Message `json:"message"` Metadata Metadata `json:"metadata"` Payload string `json:"payload"` MessageType v1.StatusMessageT `json:"messageType"` ParsedMessage interface{} `json:"parsedMessage"` }
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 ¶ added in v0.35.0
func (d *Deduplicator) AddMessageByID(messageIDs [][]byte) error
AddMessageByID adds a message to the deduplicator DB, so it will be filtered out.
func (*Deduplicator) AddMessagesByID ¶ added in v0.35.0
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.
Click to show internal directories.
Click to hide internal directories.