store: Enable gRPC gzip compression (tikv#490)

Signed-off-by: Ping Yu <[email protected]>
(cherry picked from commit fa78931)

Author: pingyu

Cargo.toml

@@ -45,7 +45,7 @@ serde_json = "1"
 take_mut = "0.2.2"
 thiserror = "1"
 tokio = { version = "1", features = ["sync", "rt-multi-thread", "macros"] }
-tonic = { version = "0.10", features = ["tls"] }
+tonic = { version = "0.10", features = ["tls", "gzip"] }
 
 [dev-dependencies]
 clap = "2"

config/tikv.toml

@@ -19,4 +19,7 @@ max-open-files = 10000
 [storage]
 reserve-space = "0MiB"
 api-version = 2
-enable-ttl = true
+enable-ttl = true
+
+[server]
+grpc-compression-type = "gzip"

src/store/client.rs

@@ -6,6 +6,7 @@ use std::time::Duration;
 
 use async_trait::async_trait;
 use derive_new::new;
+use tonic::codec::CompressionEncoding;
 use tonic::transport::Channel;
 
 use super::Request;
@@ -37,6 +38,7 @@ impl KvConnect for TikvConnect {
             .connect(address, move |channel| {
                 TikvClient::new(channel)
                     .max_decoding_message_size(self.grpc_max_decoding_message_size)
+                    .accept_compressed(CompressionEncoding::Gzip)
             })
             .await
             .map(|c| KvRpcClient::new(c, self.timeout))