val status : (Core.Unit.t, Spool.Status.t) Async.Rpc.Rpc.t
val freeze : (Spool.Message_id.t list, Core.Unit.t Core.Or_error.t) Async.Rpc.Rpc.t
val send : (Core.Time.Span.t list * Spool.Send_info.t, Core.Unit.t Core.Or_error.t) Async.Rpc.Rpc.t
val remove : (Spool.Message_id.t list, Core.Unit.t Core.Or_error.t) Async.Rpc.Rpc.t
val recover : (Spool.Recover_info.t, Core.Unit.t Core.Or_error.t) Async.Rpc.Rpc.t
val send_now : (Spool.Message_id.t list * Core.Time.Span.t list, Core.Unit.t Core.Or_error.t) Async.Rpc.Rpc.t
val events : (Core.Unit.t, Spool.Event.t, Core.Error.t) Async.Rpc.Pipe_rpc.t
val set_max_concurrent_send_jobs : (Core.Int.t, Core.Unit.t) Async.Rpc.Rpc.t