mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-06 05:12:54 +00:00
fix: remove useless metaclient field from datanode Instance (#744)
This commit is contained in:
@@ -60,8 +60,6 @@ pub struct Instance {
|
||||
pub(crate) catalog_manager: CatalogManagerRef,
|
||||
pub(crate) script_executor: ScriptExecutor,
|
||||
pub(crate) table_id_provider: Option<TableIdProviderRef>,
|
||||
#[allow(unused)]
|
||||
pub(crate) meta_client: Option<Arc<MetaClient>>,
|
||||
pub(crate) heartbeat_task: Option<HeartbeatTask>,
|
||||
}
|
||||
|
||||
@@ -158,7 +156,6 @@ impl Instance {
|
||||
),
|
||||
catalog_manager,
|
||||
script_executor,
|
||||
meta_client,
|
||||
heartbeat_task,
|
||||
table_id_provider,
|
||||
})
|
||||
|
||||
@@ -40,7 +40,7 @@ impl Instance {
|
||||
use mito::table::test_util::{new_test_object_store, MockEngine, MockMitoEngine};
|
||||
|
||||
let mock_info = meta_srv::mocks::mock_with_memstore().await;
|
||||
let meta_client = Some(Arc::new(mock_meta_client(mock_info, 0).await));
|
||||
let meta_client = Arc::new(mock_meta_client(mock_info, 0).await);
|
||||
let (_dir, object_store) = new_test_object_store("setup_mock_engine_and_table").await;
|
||||
let mock_engine = Arc::new(MockMitoEngine::new(
|
||||
TableEngineConfig::default(),
|
||||
@@ -69,7 +69,7 @@ impl Instance {
|
||||
let heartbeat_task = Some(HeartbeatTask::new(
|
||||
0,
|
||||
"127.0.0.1:3302".to_string(),
|
||||
meta_client.as_ref().unwrap().clone(),
|
||||
meta_client,
|
||||
));
|
||||
|
||||
let table_id_provider = Some(catalog_manager.clone() as TableIdProviderRef);
|
||||
@@ -78,7 +78,6 @@ impl Instance {
|
||||
sql_handler,
|
||||
catalog_manager,
|
||||
script_executor,
|
||||
meta_client,
|
||||
heartbeat_task,
|
||||
table_id_provider,
|
||||
})
|
||||
@@ -132,7 +131,6 @@ impl Instance {
|
||||
catalog_manager,
|
||||
script_executor,
|
||||
table_id_provider: Some(Arc::new(LocalTableIdProvider::default())),
|
||||
meta_client: Some(meta_client),
|
||||
heartbeat_task: Some(heartbeat_task),
|
||||
})
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user