Initial commit.

.formatter.exs

@@ -0,0 +1,4 @@
+# Used by "mix format"
+[
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+]

.gitignore

@@ -0,0 +1,38 @@
+# The directory Mix will write compiled artifacts to.
+/_build/
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover/
+
+# The directory Mix downloads your dependencies sources to.
+/deps/
+
+# Where third-party dependencies like ExDoc output generated docs.
+/doc/
+
+# Ignore .fetch files in case you like to edit your project deps locally.
+/.fetch
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez
+
+# Ignore package tarball (built via "mix hex.build").
+etcdex-*.tar
+
+# Temporary files, for example, from tests.
+/tmp/
+
+### Vim
+# Swap
+[._]*.s[a-v][a-z]
+[._]*.sw[a-p]
+[._]s[a-rt-v][a-z]
+[._]ss[a-gi-z]
+[._]sw[a-p]
+
+# Temporary files
+.netrwhist
+*~

README.md

@@ -0,0 +1,21 @@
+# EtcdEx
+
+**TODO: Add description**
+
+## Installation
+
+If [available in Hex](https://hex.pm/docs/publish), the package can be installed
+by adding `etcdex` to your list of dependencies in `mix.exs`:
+
+```elixir
+def deps do
+  [
+    {:etcdex, "~> 0.1.0"}
+  ]
+end
+```
+
+Documentation can be generated with [ExDoc](https://github.com/elixir-lang/ex_doc)
+and published on [HexDocs](https://hexdocs.pm). Once published, the docs can
+be found at <https://hexdocs.pm/etcdex>.
+

lib/etcd_ex.ex

@@ -0,0 +1,270 @@
+defmodule EtcdEx do
+  @moduledoc """
+  This module provides interface to Etcd.
+  """
+
+  @type conn :: EtcdEx.Connection.t()
+  @type key :: String.t()
+  @type value :: String.t()
+  @type range_end :: String.t()
+  @type lease :: integer
+  @type limit :: non_neg_integer
+  @type revision :: pos_integer
+  @type sort :: {sort_target, sort_order}
+  @type sort_target :: :KEY | :VERSION | :VALUE | :CREATE | :MOD
+  @type sort_order :: :NONE | :ASCEND | :DESCEND
+
+  @type get_opts :: [get_opt]
+  @type get_opt ::
+          {:range_end, range_end}
+          | {:prefix, boolean}
+          | {:from_key, boolean}
+          | {:limit, limit}
+          | {:revision, revision}
+          | {:sort, sort}
+          | {:serializable, boolean}
+          | {:keys_only, boolean}
+          | {:count_only, boolean}
+          | {:min_mod_revision, revision}
+          | {:max_mod_revision, revision}
+          | {:min_create_revision, revision}
+          | {:max_create_revision, revision}
+          | {:timeout, timeout}
+
+  @type put_opts :: [put_opt]
+  @type put_opt ::
+          {:lease, lease}
+          | {:prev_kv, boolean}
+          | {:ignore_value, boolean}
+          | {:ignore_lease, boolean}
+          | {:timeout, timeout}
+
+  @type delete_opts :: [delete_opt]
+  @type delete_opt ::
+          {:range_end, range_end}
+          | {:prefix, boolean}
+          | {:from_key, boolean}
+          | {:prev_kv, boolean}
+          | {:timeout, timeout}
+
+  @doc """
+  Gets one or range of key-value pairs from Etcd.
+  """
+  def get(conn, key, opts \\ []) when is_atom(conn) and is_binary(key) and is_list(opts) do
+    request =
+      conn
+      |> :eetcd_kv.new()
+      |> :eetcd_kv.with_key(key)
+      |> build_get_opts(opts)
+
+    EtcdEx.Connection.get(conn, request)
+  end
+
+  defp build_get_opts(req, []), do: req
+
+  defp build_get_opts(req, [{:range_end, range_end} | opts]) do
+    req
+    |> :eetcd_kv.with_range_end(range_end)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:prefix, true} | opts]) do
+    req
+    |> :eetcd_kv.with_prefix()
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:prefix, _} | opts]), do: build_get_opts(req, opts)
+
+  defp build_get_opts(req, [{:from_key, true} | opts]) do
+    req
+    |> :eetcd_kv.with_from_key()
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:from_key, _} | opts]), do: build_get_opts(req, opts)
+
+  defp build_get_opts(req, [{:limit, limit} | opts]) do
+    req
+    |> :eetcd_kv.with_limit(limit)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:lease, lease} | opts]) do
+    req
+    |> :eetcd_kv.with_lease(lease)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:revision, revision} | opts]) do
+    req
+    |> :eetcd_kv.with_rev(revision)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:sort, {sort_target, sort_order}} | opts]) do
+    req
+    |> :eetcd_kv.with_sort(sort_target, sort_order)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:serializable, true} | opts]) do
+    req
+    |> :eetcd_kv.with_serializable()
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:serializable, _} | opts]), do: build_get_opts(req, opts)
+
+  defp build_get_opts(req, [{:keys_only, true} | opts]) do
+    req
+    |> :eetcd_kv.with_keys_only()
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:keys_only, _} | opts]), do: build_get_opts(req, opts)
+
+  defp build_get_opts(req, [{:count_only, true} | opts]) do
+    req
+    |> :eetcd_kv.with_count_only()
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:count_only, _} | opts]), do: build_get_opts(req, opts)
+
+  defp build_get_opts(req, [{:min_mod_revision, revision} | opts]) do
+    req
+    |> :eetcd_kv.with_min_mod_rev(revision)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:max_mod_revision, revision} | opts]) do
+    req
+    |> :eetcd_kv.with_max_mod_rev(revision)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:min_create_revision, revision} | opts]) do
+    req
+    |> :eetcd_kv.with_min_create_rev(revision)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:max_create_revision, revision} | opts]) do
+    req
+    |> :eetcd_kv.with_max_create_rev(revision)
+    |> build_get_opts(opts)
+  end
+
+  defp build_get_opts(req, [{:timeout, timeout} | opts]) do
+    req
+    |> :eetcd_kv.with_timeout(timeout)
+    |> build_get_opts(opts)
+  end
+
+  @doc """
+  Puts a key-value pair to Etcd.
+  """
+  @spec put(conn, key, value, put_opts) :: {:ok, any} | {:error, any}
+  def put(conn, key, value, opts \\ [])
+      when is_atom(conn) and is_binary(key) and is_binary(value) and is_list(opts) do
+    request =
+      conn
+      |> :eetcd_kv.new()
+      |> :eetcd_kv.with_key(key)
+      |> :eetcd_kv.with_value(value)
+      |> build_put_opts(opts)
+
+    EtcdEx.Connection.put(conn, request)
+  end
+
+  defp build_put_opts(req, []), do: req
+
+  defp build_put_opts(req, [{:lease, lease} | opts]) do
+    req
+    |> :eetcd_kv.with_lease(lease)
+    |> build_put_opts(opts)
+  end
+
+  defp build_put_opts(req, [{:prev_kv, true} | opts]) do
+    req
+    |> :eetcd_kv.with_prev_kv()
+    |> build_put_opts(opts)
+  end
+
+  defp build_put_opts(req, [{:prev_kv, _} | opts]), do: build_put_opts(req, opts)
+
+  defp build_put_opts(req, [{:ignore_value, true} | opts]) do
+    req
+    |> :eetcd_kv.with_ignore_value()
+    |> build_put_opts(opts)
+  end
+
+  defp build_put_opts(req, [{:ignore_value, _} | opts]), do: build_put_opts(req, opts)
+
+  defp build_put_opts(req, [{:ignore_lease, true} | opts]) do
+    req
+    |> :eetcd_kv.with_ignore_lease()
+    |> build_put_opts(opts)
+  end
+
+  defp build_put_opts(req, [{:ignore_lease, _} | opts]), do: build_put_opts(req, opts)
+
+  defp build_put_opts(req, [{:timeout, timeout} | opts]) do
+    req
+    |> :eetcd_kv.with_timeout(timeout)
+    |> build_get_opts(opts)
+  end
+
+  @doc """
+  Deletes a key-value pair from Etcd.
+  """
+  @spec delete(conn, key, delete_opts) :: {:ok, any} | {:error, any}
+  def delete(conn, key, opts \\ []) do
+    request =
+      conn
+      |> :eetcd_kv.new()
+      |> :eetcd_kv.with_key(key)
+      |> build_delete_opts(opts)
+
+    EtcdEx.Connection.delete(conn, request)
+  end
+
+  defp build_delete_opts(req, []), do: req
+
+  defp build_delete_opts(req, [{:range_end, range_end} | opts]) do
+    req
+    |> :eetcd_kv.with_range_end(range_end)
+    |> build_delete_opts(opts)
+  end
+
+  defp build_delete_opts(req, [{:prefix, true} | opts]) do
+    req
+    |> :eetcd_kv.with_prefix()
+    |> build_delete_opts(opts)
+  end
+
+  defp build_delete_opts(req, [{:prefix, _} | opts]), do: build_delete_opts(req, opts)
+
+  defp build_delete_opts(req, [{:from_key, true} | opts]) do
+    req
+    |> :eetcd_kv.with_from_key()
+    |> build_delete_opts(opts)
+  end
+
+  defp build_delete_opts(req, [{:from_key, _} | opts]), do: build_delete_opts(req, opts)
+
+  defp build_delete_opts(req, [{:prev_kv, true} | opts]) do
+    req
+    |> :eetcd_kv.with_prev_kv()
+    |> build_delete_opts(opts)
+  end
+
+  defp build_delete_opts(req, [{:prev_kv, _} | opts]), do: build_delete_opts(req, opts)
+
+  defp build_delete_opts(req, [{:timeout, timeout} | opts]) do
+    req
+    |> :eetcd_kv.with_timeout(timeout)
+    |> build_get_opts(opts)
+  end
+end