use latest rmp-serde crate

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name    = "kentik-api"
-version = "0.0.5"
+version = "0.0.6"
 authors = ["Will <[email protected]>"]
 edition = "2018"
 
@@ -11,7 +11,7 @@ crossbeam-channel = "0.5.11"
 futures           = "0.3.30"
 futures-retry     = "0.6.0"
 log               = "0.4.20"
-rmp-serde         = "0.13.7"
+rmp-serde         = "1.1.2"
 serde_bytes       = "0.11.14"
 
 [dependencies.reqwest]

src/dns/client.rs

@@ -44,7 +44,7 @@ fn poll(rx: Receiver<Vec<Response>>, c: AsyncClient) -> Result<(), Error> {
 
     loop {
         let mut encode = |rs: Vec<Response>| -> Result<(), Error> {
-            let mut s = Serializer::new_named(&mut buf);
+            let mut s = Serializer::new(&mut buf).with_struct_map();
             rs.into_iter().map(|r: Response| -> Result<(), Error> {
                 Ok(r.serialize(&mut s)?)
             }).collect::<Result<_, _>>()

tests/dns.rs

@@ -36,7 +36,7 @@ fn send_dns_batch() {
     let interval = Duration::from_secs(1);
     let request = server.request(interval * 2).unwrap();
     let body = request.body();
-    let mut de = Deserializer::from_slice(&body);
+    let mut de = Deserializer::from_read_ref(&body);
 
     for record in records {
         assert_eq!(record, Response::deserialize(&mut de).unwrap());