Class: Linr::Connection::UDP

Inherits:

Object

• Object
• Linr::Connection::UDP

Defined in:

lib/linr/connection/udp.rb

Overview

Connects to a InfluxDB UDP port

Examples:

UDP.new("localhost", 8089).send("series a=0.51")

See Also:

• https://influxdb.com/docs/v0.9/write_protocols/udp.html

Constant Summary

SEND_FLAGS =

Use non-custom flags

0

Instance Method Summary

• #initialize(host, port) ⇒ UDP constructor

  Establishes a connection.

• #send(data) ⇒ Object

  Send data over the UDP connection.

Constructor Details

#initialize(host, port) ⇒ UDP

Establishes a connection

Parameters:

• host (String)
• port (Fixnum)

# File 'lib/linr/connection/udp.rb', line 16

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

Instance Method Details

#send(data) ⇒ Object

Send data over the UDP connection. Should be encoded using the Line Protocol.

Parameters:

• data (String)

See Also:

• Encoder::Line

# File 'lib/linr/connection/udp.rb', line 25

def send(data)
  @socket.send(data, SEND_FLAGS)
end