Versions in this module Expand all Collapse all v0 v0.2.3 May 29, 2026 v0.2.2 May 29, 2026 v0.2.1 May 29, 2026 v0.2.1-beta.1 May 29, 2026 v0.2.0 May 28, 2026 Changes in this version + const ProbeRetention + func WriteBucketedStats(ring []StatsSample, idxPtr *int, sample StatsSample, bucketSecs int64) + type BeaconStatsProvider interface + RelayDropped func() uint64 + RelayForwarded func() uint64 + RelayNotFound func() uint64 + type Callbacks struct + BeaconAddr func() string + BuildStatsPayload func(authenticated bool) map[string]interface{} + Done func() <-chan struct{} + GetAdminToken func() string + GetDashboardToken func() string + GetNodes func() []NodeSnapshot + ListenerAddr func() string + NodeCount func() int + OnlineCount func(threshold time.Time) int + ReadyCh func() <-chan struct{} + RequestCount func() int64 + Save func() + StaleThreshold func() time.Duration + StartTime func() time.Time + TriggerSnapshot func() error + UpdateGauges func() + WriteMetrics func(w io.Writer) + type DashboardStats struct + ActiveNodes int + Daily []StatsSample + DowntimeIntervals [][2]int64 + Hourly []StatsSample + Networks []NetworkStats + Probes map[string]*ProbeState + RelayDropped uint64 + RelayForwarded uint64 + RelayNotFound uint64 + ReleaseBanner *ReleaseBanner + ReqPerDay int64 + RestartEvents []int64 + TotalNodes int + TotalRequests int64 + TotalTrustLinks int + UptimeSecs int64 + Versions map[string]int + type Handler struct + func NewHandler(cb Callbacks) *Handler + func (h *Handler) GetProbeStates() map[string]*ProbeState + func (h *Handler) GetPulseSamples() []PulseSample + func (h *Handler) MaintenanceBanner() string + func (h *Handler) ProbeLoop() + func (h *Handler) PulseLoop() + func (h *Handler) Serve(addr string) error + func (h *Handler) SetBannerPath(path string) + func (h *Handler) SetHTTPProbeAddr(addr string) + func (h *Handler) SetMaintenanceBanner(msg string) + func (h *Handler) SetProbeStates(states map[string]*ProbeState) + func (h *Handler) StatsCollectorLoop(readyCh <-chan struct{}, done <-chan struct{}, ...) + type NetHistoryRing struct + Idx int + Samples []NetworkSampleEntry + Size int + func NewNetHistoryRing(size int) *NetHistoryRing + func (r *NetHistoryRing) Read() []NetworkSampleEntry + func (r *NetHistoryRing) Write(e NetworkSampleEntry) + func (r *NetHistoryRing) WriteBucketed(e NetworkSampleEntry, bucketSecs int64) + type NetworkSampleEntry struct + ID uint16 + Members int + Name string + Online int + Requests int64 + Timestamp int64 + type NetworkStats struct + Daily []NetworkSampleEntry + Hourly []NetworkSampleEntry + ID uint16 + Members int + Name string + Online int + Requests int64 + TrustLinks int + type NodeSnapshot struct + Hostname string + ID uint32 + LastSeen time.Time + type ProbeState struct + CurrentDownStart int64 + DowntimeIntervals [][2]int64 + LastSuccess int64 + type PulseSample struct + Total int64 + Ts int64 + type ReleaseBanner struct + PublishedAt int64 + Version string + type StatsSample struct + OnlineNodes int + Timestamp int64 + TotalNodes int + TotalRequests int64 + TrustLinks int + type StatsSampleResult struct + Global StatsSample + Networks map[uint16]NetworkSampleEntry v0.1.0 May 22, 2026
Go to main page