Module Nn_push
module Nn_push:Push updates to the slaves (client)sig..end
typeclient =Rpc_proxy.ManagedClient.mclient
val create_client : Rpc_client.connector ->
Pfs_auth.client_auth -> float -> Unixqueue.event_system -> client
Creates a new client. The
float arg is the message timeoutval begin_transaction_e : client -> string -> string -> unit Uq_engines.engine
Starts the transaction:
begin_transaction_e c clustername exp_rev.
Also transmits the datastore cache (set_ds_cache).val push_e : Nn_db.modification -> client -> unit Uq_engines.engine
Pushes the db modification to the slave which the client connects
to
val prepare_commit_e : client -> bool Uq_engines.engine
Prepares the commit. The resulting bool value is
true if the
commit is possible and allowed.val commit_e : client -> unit Uq_engines.engine
Commits the transaction
val trigger_shutdown : client -> unit
Triggers the shutdown of this client
