/
spec.go
98 lines (79 loc) · 1.73 KB
/
spec.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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
package float
import (
"github.com/indra-labs/indra/pkg/util/path"
"strconv"
"strings"
"go.uber.org/atomic"
log2 "github.com/indra-labs/indra/pkg/proc/log"
"github.com/indra-labs/indra/pkg/proc/opts/config"
"github.com/indra-labs/indra/pkg/proc/opts/meta"
)
var (
log = log2.GetLogger()
check = log.E.Chk
)
type Opt struct {
p path.Path
m meta.Metadata
v atomic.Float64
h []Hook
}
func (o *Opt) Path() (p path.Path) { return o.p }
func (o *Opt) SetPath(p path.Path) { o.p = p }
var _ config.Option = &Opt{}
type Hook func(*Opt) error
func New(m meta.Data, h ...Hook) (o *Opt) {
o = &Opt{m: meta.New(m, meta.Float), h: h}
_ = o.FromString(m.Default)
return
}
func (o *Opt) Meta() meta.Metadata { return o.m }
func (o *Opt) Type() meta.Type { return o.m.Typ }
func (o *Opt) ToOption() config.Option { return o }
func (o *Opt) RunHooks() (e error) {
for i := range o.h {
e = o.h[i](o)
if e != nil {
return
}
}
return
}
func (o *Opt) FromValue(v float64) *Opt {
o.v.Store(v)
return o
}
func (o *Opt) FromString(s string) (e error) {
s = strings.TrimSpace(s)
var p float64
p, e = strconv.ParseFloat(s, 64)
if e != nil {
return e
}
o.v.Store(p)
e = o.RunHooks()
return
}
func (o *Opt) String() (s string) {
return strconv.FormatFloat(o.v.Load(), 'f', -1, 64)
}
func (o *Opt) Expanded() (s string) { return o.String() }
func (o *Opt) SetExpanded(s string) {
err := o.FromString(s)
log.E.Chk(err)
}
func (o *Opt) Value() (c config.Concrete) {
c = config.NewConcrete()
c.Float = func() float64 { return o.v.Load() }
return
}
func Clamp(o *Opt, min, max float64) func(*Opt) {
return func(o *Opt) {
v := o.v.Load()
if v < min {
o.v.Store(min)
} else if v > max {
o.v.Store(max)
}
}
}