Skip to content

Commit

Permalink
chore: rename unregister to deregister
Browse files Browse the repository at this point in the history
  • Loading branch information
WenyXu committed Dec 29, 2023
1 parent 9e4034a commit e95e2b7
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/meta-srv/src/handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -229,7 +229,7 @@ impl HeartbeatHandlerGroup {
let _ = self.pushers.insert(key.to_string(), pusher).await;
}

pub async fn unregister(&self, key: impl AsRef<str>) -> Option<Pusher> {
pub async fn deregister(&self, key: impl AsRef<str>) -> Option<Pusher> {
let key = key.as_ref();
METRIC_META_HEARTBEAT_CONNECTION_NUM.dec();
info!("Pusher unregister: {}", key);
Expand Down
2 changes: 1 addition & 1 deletion src/meta-srv/src/service/heartbeat.rs
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ impl heartbeat_server::Heartbeat for MetaSrv {
);

if let Some(key) = pusher_key {
let _ = handler_group.unregister(&key).await;
let _ = handler_group.deregister(&key).await;
}
if let Some((cluster_id, peer_id)) = datanode_peer_ident {
datanode_peer_registry.deregister(cluster_id, peer_id);
Expand Down

0 comments on commit e95e2b7

Please sign in to comment.