From 45a1dcc987372b3bc55c2b7e383bf7e13db6e069 Mon Sep 17 00:00:00 2001 From: Claude Date: Thu, 2 Apr 2026 07:54:06 +0100 Subject: [PATCH] ax(node): replace prose comment on NewMessageDeduplicator with usage example Co-Authored-By: Charon --- pkg/node/transport.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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),