feat: auto forward query for grpc (#511)

* add basic forwarder

* support tenent settings when forward

* avoid build forwarder when disabled

* set the local addr as config.cluster.node.addr

* make clippy happy

* add the new unit tests

* address CR issues

* fix unit test for loopback ip checking

* add some debug logs

* update the comment

server/src/config.rs

@@ -13,6 +13,7 @@ use serde_derive::Deserialize;
 use table_engine::ANALYTIC_ENGINE_TYPE;
 
 use crate::{
+    grpc::forward,
     http::DEFAULT_MAX_BODY_SIZE,
     limiter::LimiterConfig,
     route::rule_based::{ClusterView, RuleList},
@@ -51,7 +52,7 @@ pub struct StaticRouteConfig {
     pub topology: StaticTopologyConfig,
 }
 
-#[derive(Debug, Clone, Deserialize, PartialEq, Eq)]
+#[derive(Debug, Clone, Deserialize, Eq, Hash, PartialEq)]
 pub struct Endpoint {
     pub addr: String,
     pub port: u16,
@@ -101,6 +102,15 @@ impl From<Endpoint> for storage::Endpoint {
     }
 }
 
+impl From<storage::Endpoint> for Endpoint {
+    fn from(endpoint: storage::Endpoint) -> Self {
+        Endpoint {
+            addr: endpoint.ip,
+            port: endpoint.port as u16,
+        }
+    }
+}
+
 #[derive(Debug, Clone, Deserialize)]
 pub struct ShardView {
     pub shard_id: ShardId,
@@ -181,34 +191,37 @@ pub struct Config {
     pub grpc_port: u16,
     pub grpc_server_cq_count: usize,
 
-    // Engine related configs:
+    /// Engine related configs:
     pub runtime: RuntimeConfig,
 
-    // Log related configs:
+    /// Log related configs:
     pub log_level: String,
     pub enable_async_log: bool,
     pub async_log_channel_len: i32,
 
-    // Tracing related configs:
+    /// Tracing related configs:
     pub tracing_log_dir: String,
     pub tracing_log_name: String,
     pub tracing_level: String,
 
-    // Config of static router.
+    /// Config of static router.
     pub static_route: StaticRouteConfig,
 
-    // Analytic engine configs.
+    /// Analytic engine configs.
     pub analytic: analytic_engine::Config,
 
-    // Query engine config.
+    /// Query engine config.
     pub query: query_engine::Config,
 
-    // Deployment configs:
+    /// Deployment configs:
     pub deploy_mode: DeployMode,
     pub cluster: ClusterConfig,
 
-    // Config of limiter
+    /// Config of limiter
     pub limiter: LimiterConfig,
+
+    /// Config for forwarding
+    pub forward: forward::Config,
 }
 
 impl Default for RuntimeConfig {
@@ -245,6 +258,7 @@ impl Default for Config {
             deploy_mode: DeployMode::Standalone,
             cluster: ClusterConfig::default(),
             limiter: LimiterConfig::default(),
+            forward: forward::Config::default(),
         }
     }
 }