FilesExpand file tree

pl-master

/

check_queue_size_munin

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

executable file

·

51 lines (37 loc) · 1.16 KB

pl-master

/

check_queue_size_munin

Copy path

Top

File metadata and controls

• Code
• Blame

executable file

·

51 lines (37 loc) · 1.16 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

#!/usr/bin/env ruby

require 'rubygems'

require 'munin_plugin'

Dir.chdir(File.join(File.expand_path(File.dirname(__FILE__)), "..")) do

require 'bunny'

$:.unshift(File.expand_path('../../lib', __FILE__))

require 'chef/expander'

require 'chef/expander/version'

require 'chef/expander/configuration'

include Chef

munin_plugin do

graph_title "Expander Queue Size"

graph_vlabel "Events"

graph_category "Opscode"

graph_info "Events in the Expander Queue waiting to be consumed by Solr."

queuesize.label "events"

queuesize.draw "LINE"

queuesize.warning "100"

queuesize.critical "200"

collect do

Expander.init_config([])

message_counts = []

begin

amqp_client = Bunny.new(Expander.config.amqp_config)

amqp_client.start

0.upto(Expander::VNODES - 1) do |vnode|

q = amqp_client.queue("vnode-#{vnode}", :durable => true)

message_counts << q.status[:message_count]

end

total_messages = message_counts.inject(:+)

ensure

amqp_client.stop if defined?(amqp_client) && amqp_client && amqp_client.connected?

end

queuesize.value total_messages

end

end

end