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