sig
type client = Rpc_proxy.ManagedClient.mclient
type commit_id = int
val create_client :
Rpc_client.connector ->
Pfs_auth.client_auth -> float -> Unixqueue.event_system -> Nn_push.client
val begin_transaction_e :
Nn_push.client ->
Nn_push.commit_id -> string -> string -> unit Uq_engines.engine
val push_e :
Nn_db.modification ->
Nn_push.client -> Nn_push.commit_id -> unit Uq_engines.engine
val prepare_commit_e :
Nn_push.client -> Nn_push.commit_id -> bool Uq_engines.engine
val commit_e :
Nn_push.client -> Nn_push.commit_id -> unit Uq_engines.engine
val trigger_shutdown : Nn_push.client -> unit
val wait_until_ready_e :
Rpc_client.connector -> Unixqueue.event_system -> unit Uq_engines.engine
end
