Class: Kanshi

Inherits:
Object
  • Object
show all
Defined in:
lib/kanshi.rb

Defined Under Namespace

Classes: Collector, ScrollsReporter

Constant Summary collapse

Queries = 
<<EOF.split(/\s*;\s*/)
SELECT
  pg_database_size(d.datname) AS size,
  numbackends,
  xact_commit,
  xact_rollback,
  blks_read,
  blks_hit,
  blks_read + blks_hit AS blks_total,
  tup_fetched,
  tup_returned,
  tup_inserted,
  tup_updated,
  tup_deleted
FROM
  pg_stat_database d
WHERE
  d.datname = ?;

SELECT
  SUM(seq_scan)::bigint AS seq_scan,
  SUM(seq_tup_read)::bigint AS seq_tup_read,
  SUM(idx_scan)::bigint AS idx_scan,
  SUM(idx_tup_fetch)::bigint AS idx_tup_fetch
FROM
  pg_stat_user_tables;

SELECT
  SUM(heap_blks_read)::bigint AS heap_blks_read,
  SUM(heap_blks_hit)::bigint AS heap_blks_hit,
  SUM(idx_blks_read)::bigint AS idx_blks_read,
  SUM(idx_blks_hit)::bigint AS idx_blks_hit
FROM
  pg_statio_user_tables;

SELECT
  COUNT(*) AS locks_waiting
FROM
  pg_locks
WHERE
  granted = 'f';

SELECT
  EXTRACT('epoch' from SUM(NOW() - xact_start)) AS total_open_xact_time
FROM
  pg_stat_activity
WHERE
  xact_start IS NOT NULL;

SELECT
  COUNT(*) AS xact_waiting
FROM
  pg_stat_activity
WHERE
  waiting = 't';

SELECT
  COUNT(*) AS xact_idle
FROM
  pg_stat_activity
WHERE
  current_query = '<IDLE> in transaction';
EOF

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Kanshi

Returns a new instance of Kanshi.



12
13
14
15
16
17
18
19
20
 
# File 'lib/kanshi.rb', line 12

def initialize(options = {})
  @options = {
    :databases => {},
    :delay => 60,
    :reporter => ScrollsReporter
  }
  @options.merge!(options)
  @reporter = @options[:reporter].new
end

Class Method Details

.run(*args) ⇒ Object 



8
9
10
 
# File 'lib/kanshi.rb', line 8

def self.run(*args)
  self.new(*args).run
end

Instance Method Details

#report ⇒ Object 



29
30
31
32
33
34
35
36
 
# File 'lib/kanshi.rb', line 29

def report
  @options[:databases].each do |name, database_url|
    @reporter.report(
      name,
      database_url,
      Collector.collect(database_url))
  end
end

#run ⇒ Object 



22
23
24
25
26
27
 
# File 'lib/kanshi.rb', line 22

def run
  loop do
    report
    sleep(@options[:delay])
  end
end