diff --git a/pkg/node/peer.go b/pkg/node/peer.go index 3331f2c..855261f 100644 --- a/pkg/node/peer.go +++ b/pkg/node/peer.go @@ -232,9 +232,8 @@ func (r *PeerRegistry) ListAllowedPublicKeys() []string { return keys } -// AddPeer adds a new peer to the registry. -// Note: Persistence is debounced (writes batched every 5s). Call Close() to ensure -// all changes are flushed to disk before shutdown. +// registry.AddPeer(&Peer{ID: "abc123", Name: "worker-1", Address: "10.0.0.2:9090", Role: RoleWorker}) +// Persistence is debounced — call Close() before shutdown to flush all pending writes. func (r *PeerRegistry) AddPeer(peer *Peer) error { r.mu.Lock()