Class Batch
has 28 methods (exceeds 20 allowed). Consider refactoring.
class Batch
include Mixins::Redis
include Mixins::Assert
include Mixins::Log
include Mixins::Counters
Class Subscriber
has 28 methods (exceeds 20 allowed). Consider refactoring.
class Subscriber < Routemaster::Models::Base
TIMEOUT_RANGE = 0..3_600_000
DEFAULT_TIMEOUT = 500
DEFAULT_MAX_EVENTS = 100
Method call
has 31 lines of code (exceeds 25 allowed). Consider refactoring.
def call
@dispatcher.batched do
Models::Batch.gauges.each_pair do |type, data|
data.each_pair do |name, count|
@dispatcher.gauge(
Method call
has 26 lines of code (exceeds 25 allowed). Consider refactoring.
def call
trace_with_newrelic('Custom/Services/ingest') do
data = Services::Codec.new.dump(@event)
@topic.subscribers.each do |s|
Method call
has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.
def call
Services::Worker.each do |w|
last_at = w.last_at
next if last_at.nil?
next unless last_at <= Routemaster.now - @max_age
Method call
has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.
def call
next_at = Routemaster.now + @every
@queue.push Models::Job.new(name: @name, run_at: @delay ? next_at : nil)
sleep TICK while (block_given? ? yield : true) && Routemaster.now < next_at
end
Method registered
has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.
def self.registered(app)
app.helpers Helpers
app.set :parse do |format|
condition do
Method length
has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.
def length(deadline: nil, scheduled: true, instant: true)
_assert(deadline.nil? || deadline.kind_of?(Integer), 'bad deadline value')
deadline ||= '+inf'
(scheduled ? _redis.zcount(_scheduled_key, '-inf', deadline) : 0) +