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