ax(node): replace prose comment on NewMessageDeduplicator with usage example
Co-Authored-By: Charon <charon@lethean.io>
This commit is contained in:
parent
27fd294ca7
commit
45a1dcc987
1 changed files with 3 additions and 1 deletions
|
|
@ -60,7 +60,9 @@ type MessageDeduplicator struct {
|
|||
ttl time.Duration
|
||||
}
|
||||
|
||||
// NewMessageDeduplicator creates a deduplicator with specified TTL
|
||||
// dedup := node.NewMessageDeduplicator(5 * time.Minute)
|
||||
// dedup.Mark(msg.ID)
|
||||
// if dedup.IsDuplicate(msg.ID) { continue }
|
||||
func NewMessageDeduplicator(ttl time.Duration) *MessageDeduplicator {
|
||||
d := &MessageDeduplicator{
|
||||
seen: make(map[string]time.Time),
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue