[elixir! #0030] 在 elixir 项目中使用 RiakKV (1) -- Riak CRDT

数据类型

set: 一个 set 内的数据是不可重复的.
counter: counter 的值只能是整数.
map: 可以包含其它的数据类型.

以下两种数据类型只能包含在 map 或 set 中使用:

register:　值为字符串
flag: 值可以是　true 或　false

设置 Bucket 类型 (名称可以为任意字符串)

riak-admin bucket-type create maps '{"props":{"datatype":"map"}}'
riak-admin bucket-type activate maps
riak-admin bucket-type create sets '{"props":{"datatype":"set"}}'
riak-admin bucket-type activate sets
riak-admin bucket-type create counters '{"props":{"datatype":"counter"}}'
riak-admin bucket-type activate counters

try it

处理 Counter

defmodule RiakCounter do
  alias Riak.CRDT.Counter

  def create_counter(bucket,key,value) do
    Counter.new
    |> Counter.increment(value)
    |> Riak.update("counters",bucket,key)
  end

  def find_counter(bucket,key) do
    Riak.find("counters",key)
    |> Counter.value
  end

  def change_counter(bucket,change) do
    Riak.find("counters",key)
    |> Counter.increment(change)
    |> Riak.update("counters",key)
  end
end

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!