chore: assert plugin getters (#17052)
This commit is contained in:
parent
b00c03cd90
commit
95d772d063
5 changed files with 16 additions and 10 deletions
|
|
@ -11,9 +11,12 @@ var registry = reg.New[Provider]("plugin")
|
|||
|
||||
// provider types
|
||||
type (
|
||||
Provider interface{}
|
||||
IntProvider interface {
|
||||
IntGetter() (func() (int64, error), error)
|
||||
Provider interface{}
|
||||
Getters interface {
|
||||
StringProvider
|
||||
FloatProvider
|
||||
IntProvider
|
||||
BoolProvider
|
||||
}
|
||||
StringProvider interface {
|
||||
StringGetter() (func() (string, error), error)
|
||||
|
|
@ -21,18 +24,21 @@ type (
|
|||
FloatProvider interface {
|
||||
FloatGetter() (func() (float64, error), error)
|
||||
}
|
||||
IntProvider interface {
|
||||
IntGetter() (func() (int64, error), error)
|
||||
}
|
||||
BoolProvider interface {
|
||||
BoolGetter() (func() (bool, error), error)
|
||||
}
|
||||
SetIntProvider interface {
|
||||
IntSetter(param string) (func(int64) error, error)
|
||||
}
|
||||
SetStringProvider interface {
|
||||
StringSetter(param string) (func(string) error, error)
|
||||
}
|
||||
SetFloatProvider interface {
|
||||
FloatSetter(param string) (func(float64) error, error)
|
||||
}
|
||||
SetIntProvider interface {
|
||||
IntSetter(param string) (func(int64) error, error)
|
||||
}
|
||||
SetBoolProvider interface {
|
||||
BoolSetter(param string) (func(bool) error, error)
|
||||
}
|
||||
|
|
|
|||
|
|
@ -178,7 +178,7 @@ func (p *HTTP) request(url string, body string) ([]byte, error) {
|
|||
return p.val, p.err
|
||||
}
|
||||
|
||||
var _ StringProvider = (*HTTP)(nil)
|
||||
var _ Getters = (*HTTP)(nil)
|
||||
|
||||
// StringGetter sends string request
|
||||
func (p *HTTP) StringGetter() (func() (string, error), error) {
|
||||
|
|
|
|||
|
|
@ -113,7 +113,7 @@ func (m *Mqtt) newReceiver() (*msgHandler, error) {
|
|||
return h, err
|
||||
}
|
||||
|
||||
var _ StringProvider = (*Mqtt)(nil)
|
||||
var _ Getters = (*Mqtt)(nil)
|
||||
|
||||
// StringGetter creates handler for string from MQTT topic that returns cached value
|
||||
func (m *Mqtt) StringGetter() (func() (string, error), error) {
|
||||
|
|
|
|||
|
|
@ -106,7 +106,7 @@ func (p *Script) exec(script string) (string, error) {
|
|||
return s, nil
|
||||
}
|
||||
|
||||
var _ StringProvider = (*Script)(nil)
|
||||
var _ Getters = (*Script)(nil)
|
||||
|
||||
// StringGetter returns string from exec result. Only STDOUT is considered.
|
||||
func (p *Script) StringGetter() (func() (string, error), error) {
|
||||
|
|
|
|||
|
|
@ -145,7 +145,7 @@ func (p *Socket) run(errC chan error) {
|
|||
}
|
||||
}
|
||||
|
||||
var _ StringProvider = (*Socket)(nil)
|
||||
var _ Getters = (*Socket)(nil)
|
||||
|
||||
// StringGetter sends string request
|
||||
func (p *Socket) StringGetter() (func() (string, error), error) {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue