diff options
author | GitLab Bot <gitlab-bot@gitlab.com> | 2020-06-18 11:18:50 +0000 |
---|---|---|
committer | GitLab Bot <gitlab-bot@gitlab.com> | 2020-06-18 11:18:50 +0000 |
commit | 8c7f4e9d5f36cff46365a7f8c4b9c21578c1e781 (patch) | |
tree | a77e7fe7a93de11213032ed4ab1f33a3db51b738 /spec/lib/gitlab/prometheus_client_spec.rb | |
parent | 00b35af3db1abfe813a778f643dad221aad51fca (diff) | |
download | gitlab-ce-8c7f4e9d5f36cff46365a7f8c4b9c21578c1e781.tar.gz |
Add latest changes from gitlab-org/gitlab@13-1-stable-ee
Diffstat (limited to 'spec/lib/gitlab/prometheus_client_spec.rb')
-rw-r--r-- | spec/lib/gitlab/prometheus_client_spec.rb | 52 |
1 files changed, 52 insertions, 0 deletions
diff --git a/spec/lib/gitlab/prometheus_client_spec.rb b/spec/lib/gitlab/prometheus_client_spec.rb index 4ff53b50a50..749192e5795 100644 --- a/spec/lib/gitlab/prometheus_client_spec.rb +++ b/spec/lib/gitlab/prometheus_client_spec.rb @@ -171,6 +171,58 @@ describe Gitlab::PrometheusClient do end end + describe '#aggregate' do + let(:query) { 'avg (metric) by (job)' } + let(:prometheus_response) do + { + "status": "success", + "data": { + "resultType": "vector", + "result": [ + { + "metric": { "job" => "gitlab-rails" }, + "value": [1488758662.506, "1"] + }, + { + "metric": { "job" => "gitlab-sidekiq" }, + "value": [1488758662.506, "2"] + } + ] + } + } + end + let(:query_url) { prometheus_query_with_time_url(query, Time.now.utc) } + + around do |example| + Timecop.freeze { example.run } + end + + context 'when request returns vector results' do + it 'returns data from the API call grouped by labels' do + req_stub = stub_prometheus_request(query_url, body: prometheus_response) + + expect(subject.aggregate(query)).to eq({ + { "job" => "gitlab-rails" } => 1, + { "job" => "gitlab-sidekiq" } => 2 + }) + expect(req_stub).to have_been_requested + end + end + + context 'when request returns no data' do + it 'returns {}' do + req_stub = stub_prometheus_request(query_url, body: prometheus_empty_body('vector')) + + expect(subject.aggregate(query)).to eq({}) + expect(req_stub).to have_been_requested + end + end + + it_behaves_like 'failure response' do + let(:execute_query) { subject.aggregate(query) } + end + end + describe '#series' do let(:query_url) { prometheus_series_url('series_name', 'other_service') } |