modules/rabbitmq/lib/puppet/provider/rabbitmq_vhost/rabbitmqctl.rb

   1 Puppet::Type.type(:rabbitmq_vhost).provide(:rabbitmqctl) do
   2
   3   commands :rabbitmqctl => 'rabbitmqctl'
   4   defaultfor :feature => :posix
   5
   6   def self.instances
   7     rabbitmqctl('list_vhosts').split(/\n/)[1..-2].map do |line|
   8       if line =~ /^(\S+)$/
   9         new(:name => $1)
  10       else
  11         raise Puppet::Error, "Cannot parse invalid user line: #{line}"
  12       end
  13     end
  14   end
  15
  16   def create
  17     rabbitmqctl('add_vhost', resource[:name])
  18   end
  19
  20   def destroy
  21     rabbitmqctl('delete_vhost', resource[:name])
  22   end
  23
  24   def exists?
  25     out = rabbitmqctl('list_vhosts').split(/\n/)[1..-2].detect do |line|
  26       line.match(/^#{resource[:name]}$/)
  27     end
  28   end
  29
  30 end