Thanks, I tried that branch, I’ve successfully connected to Riak TS cluster, but I could not do any query, can you please point me to simple example? I just need to put and get data.
Here is my implementation:
def store_to_riak do
{:ok, pid} = Riak.Connection.start_link('192.168.99.100', 8098)
IO.inspect pid
o = Riak.Object.create(bucket: "user", key: "my_key", data: "Han Solo")
IO.inspect o
Riak.put(pid, o)
end
Here is the error I got:
iex(31)> iex(2)> App.LocationController.store_to_riak
iex(31)> #PID<0.390.0>
iex(31)> %Riak.Object{bucket: "user", content_type: 'application/json', data: "Han Solo",
key: "my_key",
metadata: {:dict, 1, 16, 16, 8, 80, 48,
{[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []},
{{[], [], [], [], [], [], [], [], [], [],
[["content-type", 97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 47,
106, 115, 111, 110]], [], [], [], [], []}}}, type: :undefined,
vclock: :undefined}
iex(31)> ** (EXIT from #PID<0.354.0>) :disconnected
iex(31)>
iex(31)> Interactive Elixir (1.2.5) - press Ctrl+C to exit (type h() ENTER for help)
iex(31)> [error] GenServer #PID<0.390.0> terminating
** (stop) :disconnected
Last message: {:tcp_closed, #Port<0.13088>}
State: {:state, '192.168.99.100', 8098, false, false, :undefined, false, :gen_tcp, :undefined, {[], []}, 1, [], :infinity, :undefined, :undefined, :undefined, :undefined, [], 100}
