1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
# frozen_string_literal: true
require 'spec_helper'
require 'support/helpers/rails_helpers'
RSpec.describe Gitlab::Instrumentation::ConnectionPool, feature_category: :redis do
let(:option) { { name: 'test', size: 5 } }
let(:pool) { ConnectionPool.new(option) { 'nothing' } }
let_it_be(:size_gauge_args) { [:gitlab_connection_pool_size, 'Size of connection pool', {}, :all] }
let_it_be(:available_gauge_args) do
[:gitlab_connection_pool_available_count,
'Number of available connections in the pool', {}, :all]
end
subject(:checkout_pool) { pool.checkout }
describe '.checkout' do
let(:size_gauge_double) { instance_double(::Prometheus::Client::Gauge) }
context 'when tracking for the first time' do
it 'initialises gauges' do
expect(::Gitlab::Metrics).to receive(:gauge).with(*size_gauge_args).and_call_original
expect(::Gitlab::Metrics).to receive(:gauge).with(*available_gauge_args).and_call_original
checkout_pool
end
end
it 'sets the size gauge only once' do
expect(::Gitlab::Metrics.gauge(*size_gauge_args)).to receive(:set).with(
{ pool_name: 'test', pool_key: anything, connection_class: "String" }, 5).once
checkout_pool
checkout_pool
end
context 'when tracking on subsequent calls' do
before do
pool.checkout # initialise instance variables
end
it 'uses memoized gauges' do
expect(::Gitlab::Metrics).not_to receive(:gauge).with(*size_gauge_args)
expect(::Gitlab::Metrics).not_to receive(:gauge).with(*available_gauge_args)
expect(pool.instance_variable_get(:@size_gauge)).not_to receive(:set)
.with({ pool_name: 'test', pool_key: anything, connection_class: "String" }, 5)
expect(pool.instance_variable_get(:@available_gauge)).to receive(:set)
.with({ pool_name: 'test', pool_key: anything, connection_class: "String" }, 4)
checkout_pool
end
context 'when pool name is omitted' do
let(:option) { {} }
it 'uses unknown name' do
expect(pool.instance_variable_get(:@size_gauge)).not_to receive(:set)
.with({ pool_name: 'unknown', pool_key: anything, connection_class: "String" }, 5)
expect(pool.instance_variable_get(:@available_gauge)).to receive(:set)
.with({ pool_name: 'unknown', pool_key: anything, connection_class: "String" }, 4)
checkout_pool
end
end
end
end
end
|
