Dust.SyncEngine (dustlayer v0.1.1)

Remove a subscription previously registered with on/4. Returns :ok whether or not a subscription with that ref existed (idempotent). After this call returns, the subscription's callback will not fire again.

on(store, pattern, callback, opts \\ [])

put(store, path, value)

put(store, path, value, opts)

put_file(store, path, source_path, opts \\ [])

range(store, from, to, opts \\ [])

remove(store, path, member)

remove(store, path, member, opts)

seed_entry(store, path, value, type)

Write directly to cache without the write pipeline. For test seeding only.

set_catch_up_complete(store, through_seq)

set_status(store, new_status)

set_store_seq(store, seq)

Update last_store_seq in state. For test harness only.

start_link(opts)

status(store)

via(store)

Functions

add(store, path, member)

add(store, path, member, opts)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

delete(store, path)

delete(store, path, opts)

entry(store, path)

enum(store, pattern)

enum(store, pattern, opts)

get(store, path)

get_many(store, paths)

handle_server_event(store, event)

handle_snapshot(store, snapshot)

handle_write_accepted(store, client_op_id, store_seq)

handle_write_rejected(store, client_op_id, reason)

increment(store, path, delta \\ 1)

increment(store, path, delta, opts)

merge(store, path, map)

merge(store, path, map, opts)

off(store, ref)