[indexer grpc] compression support. (aptos-labs#11470)

* compression support.
YFDY · Jan 8, 2024 · a808904 · a808904
1 parent 3e5aa2e
commit a808904
Show file tree

Hide file tree

Showing 23 changed files with 1,548 additions and 916 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/ecosystem/indexer-grpc/indexer-grpc-cache-worker/src/lib.rs b/ecosystem/indexer-grpc/indexer-grpc-cache-worker/src/lib.rs
@@ -17,18 +17,26 @@ pub struct IndexerGrpcCacheWorkerConfig {
     pub fullnode_grpc_address: Url,
     pub file_store_config: IndexerGrpcFileStoreConfig,
     pub redis_main_instance_address: RedisUrl,
+    #[serde(default = "default_enable_cache_compression")]
+    pub enable_cache_compression: bool,
+}
+
+const fn default_enable_cache_compression() -> bool {
+    false
 }
 
 impl IndexerGrpcCacheWorkerConfig {
     pub fn new(
         fullnode_grpc_address: Url,
         file_store_config: IndexerGrpcFileStoreConfig,
         redis_main_instance_address: RedisUrl,
+        enable_cache_compression: bool,
     ) -> Self {
         Self {
             fullnode_grpc_address,
             file_store_config,
             redis_main_instance_address,
+            enable_cache_compression,
         }
     }
 }
@@ -40,6 +48,7 @@ impl RunnableConfig for IndexerGrpcCacheWorkerConfig {
             self.fullnode_grpc_address.clone(),
             self.redis_main_instance_address.clone(),
             self.file_store_config.clone(),
+            self.enable_cache_compression,
         )
         .await
         .context("Failed to create cache worker")?;