diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index f04b179910..fb6c4ff3bb 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -384,6 +384,7 @@ func (colReplica *collectionReplica) getSegmentIDsPrivate(partitionID UniqueID) } //----------------------------------------------------------------------------------------------------- segment +// addSegment add a new segment to collectionReplica func (colReplica *collectionReplica) addSegment(segmentID UniqueID, partitionID UniqueID, collectionID UniqueID, vChannelID Channel, segType segmentType, onService bool) error { colReplica.mu.Lock() defer colReplica.mu.Unlock()