Upgrade postgres and bytes dependencies.

Signed-off-by: Matthias Wahl <mwahl@wayfair.com>

Cargo.toml

@@ -39,8 +39,7 @@ async-tungstenite = {version = "0.12.0", features = ["async-std-runtime"]}
 base64 = "0.13"
 beef = {version = "0.4", features = ["impl_serde"]}
 byteorder = "1"
-bytes5 = {version = "0.5", package = "bytes"}
-bytes6 = {version = "0.6", package = "bytes"}
+bytes = "1.0"
 chrono = "0.4"
 elastic = "0.21.0-pre.5"
 error-chain = "0.12"
@@ -85,9 +84,9 @@ hdrhistogram = "7"
 xz2 = "0.1"
 
 # postgres
-postgres = {version = "0.18.1", features = ["with-serde_json-1", "with-chrono-0_4"]}
-postgres-protocol = "0.5"
-tokio-postgres = "0.6"
+postgres = {version = "0.19", features = ["with-serde_json-1", "with-chrono-0_4"]}
+postgres-protocol = "0.6"
+tokio-postgres = "0.7"
 
 # kafka. cmake is the encouraged way to build this and also the one that works on windows/with musl.
 rdkafka = {version = "0.24", features = ["cmake-build", "libz"], default-features = false}

src/preprocessor.rs

@@ -19,8 +19,8 @@ pub(crate) mod lines;
 use crate::errors::{Error, Result};
 use crate::url::TremorURL;
 use byteorder::{BigEndian, ByteOrder, ReadBytesExt};
-use bytes6::buf::Buf;
-use bytes6::BytesMut;
+use bytes::buf::Buf;
+use bytes::BytesMut;
 
 use std::io::{self, Read};
 

src/ramp/postgres.rs

@@ -23,7 +23,8 @@
 //! See [Config](struct.Config.html) for details.
 
 use crate::errors::{Error, Result};
-use bytes5::buf::{BufMut, BufMutExt};
+use bytes::buf::BufMut;
+use bytes::BytesMut;
 use chrono::prelude::*;
 use postgres::types::to_sql_checked;
 use std::time::SystemTime;
@@ -40,7 +41,7 @@ impl postgres::types::ToSql for Record<'_> {
     fn to_sql(
         &self,
         type_: &postgres::types::Type,
-        w: &mut postgres::types::private::BytesMut,
+        w: &mut BytesMut,
     ) -> std::result::Result<postgres::types::IsNull, Box<dyn std::error::Error + Sync + Send>>
     {
         if self.value.is_null() {