From 5c14f96dc45cfb50beef93134073cc094ce506b1 Mon Sep 17 00:00:00 2001 From: godchen Date: Thu, 7 Oct 2021 10:32:13 +0800 Subject: [PATCH] [skip ci]Fix cluster go comment typo (#9377) Signed-off-by: godchen0212 --- internal/datacoord/cluster.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/datacoord/cluster.go b/internal/datacoord/cluster.go index 0d91bd92b8..7d40afd9d0 100644 --- a/internal/datacoord/cluster.go +++ b/internal/datacoord/cluster.go @@ -46,7 +46,7 @@ type EventType int const ( // Register EventType const for data node registration Register EventType = 1 - // UnRegister EventType const for data node unregistration + // UnRegister EventType const for data node unRegistration UnRegister EventType = 2 // WatchChannel EventType const for a channel needs to be watched WatchChannel EventType = 3 @@ -248,7 +248,7 @@ func (c *Cluster) handleNodeEvent() { case FlushSegments: c.handleFlush(e.Data.([]*datapb.SegmentInfo)) default: - log.Warn("Unknow node event type") + log.Warn("Unknown node event type") } } } @@ -359,7 +359,7 @@ func createClient(ctx context.Context, addr string) (types.DataNode, error) { return cli, nil } -// Startup applies statup policy +// Startup applies startup policy func (c *Cluster) Startup(nodes []*NodeInfo) { c.wg.Add(1) go c.handleNodeEvent() @@ -402,7 +402,7 @@ func (c *Cluster) updateCluster(nodes []*NodeInfo) (newNodes []*NodeInfo, offlin return } -// handleRegister handls register logic +// handleRegister handle register logic // applies register policy and save result into kv store func (c *Cluster) handleRegister(n *NodeInfo) { c.mu.Lock() @@ -469,7 +469,7 @@ func (c *Cluster) handleUnRegister(n *NodeInfo) { } } -// handleWatchChannel handls watch channel logic +// handleWatchChannel handle watch channel logic // applies assignPolicy and saves results into kv store func (c *Cluster) handleWatchChannel(channel string, collectionID UniqueID) { c.mu.Lock() @@ -613,7 +613,7 @@ func (c *Cluster) txnSaveNodesAndBuffer(nodes []*NodeInfo, buffer []*datapb.Chan data[key] = string(value) } - // short cut, reusing datainfo to store array of channel status + // short cut, reusing dataInfo to store array of channel status bufNode := &datapb.DataNodeInfo{ Channels: buffer, }