Function NewPropagationDelayTracker

kv/memberlist/propagation_tracker.go:82–117

NewPropagationDelayTracker creates a new PropagationDelayTracker service.

(
	kv *KV,
	cfg PropagationDelayTrackerConfig,
	nodeName string,
	logger log.Logger,
	registerer prometheus.Registerer,
)

// NewPropagationDelayTracker creates a new PropagationDelayTracker service.
func NewPropagationDelayTracker(
	kv *KV,
	cfg PropagationDelayTrackerConfig,
	nodeName string,
	logger log.Logger,
	registerer prometheus.Registerer,
) *PropagationDelayTracker {
	t := &PropagationDelayTracker{
		cfg:         cfg,
		nodeName:    nodeName,
		kv:          kv,
		codec:       GetPropagationDelayTrackerCodec(),
		logger:      log.With(logger, "component", "memberlist-propagation-delay-tracker"),
		seenBeacons: make(map[uint64]struct{}),
		propagationDelay: promauto.With(registerer).NewHistogram(prometheus.HistogramOpts{
			Name:                            "memberlist_propagation_tracker_delay_seconds",
			Help:                            "Time from beacon publish to receive.",
			NativeHistogramBucketFactor:     1.1,
			NativeHistogramMaxBucketNumber:  100,
			NativeHistogramMinResetDuration: 1 * time.Hour,
			Buckets:                         prometheus.DefBuckets,
		}),
		beaconsPublishedTotal: promauto.With(registerer).NewCounter(prometheus.CounterOpts{
			Name: "memberlist_propagation_tracker_beacons_published_total",
			Help: "Total number of beacons published by this node.",
		}),
		beaconsReceivedTotal: promauto.With(registerer).NewCounter(prometheus.CounterOpts{
			Name: "memberlist_propagation_tracker_beacons_received_total",
			Help: "Total number of unique beacons received.",
		}),
	}

	t.Service = services.NewBasicService(nil, t.running, nil).WithName("propagation-delay-tracker")

	return t
}

func (t *PropagationDelayTracker) running(ctx context.Context) error {
	t.startupTime = time.Now().UnixMilli()