Module: Sidekiq::Paquet

Defined in:

lib/sidekiq/paquet.rb,
lib/sidekiq/paquet/web.rb,
lib/sidekiq/paquet/bundle.rb,
lib/sidekiq/paquet/flusher.rb,
lib/sidekiq/paquet/version.rb,
lib/sidekiq/paquet/middleware.rb

Defined Under Namespace

Modules: Web Classes: Bundle, Flusher, Middleware

Constant Summary

DEFAULTS =

{
  default_bundle_size: 100,
  flush_interval: nil,
  average_flush_interval: 15,
  initial_wait: 10,
  compatibility_mode: false
}

VERSION =

'0.2.4'

Class Method Summary

• .compatibility_mode=(v) ⇒ Object
• .initial_wait ⇒ Object
• .options ⇒ Object
• .options=(opts) ⇒ Object

Class Method Details

.compatibility_mode=(v) ⇒ Object

# File 'lib/sidekiq/paquet.rb', line 28

def self.compatibility_mode=(v)
  options[:compatibility_mode] = !!v
end

.initial_wait ⇒ Object

# File 'lib/sidekiq/paquet.rb', line 32

def self.initial_wait
  options[:initial_wait] + (10 * rand)
end

.options ⇒ Object

# File 'lib/sidekiq/paquet.rb', line 20

def self.options
  @options ||= DEFAULTS.dup
end

.options=(opts) ⇒ Object

# File 'lib/sidekiq/paquet.rb', line 24

def self.options=(opts)
  @options = opts
end