chore: unregister metrics on stop

sync/metrics.go

@@ -122,13 +122,13 @@ func (m *metrics) recordTotalSynced(totalSynced int) {
 	})
 }
 
-func (m *metrics) recordSyncLoopStarted(ctx context.Context) {
+func (m *metrics) syncingStarted(ctx context.Context) {
 	m.observe(ctx, func(ctx context.Context) {
 		m.syncLoopStarted.Add(ctx, 1)
 	})
 }
 
-func (m *metrics) recordTrustedPeersOutOfSync(ctx context.Context) {
+func (m *metrics) peersOutOufSync(ctx context.Context) {
 	m.observe(ctx, func(ctx context.Context) {
 		m.trustedPeersOutOfSync.Add(ctx, 1)
 	})
@@ -159,3 +159,10 @@ func (m *metrics) observe(ctx context.Context, observeFn func(context.Context))
 	}
 	observeFn(ctx)
 }
+
+func (m *metrics) Close() error {
+	if m == nil {
+		return nil
+	}
+	return m.syncReg.Unregister()
+}

sync/sync.go

@@ -109,7 +109,7 @@ func (s *Syncer[H]) Start(ctx context.Context) error {
 // Stop stops Syncer.
 func (s *Syncer[H]) Stop(context.Context) error {
 	s.cancel()
-	return nil
+	return s.metrics.Close()
 }
 
 // SyncWait blocks until ongoing sync is done.
@@ -180,7 +180,7 @@ func (s *Syncer[H]) syncLoop() {
 	for {
 		select {
 		case <-s.triggerSync:
-			s.metrics.recordSyncLoopStarted(s.ctx)
+			s.metrics.syncingStarted(s.ctx)
 			s.sync(s.ctx)
 		case <-s.ctx.Done():
 			return

sync/sync_head.go

@@ -102,7 +102,7 @@ func (s *Syncer[H]) subjectiveHead(ctx context.Context) (H, error) {
 		log.Warnw("subjective initialization with an old header", "height", trustHead.Height())
 	}
 	log.Warn("trusted peer is out of sync")
-	s.metrics.recordTrustedPeersOutOfSync(s.ctx)
+	s.metrics.peersOutOufSync(s.ctx)
 	return trustHead, nil
 }