Skip to content

Commit

Permalink
update tests
Browse files Browse the repository at this point in the history
  • Loading branch information
endorama committed Jul 20, 2021
1 parent 5d985ef commit 59b3c71
Showing 1 changed file with 14 additions and 1 deletion.
15 changes: 14 additions & 1 deletion x-pack/metricbeat/module/gcp/metrics/metrics_requester_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,78 +18,91 @@ func TestGetFilterForMetric(t *testing.T) {
var logger = logp.NewLogger("test")
cases := []struct {
title string
s string
m string
r metricsRequester
expectedFilter string
}{
{
"compute service with zone in config",
"compute",
"compute.googleapis.com/firewall/dropped_bytes_count",
metricsRequester{config: config{Zone: "us-central1-a"}, logger: logger},
"metric.type=\"compute.googleapis.com/firewall/dropped_bytes_count\" AND resource.labels.zone = starts_with(\"us-central1-a\")",
},
{
"pubsub service with zone in config",
"pubsub",
"pubsub.googleapis.com/subscription/ack_message_count",
metricsRequester{config: config{Zone: "us-central1-a"}, logger: logger},
"metric.type=\"pubsub.googleapis.com/subscription/ack_message_count\"",
},
{
"loadbalancing service with zone in config",
"loadbalancing",
"loadbalancing.googleapis.com/https/backend_latencies",
metricsRequester{config: config{Zone: "us-central1-a"}, logger: logger},
"metric.type=\"loadbalancing.googleapis.com/https/backend_latencies\"",
},
{
"compute service with region in config",
"compute",
"compute.googleapis.com/firewall/dropped_bytes_count",
metricsRequester{config: config{Region: "us-east1"}, logger: logger},
"metric.type=\"compute.googleapis.com/firewall/dropped_bytes_count\" AND resource.labels.zone = starts_with(\"us-east1\")",
},
{
"pubsub service with region in config",
"pubsub",
"pubsub.googleapis.com/subscription/ack_message_count",
metricsRequester{config: config{Region: "us-east1"}, logger: logger},
"metric.type=\"pubsub.googleapis.com/subscription/ack_message_count\"",
},
{
"loadbalancing service with region in config",
"loadbalancing",
"loadbalancing.googleapis.com/https/backend_latencies",
metricsRequester{config: config{Region: "us-east1"}, logger: logger},
"metric.type=\"loadbalancing.googleapis.com/https/backend_latencies\"",
},
{
"compute service with both region and zone in config",
"compute",
"compute.googleapis.com/firewall/dropped_bytes_count",
metricsRequester{config: config{Region: "us-central1", Zone: "us-central1-a"}, logger: logger},
"metric.type=\"compute.googleapis.com/firewall/dropped_bytes_count\" AND resource.labels.zone = starts_with(\"us-central1\")",
},
{
"compute uptime with partial region",
"compute",
"compute.googleapis.com/instance/uptime",
metricsRequester{config: config{Region: "us-west"}, logger: logger},
"metric.type=\"compute.googleapis.com/instance/uptime\" AND resource.labels.zone = starts_with(\"us-west\")",
},
{
"compute uptime with partial zone",
"compute",
"compute.googleapis.com/instance/uptime",
metricsRequester{config: config{Zone: "us-west1-"}, logger: logger},
"metric.type=\"compute.googleapis.com/instance/uptime\" AND resource.labels.zone = starts_with(\"us-west1-\")",
},
{
"compute uptime with wildcard in region",
"compute",
"compute.googleapis.com/instance/uptime",
metricsRequester{config: config{Region: "us-*"}, logger: logger},
"metric.type=\"compute.googleapis.com/instance/uptime\" AND resource.labels.zone = starts_with(\"us-\")",
},
{
"compute uptime with wildcard in zone",
"compute",
"compute.googleapis.com/instance/uptime",
metricsRequester{config: config{Zone: "us-west1-*"}, logger: logger},
"metric.type=\"compute.googleapis.com/instance/uptime\" AND resource.labels.zone = starts_with(\"us-west1-\")",
},
{
"compute service with no region/zone in config",
"compute",
"compute.googleapis.com/firewall/dropped_bytes_count",
metricsRequester{config: config{}, logger: logger},
"metric.type=\"compute.googleapis.com/firewall/dropped_bytes_count\"",
Expand All @@ -98,7 +111,7 @@ func TestGetFilterForMetric(t *testing.T) {

for _, c := range cases {
t.Run(c.title, func(t *testing.T) {
filter := c.r.getFilterForMetric(c.m)
filter := c.r.getFilterForMetric(c.s, c.m)
assert.Equal(t, c.expectedFilter, filter)
})
}
Expand Down

0 comments on commit 59b3c71

Please sign in to comment.