chore: quick update fix/version at 2025-09-18 14:28:25

Author: kooksee

monitor/example/main.go

@@ -0,0 +1,82 @@
+// main.go
+package main
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+	"time"
+
+	"github.com/pubgo/funk/monitor"
+)
+
+func main() {
+	// 创建带 Tags 的元数据
+	status := monitor.String("app_status", "ok", "Current application status",
+		map[string]any{
+			"group":   "health",
+			"mutable": true,
+		})
+
+	replicas := monitor.Int("replicas", 1, "Number of replicas",
+		map[string]any{
+			"group": "scaling",
+			"min":   1,
+			"max":   10,
+		})
+
+	_ = monitor.Duration("http_timeout", 5*time.Second, "HTTP request timeout",
+		map[string]any{
+			"unit":  "seconds",
+			"group": "network",
+		})
+
+	labels := monitor.StringMap("labels", map[string]string{"env": "dev"}, "Node labels",
+		map[string]any{
+			"group": "metadata",
+		})
+
+	_ = monitor.String("api_key", "sk-xxxx", "API authentication key",
+		map[string]any{
+			"sensitive": true,
+			"group":     "security",
+		})
+
+	// 模拟更新
+	go func() {
+		time.Sleep(2 * time.Second)
+		status.Set("degraded")
+
+		time.Sleep(2 * time.Second)
+		replicas.Set(replicas.Get() + 2)
+
+		time.Sleep(2 * time.Second)
+		current := labels.Get()
+		current["updated"] = time.Now().Format("15:04")
+		labels.Set(current)
+	}()
+
+	// HTTP handler：只输出非敏感字段
+	http.HandleFunc("/metadata", func(w http.ResponseWriter, r *http.Request) {
+		data := extractPublicMetadata()
+		w.Header().Set("Content-Type", "application/json")
+		json.NewEncoder(w).Encode(data)
+	})
+
+	log.Println("Monitor server listening on :8080")
+	log.Fatal(http.ListenAndServe(":8080", nil))
+}
+
+// extractPublicMetadata 导出所有非敏感元数据
+func extractPublicMetadata() map[string]any {
+	m := make(map[string]any)
+	monitor.VisitAll(func(e *monitor.Entry) {
+		// 跳过敏感字段
+		if sensitive, ok := e.Tags["sensitive"].(bool); ok && sensitive {
+			m[e.Name] = "******"
+			return
+		}
+		m[e.Name] = e.Getter()
+	})
+	return m
+}

monitor/monitor.go

@@ -0,0 +1,85 @@
+// monitor/monitor.go
+package monitor
+
+import "sync"
+
+// Getter returns the current value as any
+type Getter func() any
+
+// Setter updates the value from any
+type Setter func(any) error
+
+// Entry holds metadata about a registered value
+type Entry struct {
+	Name   string
+	Getter Getter
+	Setter Setter
+	Usage  string
+	Tags   map[string]any // 自定义元数据标签
+}
+
+// Monitor manages all registered values
+type Monitor struct {
+	m  map[string]*Entry
+	mu sync.RWMutex
+}
+
+var defaultMonitor = NewMonitor("default")
+
+// NewMonitor creates a new Monitor instance
+func NewMonitor(name string) *Monitor {
+	return &Monitor{
+		m: make(map[string]*Entry),
+	}
+}
+
+// AddFunc registers a new value with getter, setter, usage, and optional tags
+func (m *Monitor) AddFunc(name string, get Getter, set Setter, usage string, tags ...map[string]any) {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+
+	tagMap := make(map[string]any)
+	if len(tags) > 0 && tags[0] != nil {
+		for k, v := range tags[0] {
+			tagMap[k] = v
+		}
+	}
+
+	m.m[name] = &Entry{
+		Name:   name,
+		Getter: get,
+		Setter: set,
+		Usage:  usage,
+		Tags:   tagMap,
+	}
+}
+
+// Lookup returns the entry by name
+func (m *Monitor) Lookup(name string) *Entry {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+	return m.m[name]
+}
+
+// VisitAll calls fn for each entry
+func (m *Monitor) VisitAll(fn func(*Entry)) {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+	for _, e := range m.m {
+		fn(e)
+	}
+}
+
+// Global functions (use defaultMonitor)
+
+func AddFunc(name string, get Getter, set Setter, usage string, tags ...map[string]any) {
+	defaultMonitor.AddFunc(name, get, set, usage, tags...)
+}
+
+func Lookup(name string) *Entry {
+	return defaultMonitor.Lookup(name)
+}
+
+func VisitAll(fn func(*Entry)) {
+	defaultMonitor.VisitAll(fn)
+}