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