milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip e2e] Refine msgstream comment (#13884) 

Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
pull/13898/head
edward.zeng 2021-12-21 19:09:04 +08:00 committed by GitHub
parent 8ede9c70b2
commit 1cccc8b17d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
internal/msgstream/msg.go
View File

@ -190,7 +190,7 @@ func (dt *DeleteMsg) Type() MsgType {
return dt.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (dt *DeleteMsg) SourceID() int64 {
return dt.Base.SourceID
}
@ -257,7 +257,7 @@ func (st *SearchMsg) Type() MsgType {
return st.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (st *SearchMsg) SourceID() int64 {
return st.Base.SourceID
}
@ -329,7 +329,7 @@ func (srt *SearchResultMsg) Type() MsgType {
return srt.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (srt *SearchResultMsg) SourceID() int64 {
return srt.Base.SourceID
}
@ -384,7 +384,7 @@ func (rm *RetrieveMsg) Type() MsgType {
return rm.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (rm *RetrieveMsg) SourceID() int64 {
return rm.Base.SourceID
}
@ -456,7 +456,7 @@ func (rrm *RetrieveResultMsg) Type() MsgType {
return rrm.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (rrm *RetrieveResultMsg) SourceID() int64 {
return rrm.Base.SourceID
}
@ -511,7 +511,7 @@ func (tst *TimeTickMsg) Type() MsgType {
return tst.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (tst *TimeTickMsg) SourceID() int64 {
return tst.Base.SourceID
}
@ -577,7 +577,7 @@ func (qs *QueryNodeStatsMsg) Type() MsgType {
return qs.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (qs *QueryNodeStatsMsg) SourceID() int64 {
return qs.Base.SourceID
}
@ -630,7 +630,7 @@ func (cc *CreateCollectionMsg) Type() MsgType {
return cc.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (cc *CreateCollectionMsg) SourceID() int64 {
return cc.Base.SourceID
}
@ -685,7 +685,7 @@ func (dc *DropCollectionMsg) Type() MsgType {
return dc.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (dc *DropCollectionMsg) SourceID() int64 {
return dc.Base.SourceID
}
@ -740,7 +740,7 @@ func (cp *CreatePartitionMsg) Type() MsgType {
return cp.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (cp *CreatePartitionMsg) SourceID() int64 {
return cp.Base.SourceID
}
@ -795,7 +795,7 @@ func (dp *DropPartitionMsg) Type() MsgType {
return dp.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (dp *DropPartitionMsg) SourceID() int64 {
return dp.Base.SourceID
}
@ -911,7 +911,7 @@ func (s *SealedSegmentsChangeInfoMsg) Type() MsgType {
return s.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (s *SealedSegmentsChangeInfoMsg) SourceID() int64 {
return s.Base.SourceID
}
@ -966,7 +966,7 @@ func (m *DataNodeTtMsg) Type() MsgType {
return m.Base.MsgType
}
// SourceID indicated which component generated this message
// SourceID indicates which component generated this message
func (m *DataNodeTtMsg) SourceID() int64 {
return m.Base.SourceID
}