Module: Cosmo::API::Stats
- Defined in:
- lib/cosmo/api/stats.rb
Class Method Summary collapse
- .busy ⇒ Object
- .dead ⇒ Object
- .enqueued ⇒ Object
- .failed ⇒ Object
- .processed ⇒ Object
- .retries ⇒ Object
- .scheduled ⇒ Object
- .summary ⇒ Object
Class Method Details
.dead ⇒ Object
39 40 41 |
# File 'lib/cosmo/api/stats.rb', line 39 def dead Stream.new("dead").size end |
.enqueued ⇒ Object
27 28 29 |
# File 'lib/cosmo/api/stats.rb', line 27 def enqueued Stream.jobs.sum(&:size) end |
.failed ⇒ Object
19 20 21 |
# File 'lib/cosmo/api/stats.rb', line 19 def failed Counter.instance.get(:failed) end |
.processed ⇒ Object
15 16 17 |
# File 'lib/cosmo/api/stats.rb', line 15 def processed Counter.instance.get(:processed) end |
.retries ⇒ Object
31 32 33 |
# File 'lib/cosmo/api/stats.rb', line 31 def retries Stream.jobs.sum(&:retries) end |
.scheduled ⇒ Object
35 36 37 |
# File 'lib/cosmo/api/stats.rb', line 35 def scheduled Stream.new("scheduled").size end |
.summary ⇒ Object
11 12 13 |
# File 'lib/cosmo/api/stats.rb', line 11 def summary { processed:, failed:, busy:, enqueued:, retries:, scheduled:, dead: } end |