| Overview |  |
Behaviours: partisan_plumtree_broadcast_handler.
broadcast_id() = timestamp()
broadcast_message() = #broadcast{}
broadcast_payload() = timestamp()
timestamp() = non_neg_integer()
| broadcast_data/1 | Returns from the broadcast message the identifier and the payload. |
| exchange/1 | Anti-entropy mechanism. |
| extract_log_type_and_payload/1 | |
| graft/1 | Given a message identifier and a clock, return a given message. |
| is_stale/1 | Use the clock on the object to determine if this message is stale or not. |
| merge/2 | Perform a merge of an incoming object with an object in the local datastore. |
| start_link/0 | Same as start_link([]). |
| start_link/1 | Start and link to calling process. |
broadcast_data(Broadcast::broadcast_message()) -> {broadcast_id(), broadcast_payload()}
Returns from the broadcast message the identifier and the payload.
exchange(Peer::node()) -> {ok, pid()}
Anti-entropy mechanism.
extract_log_type_and_payload(Message) -> any()
graft(Timestamp::broadcast_id()) -> stale | {ok, broadcast_payload()} | {error, term()}
Given a message identifier and a clock, return a given message.
is_stale(Timestamp::broadcast_id()) -> boolean()
Use the clock on the object to determine if this message is stale or not.
merge(Timestamp::broadcast_id(), X2::broadcast_payload()) -> boolean()
Perform a merge of an incoming object with an object in the local datastore.
start_link() -> {ok, pid()} | ignore | {error, term()}
Same as start_link([]).
start_link(Opts::list()) -> {ok, pid()} | ignore | {error, term()}
Start and link to calling process.
Generated by EDoc