Compare commits
6 Commits
v4.0.0
...
ec3ae6b934
| Author | SHA1 | Date | |
|---|---|---|---|
| ec3ae6b934 | |||
| e712519f44 | |||
| a8d5f21394 | |||
| 5fef84faa0 | |||
| 600608bda5 | |||
| 728f1ca453 |
25
flag.go
25
flag.go
@@ -11,6 +11,7 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
"go.unistack.org/micro/v4/config"
|
"go.unistack.org/micro/v4/config"
|
||||||
|
"go.unistack.org/micro/v4/options"
|
||||||
rutil "go.unistack.org/micro/v4/util/reflect"
|
rutil "go.unistack.org/micro/v4/util/reflect"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -39,9 +40,13 @@ func (c *flagConfig) Options() config.Options {
|
|||||||
return c.opts
|
return c.opts
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *flagConfig) Init(opts ...config.Option) error {
|
func (c *flagConfig) Init(opts ...options.Option) error {
|
||||||
|
var err error
|
||||||
|
|
||||||
for _, o := range opts {
|
for _, o := range opts {
|
||||||
o(&c.opts)
|
if err = o(&c.opts); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := config.DefaultBeforeInit(c.opts.Context, c); err != nil && !c.opts.AllowFail {
|
if err := config.DefaultBeforeInit(c.opts.Context, c); err != nil && !c.opts.AllowFail {
|
||||||
@@ -155,7 +160,11 @@ func (c *flagConfig) Init(opts ...config.Option) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *flagConfig) Load(ctx context.Context, opts ...config.LoadOption) error {
|
func (c *flagConfig) Load(ctx context.Context, opts ...options.Option) error {
|
||||||
|
if c.opts.SkipLoad != nil && c.opts.SkipLoad(ctx, c) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
options := config.NewLoadOptions(opts...)
|
options := config.NewLoadOptions(opts...)
|
||||||
_ = options
|
_ = options
|
||||||
|
|
||||||
@@ -173,7 +182,11 @@ func (c *flagConfig) Load(ctx context.Context, opts ...config.LoadOption) error
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *flagConfig) Save(ctx context.Context, opts ...config.SaveOption) error {
|
func (c *flagConfig) Save(ctx context.Context, opts ...options.Option) error {
|
||||||
|
if c.opts.SkipSave != nil && c.opts.SkipSave(ctx, c) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
if err := config.DefaultBeforeSave(ctx, c); err != nil && !c.opts.AllowFail {
|
if err := config.DefaultBeforeSave(ctx, c); err != nil && !c.opts.AllowFail {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -193,7 +206,7 @@ func (c *flagConfig) Name() string {
|
|||||||
return c.opts.Name
|
return c.opts.Name
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *flagConfig) Watch(ctx context.Context, opts ...config.WatchOption) (config.Watcher, error) {
|
func (c *flagConfig) Watch(ctx context.Context, opts ...options.Option) (config.Watcher, error) {
|
||||||
return nil, fmt.Errorf("not implemented")
|
return nil, fmt.Errorf("not implemented")
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -308,7 +321,7 @@ func (c *flagConfig) configure() {
|
|||||||
c.name = flagSetName
|
c.name = flagSetName
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewConfig(opts ...config.Option) config.Config {
|
func NewConfig(opts ...options.Option) config.Config {
|
||||||
options := config.NewOptions(opts...)
|
options := config.NewOptions(opts...)
|
||||||
if len(options.StructTag) == 0 {
|
if len(options.StructTag) == 0 {
|
||||||
options.StructTag = DefaultStructTag
|
options.StructTag = DefaultStructTag
|
||||||
|
|||||||
9
go.mod
9
go.mod
@@ -1,7 +1,10 @@
|
|||||||
module go.unistack.org/micro-config-flag/v3
|
module go.unistack.org/micro-config-flag/v4
|
||||||
|
|
||||||
go 1.18
|
go 1.18
|
||||||
|
|
||||||
require go.unistack.org/micro/v4 v4.0.1
|
require go.unistack.org/micro/v4 v4.0.17
|
||||||
|
|
||||||
require github.com/imdario/mergo v0.3.14 // indirect
|
require (
|
||||||
|
dario.cat/mergo v1.0.0 // indirect
|
||||||
|
github.com/google/uuid v1.6.0 // indirect
|
||||||
|
)
|
||||||
|
|||||||
10
go.sum
10
go.sum
@@ -1,7 +1,9 @@
|
|||||||
github.com/imdario/mergo v0.3.14 h1:fOqeC1+nCuuk6PKQdg9YmosXX7Y7mHX6R/0ZldI9iHo=
|
dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
|
||||||
github.com/imdario/mergo v0.3.14/go.mod h1:WBLT9ZmE3lPoWsEzCh9LPo3TiwVN+ZKEjmz+hD27ysY=
|
dario.cat/mergo v1.0.0/go.mod h1:uNxQE+84aUszobStD9th8a29P2fMDhsBdgRYvZOxGmk=
|
||||||
go.unistack.org/micro/v4 v4.0.1 h1:xo1IxbVfgh8i0eY0VeYa3cbb13u5n/Mxnp3FOgWD4Jo=
|
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
|
||||||
go.unistack.org/micro/v4 v4.0.1/go.mod h1:p/J5UcSJjfHsWGT31uKoghQ5rUQZzQJBAFy+Z4+ZVMs=
|
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||||
|
go.unistack.org/micro/v4 v4.0.17 h1:mF7uM+J4ILdG+1fcwzKYCwDlxhdbF/e1WnGzKKLnIXc=
|
||||||
|
go.unistack.org/micro/v4 v4.0.17/go.mod h1:ZDgU9931vm2l7X6RN/6UuwRIVp24GRdmQ7dKmegArk4=
|
||||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||||
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||||
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||||
|
|||||||
34
options.go
34
options.go
@@ -3,61 +3,61 @@ package flag
|
|||||||
import (
|
import (
|
||||||
"flag"
|
"flag"
|
||||||
|
|
||||||
"go.unistack.org/micro/v4/config"
|
"go.unistack.org/micro/v4/options"
|
||||||
)
|
)
|
||||||
|
|
||||||
type sliceDelimKey struct{}
|
type sliceDelimKey struct{}
|
||||||
|
|
||||||
// SliceDelim set the slice delimeter
|
// SliceDelim set the slice delimeter
|
||||||
func SliceDelim(s string) config.Option {
|
func SliceDelim(s string) options.Option {
|
||||||
return config.SetOption(sliceDelimKey{}, s)
|
return options.ContextOption(sliceDelimKey{}, s)
|
||||||
}
|
}
|
||||||
|
|
||||||
type mapDelimKey struct{}
|
type mapDelimKey struct{}
|
||||||
|
|
||||||
// MapDelim set the map delimeter
|
// MapDelim set the map delimeter
|
||||||
func MapDelim(s string) config.Option {
|
func MapDelim(s string) options.Option {
|
||||||
return config.SetOption(mapDelimKey{}, s)
|
return options.ContextOption(mapDelimKey{}, s)
|
||||||
}
|
}
|
||||||
|
|
||||||
type timeFormatKey struct{}
|
type timeFormatKey struct{}
|
||||||
|
|
||||||
// TimeFormat set the time format
|
// TimeFormat set the time format
|
||||||
func TimeFormat(s string) config.Option {
|
func TimeFormat(s string) options.Option {
|
||||||
return config.SetOption(timeFormatKey{}, s)
|
return options.ContextOption(timeFormatKey{}, s)
|
||||||
}
|
}
|
||||||
|
|
||||||
type flagSetKey struct{}
|
type flagSetKey struct{}
|
||||||
|
|
||||||
// FlagSet set flag set name
|
// FlagSet set flag set name
|
||||||
func FlagSet(f *flag.FlagSet) config.Option {
|
func FlagSet(f *flag.FlagSet) options.Option {
|
||||||
return config.SetOption(flagSetKey{}, f)
|
return options.ContextOption(flagSetKey{}, f)
|
||||||
}
|
}
|
||||||
|
|
||||||
type flagSetNameKey struct{}
|
type flagSetNameKey struct{}
|
||||||
|
|
||||||
// FlagSetName set flag set name
|
// FlagSetName set flag set name
|
||||||
func FlagSetName(n string) config.Option {
|
func FlagSetName(n string) options.Option {
|
||||||
return config.SetOption(flagSetNameKey{}, n)
|
return options.ContextOption(flagSetNameKey{}, n)
|
||||||
}
|
}
|
||||||
|
|
||||||
type flagSetErrorHandlingKey struct{}
|
type flagSetErrorHandlingKey struct{}
|
||||||
|
|
||||||
// FlagErrorHandling set flag set error handling
|
// FlagErrorHandling set flag set error handling
|
||||||
func FlagErrorHandling(eh flag.ErrorHandling) config.Option {
|
func FlagErrorHandling(eh flag.ErrorHandling) options.Option {
|
||||||
return config.SetOption(flagSetErrorHandlingKey{}, eh)
|
return options.ContextOption(flagSetErrorHandlingKey{}, eh)
|
||||||
}
|
}
|
||||||
|
|
||||||
type flagSetUsageKey struct{}
|
type flagSetUsageKey struct{}
|
||||||
|
|
||||||
// FlagUsage set flag set usage func
|
// FlagUsage set flag set usage func
|
||||||
func FlagUsage(fn func()) config.Option {
|
func FlagUsage(fn func()) options.Option {
|
||||||
return config.SetOption(flagSetUsageKey{}, fn)
|
return options.ContextOption(flagSetUsageKey{}, fn)
|
||||||
}
|
}
|
||||||
|
|
||||||
type flagEnvKey struct{}
|
type flagEnvKey struct{}
|
||||||
|
|
||||||
// FlagEnv set flag set usage func
|
// FlagEnv set flag set usage func
|
||||||
func FlagEnv(n string) config.Option {
|
func FlagEnv(n string) options.Option {
|
||||||
return config.SetOption(flagEnvKey{}, n)
|
return options.ContextOption(flagEnvKey{}, n)
|
||||||
}
|
}
|
||||||
|
|||||||
2
util.go
2
util.go
@@ -325,6 +325,7 @@ func (c *flagConfig) flagFloat64(v reflect.Value, fn, fv, fd string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
func (c *flagConfig) flagStringSlice(v reflect.Value, fn, fv, fd string) error {
|
func (c *flagConfig) flagStringSlice(v reflect.Value, fn, fv, fd string) error {
|
||||||
nv, ok := v.Addr().Interface().(*string)
|
nv, ok := v.Addr().Interface().(*string)
|
||||||
if !ok {
|
if !ok {
|
||||||
@@ -333,6 +334,7 @@ func (c *flagConfig) flagStringSlice(v reflect.Value, fn, fv, fd string) error {
|
|||||||
flag.StringVar(nv, fn, fv, fd)
|
flag.StringVar(nv, fn, fv, fd)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
*/
|
||||||
|
|
||||||
func getFlagOpts(tf string) (string, string, string) {
|
func getFlagOpts(tf string) (string, string, string) {
|
||||||
var name, desc, def string
|
var name, desc, def string
|
||||||
|
|||||||
Reference in New Issue
Block a user