class GraphiteAPI::Connector::Group

Public Class Methods

new(options) click to toggle source
# File lib/graphite-api/connector.rb, line 76
def initialize options
  @connectors = options[:backends].map(&Connector.method(:new))
end

Public Instance Methods

check!() click to toggle source

init all sockets in group. should throw exception on Socket errors.

# File lib/graphite-api/connector.rb, line 87
def check!
  @connectors.each do |c|
    begin
      c.check!
    rescue Exception => e
      raise e, "#{c.uri}: #{e.message}", e.backtrace
    end
  end
end
publish(messages) click to toggle source
# File lib/graphite-api/connector.rb, line 80
def publish messages
  Logger.debug [:connector_group, :publish, messages.size, @connectors]
  Array(messages).each { |msg| @connectors.map {|c| c.puts msg} }
end