Integration_test_cloud_engine.Log_engine
type t
val create : logger:Logger.t -> network:Network.t -> t Async_kernel.Deferred.Or_error.t
val destroy : t -> unit Async_kernel.Deferred.Or_error.t
val event_reader : t -> (Network.Node.t * Integration_test_lib.Event_type.event) Async_kernel.Pipe.Reader.t