class Airbrake::Queue
Queue
represents a queue (worker).
@see Airbrake.notify_queue
@api public @since v4.9.0 rubocop:disable Metrics/ParameterLists
Attributes
end_time[RW]
error_count[RW]
groups[RW]
queue[RW]
start_time[RW]
time[RW]
timing[RW]
Public Class Methods
new( queue:, error_count:, groups: {}, start_time: Time.now, end_time: start_time + 1, timing: nil, time: Time.now )
click to toggle source
# File lib/airbrake-ruby/queue.rb, line 16 def initialize( queue:, error_count:, groups: {}, start_time: Time.now, end_time: start_time + 1, timing: nil, time: Time.now ) @time_utc = TimeTruncate.utc_truncate_minutes(time) @queue = queue @error_count = error_count @groups = groups @start_time = start_time @end_time = end_time @timing = timing @time = time end
Public Instance Methods
cargo()
click to toggle source
# File lib/airbrake-ruby/queue.rb, line 39 def cargo 'queues' end
destination()
click to toggle source
# File lib/airbrake-ruby/queue.rb, line 35 def destination 'queues-stats' end
hash()
click to toggle source
# File lib/airbrake-ruby/queue.rb, line 51 def hash { 'queue' => queue, 'time' => @time_utc, }.hash end
merge(other)
click to toggle source
# File lib/airbrake-ruby/queue.rb, line 58 def merge(other) self.error_count += other.error_count end
route()
click to toggle source
Queues don't have routes, but we want to define this to make sure our filter API is consistent (other models define this property)
@return [String] empty route @see github.com/airbrake/airbrake-ruby/pull/537
# File lib/airbrake-ruby/queue.rb, line 67 def route '' end
to_h()
click to toggle source
# File lib/airbrake-ruby/queue.rb, line 43 def to_h { 'queue' => queue, 'errorCount' => error_count, 'time' => @time_utc, } end