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