Copyright © 2009-2015 Zuse Institute Berlin onScale solutions GmbH
Version: $Id$
Behaviours: gen_component, tx_op_beh.
Authors: Florian Schintke (schintke@onscale.de).
client_key() = [unicode_char()]
client_value() = any()
req_id() = {rdht_tx:req_id(), pid(), any()}
unicode_char() = 0..55295 | 57344..65533 | 65536..1114111
abort/5 | |
check_config/0 | Checks whether used config parameters exist and are valid. |
commit/5 | |
extract_from_tlog/4 | Get a result entry for a write from the given TLog entry. |
init/1 | |
on/2 | |
start_gen_component/5 | |
start_link/1 | |
validate/3 | |
validate_prefilter/1 | |
work_phase/3 |
start_gen_component(Module :: module(), Handler :: gen_component:handler(), Args :: term(), Options :: [gen_component:option()], Self :: pid()) -> no_return() | ok
work_phase(ClientPid :: pid(), ReqId :: rdht_tx:req_id(), Request :: api_tx:request()) -> ok
extract_from_tlog(Entry :: tx_tlog:tlog_entry(), Key :: client_key(), Value1 :: client_value(), EnDecode :: true) -> {tx_tlog:tlog_entry(), api_tx:write_result()}
Get a result entry for a write from the given TLog entry. Update the TLog entry accordingly.
validate_prefilter(TLogEntry :: tx_tlog:tlog_entry()) -> [tx_tlog:tlog_entry()]
validate(DB :: db_dht:db(), OwnSnapNumber :: tx_tlog:snap_number(), RTLogEntry :: tx_tlog:tlog_entry()) -> {db_dht:db(), 72 | 74}
commit(DB :: db_dht:db(), RTLogEntry :: tx_tlog:tlog_entry(), OwnProposalWas :: 72 | 74, TMSnapNo :: tx_tlog:snap_number(), OwnSnapNo :: tx_tlog:snap_number()) -> db_dht:db()
abort(DB :: db_dht:db(), RTLogEntry :: tx_tlog:tlog_entry(), OwnProposalWas :: 72 | 74, TMSnapNo :: tx_tlog:snap_number(), OwnSnapNo :: tx_tlog:snap_number()) -> db_dht:db()
start_link(DHTNodeGroup :: pid_groups:groupname()) -> {ok, pid()}
init(X1 :: []) -> null
on(X1 :: comm:message(), TableName :: pdb:tableid()) -> pdb:tableid()
check_config() -> true
Checks whether used config parameters exist and are valid.
Generated by EDoc, Sep 11 2020, 15:25:57.