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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
|
require 'puppet'
require File.join(File.dirname(__FILE__), '..', '..', '..', '..', '..', 'lib', 'puppet', 'provider', 'ring_object_device', 'swift_ring_builder')
provider_class = Puppet::Type.type(:ring_object_device).provider(:swift_ring_builder)
describe provider_class do
it "should have the SwiftRingBuilder provider class as its baseclass" do
expect(provider_class.superclass).to equal(Puppet::Provider::SwiftRingBuilder)
end
let :builder_file_path do
'/etc/swift/object.builder'
end
let :provider do
described_class.new(
Puppet::Type.type(:ring_object_device).new(
:name => '192.168.101.13:6002/1',
:zone => '1',
:weight => '1',
:provider => :swift_ring_builder
)
)
end
let :object_builder_output do
'/etc/swift/object.builder, build version 3
262144 partitions, 3 replicas, 3 zones, 3 devices, 0.00 balance
The minimum number of hours before a partition can be reassigned is 1
The overload factor is 0.00% (0.000000)
Ring file /etc/swift/object.ring.gz is up-to-date
Devices: id region zone ip address:port replic_ip:replic_port name weight partitions balance meta
1 1 1 192.168.101.13:6002 192.168.101.13:6002 1 1.00 262144 0.00
2 1 2 192.168.101.14:6002 192.168.101.14:6002 1 1.00 262144 200.00 m2
0 1 3 192.168.101.15:6002 192.168.101.15:6002 1 1.00 262144-100.00 m2
3 1 1 192.168.101.16:6002 192.168.101.16:6002 1 1.00 262144-100.00
'
end
describe "with no storage policy_index set" do
it 'object builder file should be object.builder when object name has no policy_index' do
policy_index = provider.policy_index
expect(provider.builder_file_path(policy_index)).to eq builder_file_path
end
it 'object builder file should be object.builder when object is invoked with policy_index 0' do
expect(provider.builder_file_path(0)).to eq builder_file_path
end
it 'object builder file should not be object-1.builder when object name has no policy_index' do
policy_index = provider.policy_index
expect(provider.builder_file_path(policy_index)).to_not eq builder_file_path_policy1
end
it 'object builder file should not be object-1.builder when object is invoked with policy_index 0' do
expect(provider.builder_file_path(0)).to_not eq builder_file_path_policy1
end
it 'ring_object_device should exist when found in builder file' do
expect(provider).to receive(:swift_ring_builder).and_return object_builder_output
expect(File).to receive(:exists?).with(builder_file_path).and_return(true)
expect(provider.exists?).to eq({:id=>"1", :region=>"1", :zone=>"1", :weight=>"1.00", :partitions=>"262144", :balance=>"0.00", :meta=>"", :policy_index=>''})
end
it 'should be able to lookup the local ring' do
expect(File).to receive(:exists?).with(builder_file_path).and_return(true)
expect(provider).to receive(:builder_file_path).twice.and_return(builder_file_path)
expect(provider).to receive(:swift_ring_builder).and_return object_builder_output
resources = provider.lookup_ring
expect(resources['192.168.101.13:6002/1']).to_not be_nil
expect(resources['192.168.101.14:6002/1']).to_not be_nil
expect(resources['192.168.101.15:6002/1']).to_not be_nil
expect(resources['192.168.101.16:6002/1']).to_not be_nil
expect(resources['192.168.101.13:6002/1'][:id]).to eql '1'
expect(resources['192.168.101.13:6002/1'][:region]).to eql '1'
expect(resources['192.168.101.13:6002/1'][:zone]).to eql '1'
expect(resources['192.168.101.13:6002/1'][:weight]).to eql '1.00'
expect(resources['192.168.101.13:6002/1'][:partitions]).to eql '262144'
expect(resources['192.168.101.13:6002/1'][:balance]).to eql '0.00'
expect(resources['192.168.101.13:6002/1'][:meta]).to eql ''
expect(resources['192.168.101.13:6002/1'][:policy_index]).to eql ''
expect(resources['192.168.101.14:6002/1'][:id]).to eql '2'
expect(resources['192.168.101.14:6002/1'][:region]).to eql '1'
expect(resources['192.168.101.14:6002/1'][:zone]).to eql '2'
expect(resources['192.168.101.14:6002/1'][:weight]).to eql '1.00'
expect(resources['192.168.101.14:6002/1'][:partitions]).to eql '262144'
expect(resources['192.168.101.14:6002/1'][:balance]).to eql '200.00'
expect(resources['192.168.101.14:6002/1'][:meta]).to eql 'm2'
expect(resources['192.168.101.14:6002/1'][:policy_index]).to eql ''
end
end
let :builder_file_path_policy1 do
'/etc/swift/object-1.builder'
end
let :provider_policy1 do
described_class.new(
Puppet::Type.type(:ring_object_device).new(
:name => '1:192.168.101.13:6002/1',
:zone => '1',
:weight => '1',
:provider => :swift_ring_builder
)
)
end
let :object_builder_policy1_output do
'/etc/swift/object-1.builder, build version 3
262144 partitions, 3 replicas, 3 zones, 3 devices, 0.00 balance
The minimum number of hours before a partition can be reassigned is 1
The overload factor is 0.00% (0.000000)
Ring file /etc/swift/object-1.ring.gz is up-to-date
Devices: id region zone ip address:port replic_ip:replic_port name weight partitions balance meta
1 1 1 192.168.101.13:6002 192.168.101.13:6002 1 1.00 262144 0.00
2 1 2 192.168.101.14:6002 192.168.101.14:6002 1 1.00 262144 200.00 m2
0 1 3 192.168.101.15:6002 192.168.101.15:6002 1 1.00 262144-100.00 m2
3 1 1 192.168.101.16:6002 192.168.101.16:6002 1 1.00 262144-100.00
'
end
describe "with a storage policy_index set" do
it 'object builder file should be object-1.builder when object name has policy_index 1' do
policy_index = provider_policy1.policy_index
expect(provider_policy1.builder_file_path(policy_index)).to eq builder_file_path_policy1
end
it 'object builder file should not be object.builder when object names has policy_index 1' do
policy_index = provider_policy1.policy_index
expect(provider_policy1.builder_file_path(policy_index)).to_not eq builder_file_path
end
it 'ring_object_device should exist when found in builder file with policy_index=1' do
expect(provider_policy1).to receive(:swift_ring_builder).and_return object_builder_policy1_output
expect(File).to receive(:exists?).with(builder_file_path_policy1).and_return(true)
expect(provider_policy1.exists?).to eq({:id=>"1", :region=>"1", :zone=>"1", :weight=>"1.00", :partitions=>"262144", :balance=>"0.00", :meta=>"", :policy_index=>"1"})
end
it 'lookup local ring and object resource names should start with policy_index if a policy is set' do
expect(File).to receive(:exists?).with(builder_file_path_policy1).and_return(true)
expect(provider_policy1).to receive(:builder_file_path).twice.and_return(builder_file_path_policy1)
expect(provider_policy1).to receive(:swift_ring_builder).and_return object_builder_output
resources = provider_policy1.lookup_ring
expect(resources['1:192.168.101.13:6002/1']).to_not be_nil
expect(resources['1:192.168.101.14:6002/1']).to_not be_nil
expect(resources['1:192.168.101.15:6002/1']).to_not be_nil
expect(resources['1:192.168.101.16:6002/1']).to_not be_nil
expect(resources['1:192.168.101.13:6002/1'][:id]).to eql '1'
expect(resources['1:192.168.101.13:6002/1'][:region]).to eql '1'
expect(resources['1:192.168.101.13:6002/1'][:zone]).to eql '1'
expect(resources['1:192.168.101.13:6002/1'][:weight]).to eql '1.00'
expect(resources['1:192.168.101.13:6002/1'][:partitions]).to eql '262144'
expect(resources['1:192.168.101.13:6002/1'][:balance]).to eql '0.00'
expect(resources['1:192.168.101.13:6002/1'][:meta]).to eql ''
expect(resources['1:192.168.101.13:6002/1'][:policy_index]).to eql '1'
expect(resources['1:192.168.101.14:6002/1'][:id]).to eql '2'
expect(resources['1:192.168.101.14:6002/1'][:region]).to eql '1'
expect(resources['1:192.168.101.14:6002/1'][:zone]).to eql '2'
expect(resources['1:192.168.101.14:6002/1'][:weight]).to eql '1.00'
expect(resources['1:192.168.101.14:6002/1'][:partitions]).to eql '262144'
expect(resources['1:192.168.101.14:6002/1'][:balance]).to eql '200.00'
expect(resources['1:192.168.101.14:6002/1'][:meta]).to eql 'm2'
expect(resources['1:192.168.101.14:6002/1'][:policy_index]).to eql '1'
end
end
end
|
