chore: typo (#2092)

This commit is contained in:
JeremyHi
2023-08-04 09:38:17 +08:00
committed by GitHub
parent 1492700acc
commit 7987e08ca2
3 changed files with 6 additions and 6 deletions

View File

@@ -83,7 +83,7 @@ pub struct Instance {
pub(crate) catalog_manager: CatalogManagerRef,
pub(crate) table_id_provider: Option<TableIdProviderRef>,
procedure_manager: ProcedureManagerRef,
greptimedb_telemerty_task: Arc<GreptimeDBTelemetryTask>,
greptimedb_telemetry_task: Arc<GreptimeDBTelemetryTask>,
}
pub type InstanceRef = Arc<Instance>;
@@ -305,7 +305,7 @@ impl Instance {
catalog_manager: catalog_manager.clone(),
table_id_provider,
procedure_manager,
greptimedb_telemerty_task: get_greptimedb_telemetry_task(&opts.mode).await,
greptimedb_telemetry_task: get_greptimedb_telemetry_task(&opts.mode).await,
});
let heartbeat_task = Instance::build_heartbeat_task(
@@ -335,7 +335,7 @@ impl Instance {
.start()
.context(StartProcedureManagerSnafu)?;
let _ = self
.greptimedb_telemerty_task
.greptimedb_telemetry_task
.start(common_runtime::bg_runtime())
.map_err(|e| {
debug!("Failed to start greptimedb telemetry task: {}", e);

View File

@@ -177,7 +177,7 @@ pub struct MetaSrv {
mailbox: MailboxRef,
ddl_manager: DdlManagerRef,
table_metadata_manager: TableMetadataManagerRef,
greptimedb_telemerty_task: Arc<GreptimeDBTelemetryTask>,
greptimedb_telemetry_task: Arc<GreptimeDBTelemetryTask>,
pubsub: Option<(PublishRef, SubscribeManagerRef)>,
}
@@ -200,7 +200,7 @@ impl MetaSrv {
let leader_cached_kv_store = self.leader_cached_kv_store.clone();
let subscribe_manager = self.subscribe_manager().cloned();
let mut rx = election.subscribe_leader_change();
let task_handler = self.greptimedb_telemerty_task.clone();
let task_handler = self.greptimedb_telemetry_task.clone();
let _handle = common_runtime::spawn_bg(async move {
loop {
match rx.recv().await {

View File

@@ -251,7 +251,7 @@ impl MetaSrvBuilder {
mailbox,
ddl_manager,
table_metadata_manager,
greptimedb_telemerty_task: get_greptimedb_telemetry_task(meta_peer_client).await,
greptimedb_telemetry_task: get_greptimedb_telemetry_task(meta_peer_client).await,
pubsub,
})
}