Skip to content

Commit 978af63

Browse files
committed
remove the top level metatada attribute
1 parent be43167 commit 978af63

File tree

3 files changed

+4
-8
lines changed

3 files changed

+4
-8
lines changed

agentcfg/fetch.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ var (
3838

3939
func Fetch(kb *kibana.Client, q Query, err error) (map[string]interface{}, string, error) {
4040
var doc Doc
41-
resultBytes, err := request(kb, convert.ToReader(q.Metadata), err)
41+
resultBytes, err := request(kb, convert.ToReader(q), err)
4242
err = convert.FromBytes(resultBytes, &doc, err)
4343
return doc.Source.Settings, doc.Id, err
4444
}

agentcfg/model.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -31,15 +31,11 @@ type Source struct {
3131
Settings map[string]interface{} `json:"settings"`
3232
}
3333

34-
type Query struct {
35-
Metadata Metadata `json:"metadata"`
36-
}
37-
3834
func NewQuery(name, env string) Query {
39-
return Query{Metadata: Metadata{Service{name, env}}}
35+
return Query{Service{name, env}}
4036
}
4137

42-
type Metadata struct {
38+
type Query struct {
4339
Service Service `json:"service"`
4440
}
4541

beater/agent_config_handler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ func buildQuery(r *http.Request) (query agentcfg.Query, err error) {
8888
return
8989
}
9090

91-
if err == nil && query.Metadata.Service.Name == "" {
91+
if err == nil && query.Service.Name == "" {
9292
err = errors.New(agentcfg.ServiceName + " is required")
9393
}
9494

0 commit comments

Comments
 (0)