Module rdht_tx_write

Part of replicated DHT implementation.

Copyright © 2009-2015 Zuse Institute Berlin onScale solutions GmbH

Version: $Id$

Behaviours: gen_component, tx_op_beh.

Authors: Florian Schintke (schintke@onscale.de).

Description

Part of replicated DHT implementation. The write operation.

Data Types

client_key()

client_key() = [unicode_char()]

client_value()

client_value() = any()

req_id()

req_id() = {rdht_tx:req_id(), pid(), any()}

unicode_char()

unicode_char() = 0..55295 | 57344..65533 | 65536..1114111

Function Index

abort/5
check_config/0Checks whether used config parameters exist and are valid.
commit/5
extract_from_tlog/4Get 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

Function Details

start_gen_component/5

start_gen_component(Module :: module(),
                    Handler :: gen_component:handler(),
                    Args :: term(),
                    Options :: [gen_component:option()],
                    Self :: pid()) ->
                       no_return() | ok

work_phase/3

work_phase(ClientPid :: pid(),
           ReqId :: rdht_tx:req_id(),
           Request :: api_tx:request()) ->
              ok

extract_from_tlog/4

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/1

validate_prefilter(TLogEntry :: tx_tlog:tlog_entry()) ->
                      [tx_tlog:tlog_entry()]

validate/3

validate(DB :: db_dht:db(),
         OwnSnapNumber :: tx_tlog:snap_number(),
         RTLogEntry :: tx_tlog:tlog_entry()) ->
            {db_dht:db(), 72 | 74}

commit/5

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/5

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/1

start_link(DHTNodeGroup :: pid_groups:groupname()) -> {ok, pid()}

init/1

init(X1 :: []) -> null

on/2

on(X1 :: comm:message(), TableName :: pdb:tableid()) ->
      pdb:tableid()

check_config/0

check_config() -> true

Checks whether used config parameters exist and are valid.


Generated by EDoc, Aug 2 2016, 13:42:54.