diff --git a/src/datanode/src/datanode.rs b/src/datanode/src/datanode.rs index c19fb30a54b2..2a5d20194d95 100644 --- a/src/datanode/src/datanode.rs +++ b/src/datanode/src/datanode.rs @@ -67,7 +67,7 @@ pub struct Datanode { opts: DatanodeOptions, services: Option, heartbeat_task: Option, - event_receiver: Option, + region_event_receiver: Option, region_server: RegionServer, greptimedb_telemetry_task: Arc, } diff --git a/src/datanode/src/event_listener.rs b/src/datanode/src/event_listener.rs index 78bc9b41bea4..c21e28d1c6e9 100644 --- a/src/datanode/src/event_listener.rs +++ b/src/datanode/src/event_listener.rs @@ -23,10 +23,10 @@ pub enum RegionServerEvent { pub trait RegionServerEventListener: Sync + Send { /// Called *after* a new region was created/opened. - fn register_region(&self, _region_id: RegionId) {} + fn on_register_region(&self, _region_id: RegionId) {} /// Called *after* a region was closed. - fn deregister_region(&self, _region_id: RegionId) {} + fn on_deregister_region(&self, _region_id: RegionId) {} } pub type RegionServerEventListenerRef = Box;