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
|
require File.expand_path(File.join(File.dirname(__FILE__), '..', 'rabbitmq_cli'))
Puppet::Type.type(:rabbitmq_vhost).provide(:rabbitmqctl, parent: Puppet::Provider::RabbitmqCli) do
confine feature: :posix
def self.instances
vhost_list = run_with_retries do
rabbitmqctl_list('vhosts')
end
vhost_list.split(%r{\n}).map do |line|
raise Puppet::Error, "Cannot parse invalid vhost line: #{line}" unless line =~ %r{^(\S+)$}
new(name: Regexp.last_match(1))
end
end
def create
rabbitmqctl('add_vhost', resource[:name])
end
def destroy
rabbitmqctl('delete_vhost', resource[:name])
end
def exists?
run_with_retries { rabbitmqctl_list('vhosts') }.split(%r{\n}).include? resource[:name]
end
end
|
