Method runStatsLoop

internal/carrier/stats.go:19–30

runStatsLoop periodically emits a one-line summary of carrier health so a developer can spot drift (rising RST count, blacklisted endpoints, etc.) without grepping for individual events. Returns when ctx is canceled.

(ctx context.Context)

// developer can spot drift (rising RST count, blacklisted endpoints, etc.)
// without grepping for individual events. Returns when ctx is canceled.
func (c *Client) runStatsLoop(ctx context.Context) {
	t := time.NewTicker(statsInterval)
	defer t.Stop()
	for {
		select {
		case <-ctx.Done():
			return
		case <-t.C:
			c.logStats()
		}
	}
}

func (c *Client) logStats() {
	c.mu.Lock()