class Airbrake::Queue
@since v4.9.0
@api public
@see Airbrake.notify_queue
Queue represents a queue (worker).
def cargo
def cargo 'queues' end
def destination
def destination 'queues-stats' end
def hash
def hash { 'queue' => queue, 'time' => @time_utc, }.hash end
def initialize(
def initialize( queue:, error_count:, groups: {}, timing: nil, time: Time.now ) @time_utc = TimeTruncate.utc_truncate_minutes(time) @queue = queue @error_count = error_count @groups = groups @timing = timing @time = time end
def merge(other)
def merge(other) self.error_count += other.error_count end
def route
- See: https://github.com/airbrake/airbrake-ruby/pull/537 -
Returns:
-
(String)
- empty route
def route '' end
def to_h
def to_h { 'queue' => queue, 'errorCount' => error_count, 'time' => @time_utc, } end