chore: quick update fix/version at 2025-09-17 22:36:02

Author: kooksee

metaflags/example/main.go

@@ -0,0 +1,77 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+	"strings"
+	"time"
+
+	"github.com/pubgo/funk/metaflags"
+)
+
+var startTime = time.Now()
+
+func main() {
+	status := metaflags.String("app_status", "ok", "Current app status")
+	replicas := metaflags.Int("replicas", 1, "Number of replicas")
+	timeout := metaflags.Duration("timeout", 5*time.Second, "Request timeout")
+	features := metaflags.StringSlice("features", []string{"auth"}, "Enabled features")
+	labels := metaflags.StringMap("labels", map[string]string{"env": "dev"}, "Node labels")
+
+	// 模拟更新
+	go func() {
+		time.Sleep(2 * time.Second)
+		status.Set("degraded")
+
+		time.Sleep(2 * time.Second)
+		replicas.Set(3)
+
+		time.Sleep(2 * time.Second)
+		timeout.Set(10 * time.Second)
+
+		time.Sleep(2 * time.Second)
+		features.Set([]string{"auth", "metrics", "tracing"})
+
+		time.Sleep(2 * time.Second)
+		lbls := labels.Get().(map[string]string)
+		lbls["updated"] = time.Now().Format("15:04")
+		labels.Set(lbls)
+	}()
+
+	// HTTP 输出所有元数据
+	http.HandleFunc("/metadata", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "application/json")
+		fmt.Fprintln(w, "{")
+		first := true
+		metaflags.VisitAll(func(e *metaflags.Entry) {
+			if !first {
+				fmt.Fprint(w, ",")
+			}
+			first = false
+			fmt.Fprintf(w, "\n  %q: %v", e.Name, mustJSON(e.Value.Get()))
+		})
+		fmt.Fprintln(w, "\n}")
+	})
+
+	log.Println("Server starting on :8080")
+	log.Fatal(http.ListenAndServe(":8080", nil))
+}
+
+// 简单 JSON 转换（生产环境用 json.Marshal）
+func mustJSON(v interface{}) string {
+	switch val := v.(type) {
+	case string:
+		return fmt.Sprintf("%q", val)
+	case []string:
+		return fmt.Sprintf("%q", val)
+	case map[string]string:
+		var parts []string
+		for k, v := range val {
+			parts = append(parts, fmt.Sprintf("%q:%q", k, v))
+		}
+		return fmt.Sprintf("{%s}", strings.Join(parts, ","))
+	default:
+		return fmt.Sprintf("%v", val)
+	}
+}

metaflags/metaflag.go

@@ -0,0 +1,75 @@
+package metaflags
+
+import (
+	"github.com/pubgo/funk/assert"
+	"sync"
+)
+
+// Value is the interface to the dynamic value stored in metadata.
+type Value interface {
+	Get() any
+	Set(value any) error
+	String() string
+	Key() string // 返回该值的名称
+}
+
+// Entry holds metadata about a registered value
+type Entry struct {
+	Name  string
+	Value Value
+	Usage string
+}
+
+// FlagSet holds a set of metadata values
+type FlagSet struct {
+	m  map[string]*Entry
+	mu sync.RWMutex
+}
+
+var defaultSet = NewFlagSet()
+
+func NewFlagSet() *FlagSet { return &FlagSet{m: make(map[string]*Entry)} }
+
+func (f *FlagSet) AddFunc(name string, getter func() any, setter func(val any) error, usage string) Value {
+	return f.Add(name, &FuncValue{get: getter, set: setter, name: name}, usage)
+}
+
+// Add registers a new metadata entry and injects name if supported
+func (f *FlagSet) Add(name string, value Value, usage string) Value {
+	f.mu.Lock()
+	defer f.mu.Unlock()
+
+	assert.If(value == nil, "flag value is nil")
+	assert.If(name == "", "flag name is empty")
+	assert.If(f.m[name] != nil, "flag '%s' already registered", name)
+
+	f.m[name] = &Entry{
+		Name:  name,
+		Value: value,
+		Usage: usage,
+	}
+	return value
+}
+
+// Lookup returns the Entry for the given name
+func (f *FlagSet) Lookup(name string) *Entry {
+	f.mu.RLock()
+	defer f.mu.RUnlock()
+	return f.m[name]
+}
+
+// VisitAll calls fn for each Entry
+func (f *FlagSet) VisitAll(fn func(*Entry)) {
+	f.mu.RLock()
+	defer f.mu.RUnlock()
+	for _, entry := range f.m {
+		fn(entry)
+	}
+}
+
+// Default accessors
+func Lookup(name string) *Entry { return defaultSet.Lookup(name) }
+func VisitAll(fn func(*Entry))  { defaultSet.VisitAll(fn) }
+func Add(name string, val Value, u string) Value {
+	return defaultSet.Add(name, val, u)
+}