Packages

instream

0.14.0
2.2.1 2.2.0 2.1.0 2.0.0 2.0.0-rc.1 2.0.0-rc.0 1.0.0 0.22.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.1 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

InfluxDB driver for Elixir

HexDocs

Current section

Files

Jump to
Readme
30 Versions
3 Dependencies
Dependants
Files
Activity
instream lib instream writer udp.ex
Raw

lib/instream/writer/udp.ex 

defmodule Instream.Writer.UDP do

  @moduledoc """

  Point writer for the line protocol using UDP.

  """



  use Instream.Writer



  alias Instream.Encoder.Line, as: Encoder





  def write(query, _opts, %{ module: conn, udp_socket: udp_socket }) do

    config  = conn.config()

    payload = query.payload |> to_line()



    :ok = :gen_udp.send(

      udp_socket,

      config[:host] |> to_char_list(),

      config[:port_udp],

      to_char_list(payload)

    )



    { 200, [], "" }  # always ":ok"

  end



  defp to_line(payload), do: payload |> Map.get(:points, []) |> Encoder.encode()

end