Add Close method for ChannelManager in datacoord (#23493)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>

internal/datacoord/channel_manager.go

@@ -184,6 +184,13 @@ func (c *ChannelManager) Startup(ctx context.Context, nodes []int64) error {
 	return nil
 }
 
+// Close notifies the running checker.
+func (c *ChannelManager) Close() {
+	if c.stopChecker != nil {
+		c.stopChecker()
+	}
+}
+
 // checkOldNodes processes the existing watch channels when starting up.
 // ToWatch         get startTs and timeoutTs, start timer
 // WatchSuccess    ignore

internal/datacoord/cluster.go

@@ -139,4 +139,5 @@ func (c *Cluster) GetSessions() []*Session {
 // Close releases resources opened in Cluster
 func (c *Cluster) Close() {
 	c.sessionManager.Close()
+	c.channelManager.Close()
 }