Module: Cosmo::API::Stats

Defined in:
lib/cosmo/api/stats.rb

Class Method Summary collapse

Class Method Details

.busyObject



23
24
25
# File 'lib/cosmo/api/stats.rb', line 23

def busy
  Busy.instance.size
end

.deadObject



39
40
41
# File 'lib/cosmo/api/stats.rb', line 39

def dead
  Stream.new("dead").size
end

.enqueuedObject



27
28
29
# File 'lib/cosmo/api/stats.rb', line 27

def enqueued
  Stream.jobs.sum(&:size)
end

.failedObject



19
20
21
# File 'lib/cosmo/api/stats.rb', line 19

def failed
  Counter.instance.get(:failed)
end

.processedObject



15
16
17
# File 'lib/cosmo/api/stats.rb', line 15

def processed
  Counter.instance.get(:processed)
end

.retriesObject



31
32
33
# File 'lib/cosmo/api/stats.rb', line 31

def retries
  Stream.jobs.sum(&:retries)
end

.scheduledObject



35
36
37
# File 'lib/cosmo/api/stats.rb', line 35

def scheduled
  Stream.new("scheduled").size
end

.summaryObject



11
12
13
# File 'lib/cosmo/api/stats.rb', line 11

def summary
  { processed:, failed:, busy:, enqueued:, retries:, scheduled:, dead: }
end