class Metrico::Client

Attributes

transport[R]

Public Class Methods

new() click to toggle source
# File lib/metrico/client.rb, line 5
def initialize
  @transport = NATS::IO::Client.new
  @transport.connect(Metrico.config.nats_connect_options)
  transport_callbacks
end

Public Instance Methods

push(point) click to toggle source
# File lib/metrico/client.rb, line 11
def push(point)
  transport.publish(Metrico.config.subject, point.to_s)
end

Private Instance Methods

transport_callbacks() click to toggle source
# File lib/metrico/client.rb, line 15
        def transport_callbacks
  %w[on_error on_reconnect on_disconnect on_close].each do |callback|
    if Metrico.config.send(callback)
      @transport.send(callback, &Metrico.config.send(callback))
    end
  end
end