Class: Metricize::Forwarder

Inherits:
Object
  • Object
show all
Includes:
SharedMethods
Defined in:
lib/metricize/forwarder.rb

Instance Method Summary collapse

Methods included from SharedMethods

#establish_redis_connection

Constructor Details

#initialize(options) ⇒ Forwarder

Returns a new instance of Forwarder.



5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/metricize/forwarder.rb', line 5

def initialize(options)
  @password          = options.fetch(:password)
  @username          = options.fetch(:username)
  @remote_url        = options[:remote_url]     || 'metrics-api.librato.com/v1/metrics'
  @remote_timeout    = (options[:remote_timeout] || 12).to_i
  @remote_requests   = (options[:remote_requests] || 30).to_i
  @batch_size        = (options[:batch_size] || 5000).to_i
  @batch_sleep       = (options[:batch_sleep] || 1).to_i
  establish_logger(options)
  initialize_redis(options)
end

Instance Method Details

#go! ⇒ Object 



17
18
19
 
# File 'lib/metricize/forwarder.rb', line 17

def go!
  process_metric_queue
end