barrel_p2p_reminder (barrel_p2p v0.1.0)

View Source

Summary

Functions

Cancel a pending reminder cluster-wide. Stability: beta.

Set a reminder for Key to fire at absolute wall-clock FireAtMs (milliseconds, erlang:system_time(millisecond) scale), delivering Payload on whichever node owns Key at fire time. Re-setting an existing Key replaces it. Stability: beta.

Like remind/3 but DelayMs from now; converted to an absolute target so every node agrees on the fire time. Stability: beta.

Types

fence/0

-type fence() :: non_neg_integer().

key/0

-type key() :: term().

payload/0

-type payload() :: term().

Functions

cancel_reminder(Key)

-spec cancel_reminder(key()) -> ok.

Cancel a pending reminder cluster-wide. Stability: beta.

handle_call(Request, From, State)

handle_cast(Msg, State)

handle_info(Info, State)

init(_)

remind(Key, FireAtMs, Payload)

-spec remind(key(), integer(), payload()) -> ok.

Set a reminder for Key to fire at absolute wall-clock FireAtMs (milliseconds, erlang:system_time(millisecond) scale), delivering Payload on whichever node owns Key at fire time. Re-setting an existing Key replaces it. Stability: beta.

remind_after(Key, DelayMs, Payload)

-spec remind_after(key(), non_neg_integer(), payload()) -> ok.

Like remind/3 but DelayMs from now; converted to an absolute target so every node agrees on the fire time. Stability: beta.

replica_anti_entropy()

replica_apply_full_sync(Name, Snapshot)

replica_full_sync_snapshot(Name)

replica_merge_delta(Name, Delta)

replica_remove_node(Name, Node)

start_link()

subscribe(Pid)

-spec subscribe(pid()) -> ok.

terminate(Reason, State)

unsubscribe(Pid)

-spec unsubscribe(pid()) -> ok.