ClusterKV (cluster_kv v0.2.0)

Documentation for ClusterKV.

Link to this section Summary

Functions

batch(name, keyspace, batch)

See ClusterKV.Ring.batch/3.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

cluster_supervisor_name(name)

get(name, keyspace, key, timeout \\ :infinity)

See ClusterKV.Ring.get/4.

get_wildcard_key(key, split_on, join, wildcard)

See ClusterKV.Ring.get_wildcard_key/4.

init(arg)

Callback implementation for Supervisor.init/1.

prefix(name, keyspace, key, split_on, min, timeout \\ :infinity)

See ClusterKV.Ring.prefix/6.

put(name, keyspace, key, value)

See ClusterKV.Ring.put/4.

put_wildcard(name, keyspace, key, value, split_on, join, wildcard)

See ClusterKV.Ring.put_wildcard/7.

ring_name(name)

start_link(list)

stream(name, timeout \\ :infinity)

See ClusterKV.Ring.stream/2.

update(name, keyspace, key, value, fun)

See ClusterKV.Ring.update/5.

update_if(name, keyspace, key, value, fun)

See ClusterKV.Ring.update_if/5.

wildcard(name, keyspace, key, split_on, join, wildcard, timeout \\ :infinity)

See ClusterKV.Ring.wildcard/7.

Link to this section Functions

batch(name, keyspace, batch)

See ClusterKV.Ring.batch/3.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

cluster_supervisor_name(name)

db_name(name)

ets_name(name)

get(name, keyspace, key, timeout \\ :infinity)

See ClusterKV.Ring.get/4.

get_wildcard_key(key, split_on, join, wildcard)

See ClusterKV.Ring.get_wildcard_key/4.

init(arg)

Callback implementation for Supervisor.init/1.

prefix(name, keyspace, key, split_on, min, timeout \\ :infinity)

See ClusterKV.Ring.prefix/6.

put(name, keyspace, key, value)

See ClusterKV.Ring.put/4.

put_wildcard(name, keyspace, key, value, split_on, join, wildcard)

See ClusterKV.Ring.put_wildcard/7.

ring_name(name)

start_link(list)

Specs

start_link(
  name: atom(),
  topologies: list(),
  replicas: integer(),
  quorum: integer()
) ::
  {:ok, pid()}
  | {:error, {:already_started, pid()} | {:shutdown, term()} | term()}

stream(name, timeout \\ :infinity)

See ClusterKV.Ring.stream/2.

update(name, keyspace, key, value, fun)

See ClusterKV.Ring.update/5.

update_if(name, keyspace, key, value, fun)

See ClusterKV.Ring.update_if/5.

wildcard(name, keyspace, key, split_on, join, wildcard, timeout \\ :infinity)

See ClusterKV.Ring.wildcard/7.