Packages

instream

0.12.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 line.ex
Raw

lib/instream/writer/line.ex 

defmodule Instream.Writer.Line do

  @moduledoc """

  Point writer for the line protocol.

  """



  use Instream.Writer



  alias Instream.Encoder.Line, as: Encoder

  alias Instream.Query.Headers

  alias Instream.Query.URL





  def write(query, opts, conn) do

    headers = Headers.assemble(conn) ++ [{ 'Content-Type', 'text/plain' }]

    body    = query.payload |> to_line()



    db  = opts[:database] || Map.get(query.payload, :database)

    url =

         conn

      |> URL.write()

      |> URL.append_database(db)

      |> URL.append_precision(query.opts[:precision])



    http_opts = Keyword.get(conn, :http_opts, [])



    { :ok, status, headers, client } = :hackney.post(url, headers, body, http_opts)

    { :ok, response }                = :hackney.body(client)



    { status, headers, response }

  end



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

end