Versions in this module Expand all Collapse all v0 v0.2.5 Jun 19, 2026 Changes in this version + type AuditEntrySnapshot struct + Action string + Details string + Hash string + NetworkID uint16 + NodeID uint32 + Timestamp string + type BackupEntry struct + ModUnix int64 + Name string + SizeBytes int64 + type BreakerListEntry struct + AllowedTotal int64 + DeniedTotal int64 + LastDeniedAt *time.Time + Name string + Reason string + State string + UpdatedAt *time.Time type Callbacks + AuditRecent func(n int) []AuditEntrySnapshot + BackupsList func() ([]BackupEntry, error) + BreakerAllow func(name string) (allowed bool, reason string) + BreakerDelete func(name string) error + BreakerList func() []BreakerListEntry + BreakerSet func(name, state, reason string) error + BuildInfo func() map[string]string + GetLogLevel func() string + HealthSnapshot func() map[string]any + MemberKick func(netID uint16, nodeID uint32, reason string) error + MemberRole func(netID uint16, nodeID uint32, role, reason string) error + MembersList func(netID uint16) ([]MemberSnapshot, error) + NetworksList func() []NetworkSnapshot + ReplicationStatus func() ReplicationSnapshot + SetLogLevel func(level string) error + TotalEverRegistered func() int64 + WhitelistGet func() ([]byte, error) + WhitelistSet func(data []byte) error type Handler + func (h *Handler) RecentThroughput(window int) float64 + func (h *Handler) SetBackupsList(fn func() ([]BackupEntry, error)) + func (h *Handler) SetLogLevelCallbacks(get func() string, set func(string) error) + func (h *Handler) SetReplicationStatus(fn func() ReplicationSnapshot) + func (h *Handler) SetWhitelistCallbacks(get func() ([]byte, error), set func([]byte) error) + type MemberSnapshot struct + Hostname string + LastSeenUnix int64 + NodeID uint32 + Role string + type NetworkSnapshot struct + AdminsCount int + Enterprise bool + ID uint16 + MembersCount int + Name string + OwnersCount int + PolicySet bool + type ReplicationSnapshot struct + IsStandby bool + LastPushAgeSecs int64 + LastPushUnix int64 + Subscribers int + Term uint64 v0.2.4 Jun 7, 2026 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