Skip to content

Commit 72b948d

Browse files
committed
feature: add XXX:8081/jobmanager/metrics?get=XXXXX method to JobManagerMetrics function
1 parent 471e35b commit 72b948d

1 file changed

Lines changed: 11 additions & 4 deletions

File tree

job.go

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,14 +33,15 @@ func (c *Client) JobManagerConfig() ([]kv, error) {
3333
return r, err
3434
}
3535

36-
type metric struct {
37-
ID string `json:"id"`
36+
type metricValue struct {
37+
ID string `json:"id"`
38+
Value string `json:"value,omitempty"`
3839
}
3940

4041
// JobManagerMetrics provides access to job manager
4142
// metrics.
42-
func (c *Client) JobManagerMetrics() ([]metric, error) {
43-
var r []metric
43+
func (c *Client) JobManagerMetrics(ids []string) ([]metricValue, error) {
44+
var r []metricValue
4445
req, err := http.NewRequest(
4546
"GET",
4647
c.url("/jobmanager/metrics"),
@@ -49,6 +50,12 @@ func (c *Client) JobManagerMetrics() ([]metric, error) {
4950
if err != nil {
5051
return r, err
5152
}
53+
q := req.URL.Query()
54+
if len(ids) > 0 {
55+
q.Add("get", strings.Join(ids, ","))
56+
}
57+
req.URL.RawQuery = q.Encode()
58+
5259
b, err := c.client.Do(req)
5360
if err != nil {
5461
return r, err

0 commit comments

Comments
 (0)