diff --git a/pkg/node/transport.go b/pkg/node/transport.go index 85dcad9..e212b0a 100644 --- a/pkg/node/transport.go +++ b/pkg/node/transport.go @@ -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),