a9ec8e1c2d
In some case, there are no spaces before - of the balance in swift 1.8.
The change fix this.
/etc/swift/object.builder, build version 9
32768 partitions, 3.000000 replicas, 1 regions, 3 zones, 9 devices, 200.00 balance
The minimum number of hours before a partition can be reassigned is 24
Devices: id region zone ip address port name weight partitions balance meta
0 1 1 10.68.0.45 6000 sdd 100.00 32768 200.00
1 1 2 10.68.0.46 6000 sdd 100.00 0-100.00
...
Change-Id: Ic7757a22ce94e4d51ae11780d4626c90a9ed430f
138 lines
3.5 KiB
Ruby
138 lines
3.5 KiB
Ruby
class Puppet::Provider::SwiftRingBuilder < Puppet::Provider
|
|
|
|
def self.instances
|
|
# TODO iterate through the databases
|
|
# and add the database that we used a property
|
|
ring.keys.collect do |name|
|
|
new(:name => name)
|
|
end
|
|
end
|
|
|
|
|
|
def self.lookup_ring
|
|
object_hash = {}
|
|
if File.exists?(builder_file_path)
|
|
if rows = swift_ring_builder(builder_file_path).split("\n")[4..-1]
|
|
rows.each do |row|
|
|
# Swift 1.7+ output example:
|
|
# Devices: id region zone ip address port name weight partitions balance meta
|
|
# 0 1 2 127.0.0.1 6022 2 1.00 262144 0.00
|
|
# 0 1 3 192.168.101.15 6002 1 1.00 262144 -100.00
|
|
# Swift 1.8+ output example:
|
|
# Devices: id region zone ip address port name weight partitions balance meta
|
|
# 2 1 2 192.168.101.14 6002 1 1.00 262144 200.00 m2
|
|
# 0 1 3 192.168.101.15 6002 1 1.00 262144-100.00 m2
|
|
if row =~ /^\s*(\d+)\s+\d+\s+(\d+)\s+(\S+)\s+(\d+)\s+(\S+)\s+(\d+\.\d+)\s+(\d+)\s*((-|\s-?)?\d+\.\d+)\s*(\S*)/
|
|
|
|
object_hash["#{$3}:#{$4}/#{$5}"] = {
|
|
:id => $1,
|
|
:zone => $2,
|
|
:weight => $6,
|
|
:partitions => $7,
|
|
:balance => $8,
|
|
:meta => $10
|
|
}
|
|
# This regex is for older swift versions
|
|
elsif row =~ /^\s+(\d+)\s+(\d+)\s+(\S+)\s+(\d+)\s+(\S+)\s+(\d+\.\d+)\s+(\d+)\s+(-?\d+\.\d+)\s+(\S*)$/
|
|
|
|
object_hash["#{$3}:#{$4}/#{$5}"] = {
|
|
:id => $1,
|
|
:zone => $2,
|
|
:weight => $6,
|
|
:partitions => $7,
|
|
:balance => $8,
|
|
:meta => $9
|
|
}
|
|
|
|
else
|
|
Puppet.warning("Unexpected line: #{row}")
|
|
end
|
|
end
|
|
end
|
|
end
|
|
object_hash
|
|
end
|
|
|
|
def ring
|
|
self.class.ring
|
|
end
|
|
|
|
def builder_file_path
|
|
self.class.builder_file_path
|
|
end
|
|
|
|
def exists?
|
|
ring[resource[:name]]
|
|
end
|
|
|
|
def create
|
|
[:zone, :weight].each do |param|
|
|
raise(Puppet::Error, "#{param} is required") unless resource[param]
|
|
end
|
|
swift_ring_builder(
|
|
builder_file_path,
|
|
'add',
|
|
"z#{resource[:zone]}-#{resource[:name]}",
|
|
resource[:weight]
|
|
)
|
|
end
|
|
|
|
def id
|
|
ring[resource[:name]][:id]
|
|
end
|
|
|
|
def id=(id)
|
|
raise(Puppet::Error, "Cannot assign id, it is immutable")
|
|
end
|
|
|
|
def zone
|
|
ring[resource[:name]][:zone]
|
|
end
|
|
|
|
# TODO - is updating the zone supported?
|
|
def zone=(zone)
|
|
Puppet.warning('Setting zone is not yet supported, I am not even sure if it is supported')
|
|
end
|
|
|
|
def weight
|
|
ring[resource[:name]][:weight]
|
|
# get the weight
|
|
end
|
|
|
|
def weight=(weight)
|
|
swift_ring_builder(
|
|
builder_file_path,
|
|
'set_weight',
|
|
"d#{ring[resource[:name]][:id]}",
|
|
resource[:weight]
|
|
)
|
|
# requires a rebalance
|
|
end
|
|
|
|
def partitions
|
|
ring[resource[:name]][:partitions]
|
|
end
|
|
|
|
def partitions=(part)
|
|
raise(Puppet::Error, "Cannot set partitions, it is set by rebalancing")
|
|
end
|
|
|
|
def balance
|
|
ring[resource[:name]][:balance]
|
|
end
|
|
|
|
def balance=(balance)
|
|
raise(Puppet::Error, "Cannot set balance, it is set by rebalancing")
|
|
end
|
|
|
|
def meta
|
|
ring[resource[:name]][:meta]
|
|
end
|
|
|
|
def meta=(meta)
|
|
raise(Puppet::Error, "Cannot set meta, I am not sure if it makes sense or what it is for")
|
|
end
|
|
|
|
end
|
|
|