admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 10:08:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip ci] Fix golint for binlog_writer.go (#9388)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2021-10-07 22:13:09 +08:00 committed by GitHub
parent 057834fa57
commit 74233fcfd8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/storage/binlog_writer.go
View File

@ -23,12 +23,17 @@ import (
type BinlogType int32 type BinlogType int32
const ( const (
// InsertBinlog BinlogType for insert data
InsertBinlog BinlogType = iota InsertBinlog BinlogType = iota
// DeleteBinlog BinlogType for delete data
DeleteBinlog DeleteBinlog
// DDLBinlog BinlogType for DDL
DDLBinlog DDLBinlog
// IndexFileBinlog BinlogType for index
IndexFileBinlog IndexFileBinlog
) )
const ( const (
// MagicNumber used in binlog
MagicNumber int32 = 0xfffabc MagicNumber int32 = 0xfffabc
) )
@ -65,6 +70,7 @@ func (writer *baseBinlogWriter) GetRowNums() (int32, error) {
return int32(length), nil return int32(length), nil
} }
// GetBinlogType returns writer's binlogType
func (writer *baseBinlogWriter) GetBinlogType() BinlogType { func (writer *baseBinlogWriter) GetBinlogType() BinlogType {
return writer.binlogType return writer.binlogType
} }
@ -220,10 +226,12 @@ func (writer *DDLBinlogWriter) NextDropPartitionEventWriter() (*dropPartitionEve
return event, nil return event, nil
} }
// IndexFileBinlogWriter is an object to write binlog file which saves index files
type IndexFileBinlogWriter struct { type IndexFileBinlogWriter struct {
baseBinlogWriter baseBinlogWriter
} }
// NextIndexFileEventWriter return next available EventWriter
func (writer *IndexFileBinlogWriter) NextIndexFileEventWriter() (*indexFileEventWriter, error) { func (writer *IndexFileBinlogWriter) NextIndexFileEventWriter() (*indexFileEventWriter, error) {
if writer.isClosed() { if writer.isClosed() {
return nil, fmt.Errorf("binlog has closed") return nil, fmt.Errorf("binlog has closed")
@ -289,6 +297,7 @@ func NewDDLBinlogWriter(dataType schemapb.DataType, collectionID int64) *DDLBinl
} }
} }
// NewIndexFileBinlogWriter returns a new IndexFileBinlogWriter with provided parameters
func NewIndexFileBinlogWriter( func NewIndexFileBinlogWriter(
indexBuildID UniqueID, indexBuildID UniqueID,
version int64, version int64,