class Airbrake::Queue

Queue represents a queue (worker).

@see Airbrake.notify_queue @api public @since v4.9.0

Attributes

error_count[RW]
groups[RW]
queue[RW]
time[RW]
timing[RW]

Public Class Methods

new( queue:, error_count:, groups: {}, timing: nil, time: Time.now ) click to toggle source
# File lib/airbrake-ruby/queue.rb, line 14
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

Public Instance Methods

cargo() click to toggle source
# File lib/airbrake-ruby/queue.rb, line 33
def cargo
  'queues'
end
destination() click to toggle source
# File lib/airbrake-ruby/queue.rb, line 29
def destination
  'queues-stats'
end
hash() click to toggle source
# File lib/airbrake-ruby/queue.rb, line 45
def hash
  {
    'queue' => queue,
    'time' => @time_utc,
  }.hash
end
merge(other) click to toggle source
# File lib/airbrake-ruby/queue.rb, line 52
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 61
def route
  ''
end
to_h() click to toggle source
# File lib/airbrake-ruby/queue.rb, line 37
def to_h
  {
    'queue' => queue,
    'errorCount' => error_count,
    'time' => @time_utc,
  }
end