Sha256: 7408e4f58ddc717abd775c7bec70cc381a6755926afc44c276add4de100135da

Contents?: true

Size: 363 Bytes

Versions: 14

Compression:

Stored size: 363 Bytes

Contents

# encoding: utf-8
require "socket"
require "gmetric"

class GangliaClient

  attr_reader :addr, :port, :socket

  def initialize(addr, port)
    @addr   = addr
    @port   = port
    @socket = UDPSocket.new
    socket.connect(addr, port)
  end

  def send(data={})
    g = Ganglia::GMetric.pack(data)
    @socket.send(g[0], 0)
    @socket.send(g[1], 0)
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version Path
logstash-input-ganglia-3.1.4 spec/support/client.rb
logstash-input-ganglia-3.1.3 spec/support/client.rb
logstash-input-ganglia-3.1.2 spec/support/client.rb
logstash-input-ganglia-3.1.1 spec/support/client.rb
logstash-input-ganglia-3.1.0 spec/support/client.rb
logstash-input-ganglia-3.0.2 spec/support/client.rb
logstash-input-ganglia-3.0.1 spec/support/client.rb
logstash-input-ganglia-3.0.0 spec/support/client.rb
logstash-input-ganglia-2.0.6 spec/support/client.rb
logstash-input-ganglia-2.0.4 spec/support/client.rb
logstash-input-ganglia-2.0.3 spec/support/client.rb
logstash-input-ganglia-2.0.2 spec/support/client.rb
logstash-input-ganglia-2.0.1 spec/support/client.rb
logstash-input-ganglia-2.0.0 spec/support/client.rb