Skip to content

Commit

Permalink
clean the code
Browse files Browse the repository at this point in the history
  • Loading branch information
WakeupTsai committed Jul 5, 2018
1 parent 3673e84 commit faa0480
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 8 deletions.
7 changes: 0 additions & 7 deletions src/server/handler_node_metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ func listNodeMetricsHandler(ctx *web.Context) {

// kube_node_info, kube_node_labels
results, err := queryFromPrometheus(sp, `{__name__=~"kube_node_info|kube_node_labels"}`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand All @@ -43,7 +42,6 @@ func listNodeMetricsHandler(ctx *web.Context) {

// kube_node_status_condition
results, err = queryFromPrometheus(sp, `{__name__=~"kube_node_status_condition",status="true"}==1`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand All @@ -56,7 +54,6 @@ func listNodeMetricsHandler(ctx *web.Context) {

// kube_pod_container_resource_limits, kube_pod_container_resource_requests
results, err = queryFromPrometheus(sp, `sum by(__name__, resource,node) ({__name__=~"kube_pod_container_resource_limits|kube_pod_container_resource_requests"})`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand Down Expand Up @@ -95,7 +92,6 @@ func getNodeMetricsHandler(ctx *web.Context) {

// kube_node_info, kube_node_created, node_network_interface, kube_node_labels, kube_node_status_capacity, kube_node_status_allocatable
results, err := queryFromPrometheus(sp, `{__name__=~"kube_node_info|kube_node_created|node_network_interface|kube_node_labels|kube_node_status_capacity|kube_node_status_allocatable",node=~"`+id+`"}`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand Down Expand Up @@ -148,7 +144,6 @@ func getNodeMetricsHandler(ctx *web.Context) {

// kube_node_status_condition
results, err = queryFromPrometheus(sp, ` {__name__=~"kube_node_status_condition",node=~"`+id+`",status="true"}==1`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand All @@ -157,7 +152,6 @@ func getNodeMetricsHandler(ctx *web.Context) {

// kube_pod_container_resource_limits, kube_pod_container_resource_requests
results, err = queryFromPrometheus(sp, `sum by(__name__, resource) ({__name__=~"kube_pod_container_resource_limits|kube_pod_container_resource_requests",node=~"`+id+`"})`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand All @@ -183,7 +177,6 @@ func getNodeMetricsHandler(ctx *web.Context) {

// node_network_interface, node_network_receive_bytes_total, node_network_transmit_bytes_total, node_network_receive_packets_total, node_network_transmit_packets_total
results, err = queryFromPrometheus(sp, `{__name__=~"node_network_interface|node_network_receive_bytes_total|node_network_transmit_bytes_total|node_network_receive_packets_total|node_network_transmit_packets_total",node=~"`+id+`"}`)

if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, err)
}
Expand Down
2 changes: 1 addition & 1 deletion src/server/handler_prometheus.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ func queryMetrics(ctx *web.Context) {

result, err := queryFromPrometheus(sp, expression)
if err != nil {
response.BadRequest(req.Request, resp.ResponseWriter, fmt.Errorf("%v: %v", result, err))
response.BadRequest(req.Request, resp.ResponseWriter, err)
}

resp.WriteJson(map[string]interface{}{
Expand Down

0 comments on commit faa0480

Please sign in to comment.