-
Notifications
You must be signed in to change notification settings - Fork 0
/
vars.go
52 lines (41 loc) · 1.03 KB
/
vars.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package vars
import (
"expvar"
"github.com/pubgo/lug/logutil"
"github.com/pubgo/x/byteutil"
"github.com/pubgo/x/jsonx"
"github.com/pubgo/x/stack"
"github.com/pubgo/x/try"
"github.com/pubgo/xerror"
"github.com/pubgo/xlog"
"go.uber.org/zap"
)
var pkg = logutil.Pkg("vars")
type value func() interface{}
func (f value) Value() interface{} { return f() }
func (f value) String() (val string) {
var dt interface{}
try.Logs(xlog.GetDefault(), func() { dt = f() }, pkg)
v, err := jsonx.Marshal(dt)
if err != nil {
return err.Error()
}
return byteutil.ToStr(v)
}
func Watch(name string, data func() interface{}) {
expvar.Publish(name, value(func() (val interface{}) {
defer xerror.Resp(func(err xerror.XErr) {
xlog.Error("unknown error",
pkg,
zap.String(name, stack.Func(data)),
zap.Any("err", err))
})
return data()
}))
}
func Get(name string) expvar.Var {
return expvar.Get(name)
}
func Each(fn func(key string, val func() string)) {
expvar.Do(func(kv expvar.KeyValue) { fn(kv.Key, kv.Value.String) })
}