Skip to content

Commit 5d3a467

Browse files
committed
return everything as string
1 parent 978af63 commit 5d3a467

File tree

2 files changed

+20
-2
lines changed

2 files changed

+20
-2
lines changed

agentcfg/fetch.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ var (
3636
minVersion = common.Version{Major: 7, Minor: 3}
3737
)
3838

39-
func Fetch(kb *kibana.Client, q Query, err error) (map[string]interface{}, string, error) {
39+
func Fetch(kb *kibana.Client, q Query, err error) (map[string]string, string, error) {
4040
var doc Doc
4141
resultBytes, err := request(kb, convert.ToReader(q), err)
4242
err = convert.FromBytes(resultBytes, &doc, err)

agentcfg/model.go

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,11 @@
1717

1818
package agentcfg
1919

20+
import (
21+
"encoding/json"
22+
"fmt"
23+
)
24+
2025
var (
2126
ServiceName = "service.name"
2227
ServiceEnv = "service.environment"
@@ -28,7 +33,20 @@ type Doc struct {
2833
}
2934

3035
type Source struct {
31-
Settings map[string]interface{} `json:"settings"`
36+
Settings Settings `json:"settings"`
37+
}
38+
39+
type Settings map[string]string
40+
41+
func (s *Settings) UnmarshalJSON(b []byte) error {
42+
in := make(map[string]interface{})
43+
out := make(map[string]string)
44+
err := json.Unmarshal(b, &in)
45+
for k, v := range in {
46+
out[k] = fmt.Sprintf("%v", v)
47+
}
48+
*s = out
49+
return err
3250
}
3351

3452
func NewQuery(name, env string) Query {

0 commit comments

Comments
 (0)