From 21827ced6486d069829f27d9b532bbb9ba2d9277 Mon Sep 17 00:00:00 2001 From: Ryan Leung Date: Mon, 1 Nov 2021 14:56:37 +0800 Subject: [PATCH] address the comment Signed-off-by: Ryan Leung --- tidb-binlog/proto/generate-binlog.sh | 2 +- .../{bl.pb.go => secondary_binlog.pb.go} | 503 +++++++++--------- .../{bl.proto => secondary_binlog.proto} | 0 3 files changed, 253 insertions(+), 252 deletions(-) rename tidb-binlog/proto/go-binlog/{bl.pb.go => secondary_binlog.pb.go} (80%) rename tidb-binlog/proto/proto/{bl.proto => secondary_binlog.proto} (100%) diff --git a/tidb-binlog/proto/generate-binlog.sh b/tidb-binlog/proto/generate-binlog.sh index f093422c9..4a489cd4c 100755 --- a/tidb-binlog/proto/generate-binlog.sh +++ b/tidb-binlog/proto/generate-binlog.sh @@ -3,7 +3,7 @@ cd proto/ echo "generate binlog code..." GOGO_ROOT=${GOPATH}/src/github.com/gogo/protobuf -protoc -I.:${GOGO_ROOT}:${GOGO_ROOT}/protobuf --gofast_out=../go-binlog bl.proto +protoc -I.:${GOGO_ROOT}:${GOGO_ROOT}/protobuf --gofast_out=../go-binlog secondary_binlog.proto cd ../go-binlog sed -i.bak -E 's/_ \"github.com\/gogo\/protobuf\/gogoproto\"//g' *.pb.go sed -i.bak -E 's/import fmt \"fmt\"//g' *.pb.go diff --git a/tidb-binlog/proto/go-binlog/bl.pb.go b/tidb-binlog/proto/go-binlog/secondary_binlog.pb.go similarity index 80% rename from tidb-binlog/proto/go-binlog/bl.pb.go rename to tidb-binlog/proto/go-binlog/secondary_binlog.pb.go index bf80c1b84..03b81cd6c 100644 --- a/tidb-binlog/proto/go-binlog/bl.pb.go +++ b/tidb-binlog/proto/go-binlog/secondary_binlog.pb.go @@ -1,22 +1,22 @@ // Code generated by protoc-gen-gogo. DO NOT EDIT. -// source: bl.proto +// source: secondary_binlog.proto /* Package slave_binlog is a generated protocol buffer package. It is generated from these files: - bl.proto + secondary_binlog.proto It has these top-level messages: - Column - ColumnInfo - Row - Table - Key - TableMutation - DMLData - DDLData - Binlog + Column + ColumnInfo + Row + Table + Key + TableMutation + DMLData + DDLData + Binlog */ package slave_binlog @@ -81,7 +81,7 @@ func (x *MutationType) UnmarshalJSON(data []byte) error { } func (MutationType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{0} + return fileDescriptor_3e5ebd7aa3410f61, []int{0} } type BinlogType int32 @@ -121,7 +121,7 @@ func (x *BinlogType) UnmarshalJSON(data []byte) error { } func (BinlogType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{1} + return fileDescriptor_3e5ebd7aa3410f61, []int{1} } // for text and char type, string_value is set @@ -144,7 +144,7 @@ func (m *Column) Reset() { *m = Column{} } func (m *Column) String() string { return proto.CompactTextString(m) } func (*Column) ProtoMessage() {} func (*Column) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{0} + return fileDescriptor_3e5ebd7aa3410f61, []int{0} } func (m *Column) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -239,7 +239,7 @@ func (m *ColumnInfo) Reset() { *m = ColumnInfo{} } func (m *ColumnInfo) String() string { return proto.CompactTextString(m) } func (*ColumnInfo) ProtoMessage() {} func (*ColumnInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{1} + return fileDescriptor_3e5ebd7aa3410f61, []int{1} } func (m *ColumnInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -314,7 +314,7 @@ func (m *Row) Reset() { *m = Row{} } func (m *Row) String() string { return proto.CompactTextString(m) } func (*Row) ProtoMessage() {} func (*Row) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{2} + return fileDescriptor_3e5ebd7aa3410f61, []int{2} } func (m *Row) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -367,7 +367,7 @@ func (m *Table) Reset() { *m = Table{} } func (m *Table) String() string { return proto.CompactTextString(m) } func (*Table) ProtoMessage() {} func (*Table) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{3} + return fileDescriptor_3e5ebd7aa3410f61, []int{3} } func (m *Table) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -445,7 +445,7 @@ func (m *Key) Reset() { *m = Key{} } func (m *Key) String() string { return proto.CompactTextString(m) } func (*Key) ProtoMessage() {} func (*Key) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{4} + return fileDescriptor_3e5ebd7aa3410f61, []int{4} } func (m *Key) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -502,7 +502,7 @@ func (m *TableMutation) Reset() { *m = TableMutation{} } func (m *TableMutation) String() string { return proto.CompactTextString(m) } func (*TableMutation) ProtoMessage() {} func (*TableMutation) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{5} + return fileDescriptor_3e5ebd7aa3410f61, []int{5} } func (m *TableMutation) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -564,7 +564,7 @@ func (m *DMLData) Reset() { *m = DMLData{} } func (m *DMLData) String() string { return proto.CompactTextString(m) } func (*DMLData) ProtoMessage() {} func (*DMLData) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{6} + return fileDescriptor_3e5ebd7aa3410f61, []int{6} } func (m *DMLData) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -616,7 +616,7 @@ func (m *DDLData) Reset() { *m = DDLData{} } func (m *DDLData) String() string { return proto.CompactTextString(m) } func (*DDLData) ProtoMessage() {} func (*DDLData) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{7} + return fileDescriptor_3e5ebd7aa3410f61, []int{7} } func (m *DDLData) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -684,7 +684,7 @@ func (m *Binlog) Reset() { *m = Binlog{} } func (m *Binlog) String() string { return proto.CompactTextString(m) } func (*Binlog) ProtoMessage() {} func (*Binlog) Descriptor() ([]byte, []int) { - return fileDescriptor_d439c18ff2786a99, []int{8} + return fileDescriptor_3e5ebd7aa3410f61, []int{8} } func (m *Binlog) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -762,57 +762,58 @@ func init() { proto.RegisterType((*Binlog)(nil), "slave.binlog.Binlog") } -func init() { proto.RegisterFile("bl.proto", fileDescriptor_d439c18ff2786a99) } - -var fileDescriptor_d439c18ff2786a99 = []byte{ - // 750 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x94, 0x4d, 0x6e, 0xeb, 0x36, - 0x14, 0x85, 0x4d, 0xcb, 0x7f, 0xba, 0x72, 0x03, 0x97, 0x4d, 0x01, 0x21, 0x41, 0x1d, 0x45, 0x99, - 0x08, 0x29, 0xe0, 0x06, 0x46, 0x1b, 0x20, 0x45, 0x47, 0xa9, 0x26, 0x41, 0x7e, 0xd0, 0x12, 0x69, - 0x07, 0x9d, 0x08, 0xb2, 0x45, 0x3b, 0x42, 0x29, 0xd1, 0x31, 0xa9, 0x18, 0xea, 0x42, 0x8a, 0x6e, - 0xa3, 0xbb, 0xc8, 0xb0, 0x40, 0xe7, 0x45, 0x90, 0xae, 0xe0, 0xed, 0xe0, 0x81, 0xa4, 0x14, 0xdb, - 0xef, 0x79, 0xf6, 0x66, 0xf4, 0xb9, 0xdf, 0x25, 0x79, 0x0e, 0xaf, 0x05, 0xbd, 0x09, 0x1b, 0x2d, - 0x96, 0x5c, 0x72, 0xdc, 0x17, 0x2c, 0x7e, 0xa2, 0xa3, 0x49, 0x9a, 0x33, 0x3e, 0x3f, 0xd8, 0x9f, - 0xf3, 0x39, 0xd7, 0x85, 0x6f, 0xd4, 0xca, 0x30, 0xfe, 0xbf, 0x08, 0x3a, 0x3f, 0x72, 0x56, 0x64, - 0x39, 0x1e, 0x42, 0x37, 0x15, 0x51, 0x5e, 0x30, 0xe6, 0x22, 0x0f, 0x05, 0xbd, 0xef, 0xdb, 0xb3, - 0x98, 0x09, 0x4a, 0x3a, 0xa9, 0xb8, 0x2b, 0x18, 0xc3, 0x47, 0xe0, 0xa4, 0xb9, 0x3c, 0xff, 0x36, - 0x7a, 0x8a, 0x59, 0x41, 0xdd, 0xa6, 0x87, 0x02, 0x8b, 0x80, 0x96, 0x7e, 0x55, 0x0a, 0x3e, 0x86, - 0x7e, 0xb1, 0x49, 0x58, 0x1e, 0x0a, 0x5a, 0xc4, 0x29, 0xb6, 0x91, 0x84, 0x17, 0x13, 0x46, 0x2b, - 0xa4, 0xe5, 0xa1, 0x00, 0x11, 0xc7, 0x68, 0x06, 0x39, 0x02, 0x67, 0x52, 0x4a, 0x2a, 0x2a, 0xa2, - 0xed, 0xa1, 0xa0, 0x4f, 0x40, 0x4b, 0x6f, 0x7b, 0x08, 0xb9, 0x4c, 0xf3, 0x79, 0x45, 0x74, 0x3c, - 0x14, 0xd8, 0xc4, 0x31, 0x9a, 0x46, 0xfc, 0xbf, 0x11, 0x80, 0x71, 0x75, 0x95, 0xcf, 0x38, 0x76, - 0xa1, 0x95, 0xc7, 0x19, 0xd5, 0xb6, 0xec, 0xcb, 0xd6, 0xf3, 0x7f, 0x47, 0x0d, 0xa2, 0x15, 0x7c, - 0x02, 0x90, 0x95, 0xe2, 0x91, 0x45, 0xb2, 0x5c, 0x18, 0x4b, 0x75, 0xdd, 0xd6, 0xfa, 0x7d, 0xb9, - 0xa0, 0xf8, 0x14, 0xf6, 0x52, 0x11, 0x2d, 0x96, 0x69, 0x16, 0x2f, 0xcb, 0xe8, 0x77, 0x5a, 0x6a, - 0x67, 0xbd, 0x0a, 0xec, 0xa7, 0xe2, 0x27, 0x53, 0xba, 0xa6, 0xa5, 0x3a, 0x6a, 0xc6, 0x68, 0xae, - 0x8d, 0xb5, 0xeb, 0xa3, 0x94, 0xa2, 0xe2, 0x4d, 0xe8, 0x34, 0xcd, 0x62, 0xa6, 0x3d, 0xd5, 0xc5, - 0x5a, 0xf4, 0xbf, 0x03, 0x8b, 0xf0, 0x15, 0x1e, 0x41, 0x77, 0xaa, 0x6f, 0x2e, 0x5c, 0xe4, 0x59, - 0x81, 0x33, 0xde, 0x1f, 0x6d, 0x3e, 0xe3, 0xc8, 0xd8, 0x22, 0x35, 0xe4, 0xbf, 0x43, 0xd0, 0xbe, - 0x8f, 0x27, 0x4c, 0x07, 0x27, 0xa6, 0x0f, 0x34, 0x8b, 0xa3, 0xb5, 0x59, 0x02, 0x46, 0xba, 0x53, - 0x66, 0xbf, 0x02, 0x90, 0x8a, 0x34, 0x75, 0x6d, 0x96, 0xd8, 0x5a, 0xd1, 0xe5, 0x0b, 0x70, 0xcc, - 0xa6, 0x51, 0x9a, 0xcf, 0xb8, 0x6b, 0xe9, 0xd3, 0xdd, 0x5d, 0xa7, 0xab, 0x50, 0x09, 0x4c, 0xd7, - 0x01, 0x5f, 0x80, 0x9d, 0x15, 0x32, 0x96, 0x29, 0xcf, 0x85, 0xdb, 0xd2, 0x8d, 0x87, 0xdb, 0x8d, - 0xfa, 0x8a, 0xb7, 0x15, 0x43, 0xd6, 0x34, 0x1e, 0x83, 0x53, 0xe4, 0xe9, 0x63, 0x41, 0x55, 0xb0, - 0xc2, 0x6d, 0xeb, 0xe6, 0xcf, 0xb7, 0x9b, 0xaf, 0x69, 0x49, 0xc0, 0x50, 0xd7, 0xb4, 0x14, 0xfe, - 0x0f, 0x60, 0xa9, 0xac, 0xf1, 0xe6, 0xb3, 0x56, 0x0f, 0x7a, 0x0c, 0xfd, 0xca, 0x84, 0xfa, 0x29, - 0xdc, 0xa6, 0x67, 0xa9, 0xe1, 0x30, 0x9a, 0xb2, 0x29, 0xfc, 0x3f, 0x11, 0x7c, 0xb6, 0x75, 0x1d, - 0x3c, 0x82, 0x96, 0x7e, 0x7f, 0xe4, 0x35, 0x83, 0xbd, 0xf1, 0xc1, 0xf6, 0xe1, 0x35, 0xa5, 0x46, - 0x81, 0x68, 0x0e, 0x9f, 0x80, 0xb5, 0xe4, 0x2b, 0xb7, 0xe9, 0x35, 0x3f, 0xbe, 0x2b, 0xe1, 0x2b, - 0xa2, 0xaa, 0xf8, 0x0c, 0x60, 0xfa, 0x10, 0xe7, 0x73, 0x1a, 0x29, 0x56, 0x4d, 0xcc, 0x4e, 0xd6, - 0x36, 0x10, 0xe1, 0x2b, 0xff, 0x1c, 0xba, 0xe1, 0xed, 0x4d, 0x18, 0xcb, 0x18, 0x7f, 0x0d, 0x1d, - 0xfd, 0x30, 0xf5, 0x10, 0x7c, 0xb1, 0x23, 0x4d, 0x52, 0x21, 0xfe, 0x0c, 0xba, 0x61, 0x68, 0xfa, - 0x3e, 0x75, 0x06, 0x0e, 0xc1, 0x4e, 0x12, 0x16, 0x3d, 0x16, 0x74, 0x69, 0xa6, 0xbc, 0x4f, 0x7a, - 0x49, 0xc2, 0x7e, 0x56, 0xbf, 0xfd, 0x17, 0x04, 0x9d, 0x4b, 0x7d, 0x01, 0x3c, 0x7e, 0x4b, 0x0c, - 0x05, 0x7b, 0x1f, 0x0e, 0x89, 0x61, 0x54, 0x5e, 0xf5, 0x1f, 0x40, 0xa7, 0x76, 0x0c, 0xf6, 0x94, - 0x67, 0x59, 0x2a, 0x23, 0x29, 0xcc, 0xd7, 0xa3, 0x2a, 0xf7, 0x8c, 0x7c, 0x2f, 0xf0, 0x19, 0xf4, - 0x92, 0x8c, 0x45, 0x49, 0x2c, 0xe3, 0x2a, 0xb1, 0x2f, 0xb7, 0xb7, 0xae, 0xf2, 0x21, 0xdd, 0x24, - 0x63, 0xda, 0xb0, 0xea, 0x48, 0xaa, 0x8e, 0xd6, 0xce, 0x8e, 0xb0, 0xee, 0x48, 0x4c, 0xc7, 0x21, - 0xd8, 0x32, 0xcd, 0x68, 0xf4, 0x07, 0xcf, 0xcd, 0xd7, 0xc5, 0x26, 0x3d, 0x25, 0xfc, 0xc6, 0x73, - 0x7a, 0x3a, 0x86, 0xfe, 0xe6, 0x7b, 0x63, 0x80, 0xce, 0x55, 0x2e, 0xe8, 0x52, 0x0e, 0x1a, 0x6a, - 0xfd, 0xcb, 0x22, 0x89, 0x25, 0x1d, 0x20, 0xb5, 0x0e, 0x29, 0xa3, 0x92, 0x0e, 0x9a, 0xa7, 0x43, - 0x80, 0xb5, 0x63, 0xdc, 0x05, 0x2b, 0xbc, 0xbd, 0x19, 0x34, 0xf4, 0x22, 0xbc, 0x19, 0xa0, 0xcb, - 0xc1, 0xf3, 0xeb, 0x10, 0xfd, 0xf3, 0x3a, 0x44, 0x2f, 0xaf, 0x43, 0xf4, 0xd7, 0xff, 0xc3, 0xc6, - 0xfb, 0x00, 0x00, 0x00, 0xff, 0xff, 0x8f, 0x81, 0x5f, 0x03, 0xa3, 0x05, 0x00, 0x00, +func init() { proto.RegisterFile("secondary_binlog.proto", fileDescriptor_3e5ebd7aa3410f61) } + +var fileDescriptor_3e5ebd7aa3410f61 = []byte{ + // 756 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x94, 0xcf, 0x8e, 0xeb, 0x34, + 0x14, 0xc6, 0xeb, 0xa6, 0xff, 0x72, 0x52, 0x46, 0xc5, 0x5c, 0x50, 0x74, 0x47, 0x74, 0x32, 0xb9, + 0x9b, 0x68, 0x90, 0xca, 0x55, 0x05, 0x57, 0xba, 0x88, 0xd5, 0x90, 0xcd, 0x68, 0xfe, 0x08, 0xac, + 0x81, 0x05, 0x9b, 0x28, 0x6d, 0xdc, 0x4e, 0x84, 0x63, 0x77, 0x6a, 0x67, 0xaa, 0xf0, 0x20, 0x88, + 0xd7, 0xe0, 0x2d, 0x66, 0x89, 0xc4, 0x1e, 0x8d, 0x86, 0x27, 0xe0, 0x0d, 0x90, 0xed, 0x64, 0xda, + 0x42, 0x77, 0xec, 0xdc, 0xef, 0xfc, 0x8e, 0xed, 0xef, 0xf3, 0x69, 0xe0, 0x13, 0x49, 0xe7, 0x82, + 0x67, 0xe9, 0xba, 0x4a, 0x66, 0x39, 0x67, 0x62, 0x39, 0x59, 0xad, 0x85, 0x12, 0x78, 0x28, 0x59, + 0xfa, 0x40, 0x27, 0x56, 0x7b, 0xfd, 0x6a, 0x29, 0x96, 0xc2, 0x14, 0x3e, 0xd7, 0x2b, 0xcb, 0x84, + 0x7f, 0x20, 0xe8, 0x7d, 0x23, 0x58, 0x59, 0x70, 0x3c, 0x86, 0x7e, 0x2e, 0x13, 0x5e, 0x32, 0xe6, + 0xa3, 0x00, 0x45, 0x83, 0xaf, 0xba, 0x8b, 0x94, 0x49, 0x4a, 0x7a, 0xb9, 0xbc, 0x29, 0x19, 0xc3, + 0x27, 0xe0, 0xe5, 0x5c, 0xbd, 0xfb, 0x22, 0x79, 0x48, 0x59, 0x49, 0xfd, 0x76, 0x80, 0x22, 0x87, + 0x80, 0x91, 0x7e, 0xd0, 0x0a, 0x3e, 0x85, 0x61, 0xb9, 0x4b, 0x38, 0x01, 0x8a, 0x3a, 0xc4, 0x2b, + 0xf7, 0x91, 0x4c, 0x94, 0x33, 0x46, 0x6b, 0xa4, 0x13, 0xa0, 0x08, 0x11, 0xcf, 0x6a, 0x16, 0x39, + 0x01, 0x6f, 0x56, 0x29, 0x2a, 0x6b, 0xa2, 0x1b, 0xa0, 0x68, 0x48, 0xc0, 0x48, 0x2f, 0x7b, 0x48, + 0xb5, 0xce, 0xf9, 0xb2, 0x26, 0x7a, 0x01, 0x8a, 0x5c, 0xe2, 0x59, 0xcd, 0x20, 0xe1, 0x6f, 0x08, + 0xc0, 0xba, 0xba, 0xe0, 0x0b, 0x81, 0x7d, 0xe8, 0xf0, 0xb4, 0xa0, 0xc6, 0x96, 0x7b, 0xde, 0x79, + 0xfc, 0xf3, 0xa4, 0x45, 0x8c, 0x82, 0xdf, 0x00, 0x14, 0x95, 0xbc, 0x67, 0x89, 0xaa, 0x56, 0xd6, + 0x52, 0x53, 0x77, 0x8d, 0x7e, 0x5b, 0xad, 0x28, 0x3e, 0x83, 0xa3, 0x5c, 0x26, 0xab, 0x75, 0x5e, + 0xe8, 0x88, 0x7f, 0xa2, 0x95, 0x71, 0x36, 0xa8, 0xc1, 0x61, 0x2e, 0xbf, 0xb5, 0xa5, 0x4b, 0x5a, + 0xe9, 0xa3, 0x16, 0x8c, 0x72, 0x63, 0xac, 0xdb, 0x1c, 0xa5, 0x15, 0x1d, 0x6f, 0x46, 0xe7, 0x79, + 0x91, 0x32, 0xe3, 0xa9, 0x29, 0x36, 0x62, 0xf8, 0x25, 0x38, 0x44, 0x6c, 0xf0, 0x04, 0xfa, 0x73, + 0x73, 0x73, 0xe9, 0xa3, 0xc0, 0x89, 0xbc, 0xe9, 0xab, 0xc9, 0xee, 0x33, 0x4e, 0xac, 0x2d, 0xd2, + 0x40, 0xe1, 0xdf, 0x08, 0xba, 0xb7, 0xe9, 0x8c, 0x99, 0xe0, 0xe4, 0xfc, 0x8e, 0x16, 0x69, 0xb2, + 0x35, 0x4b, 0xc0, 0x4a, 0x37, 0xda, 0xec, 0xa7, 0x00, 0x4a, 0x93, 0xb6, 0x6e, 0xcc, 0x12, 0xd7, + 0x28, 0xa6, 0xfc, 0x1e, 0x3c, 0xbb, 0x69, 0x92, 0xf3, 0x85, 0xf0, 0x1d, 0x73, 0xba, 0x7f, 0xe8, + 0x74, 0x1d, 0x2a, 0x81, 0xf9, 0x36, 0xe0, 0xf7, 0xe0, 0x16, 0xa5, 0x4a, 0x55, 0x2e, 0xb8, 0xf4, + 0x3b, 0xa6, 0xf1, 0x78, 0xbf, 0xd1, 0x5c, 0xf1, 0xba, 0x66, 0xc8, 0x96, 0xc6, 0x53, 0xf0, 0x4a, + 0x9e, 0xdf, 0x97, 0x54, 0x07, 0x2b, 0xfd, 0xae, 0x69, 0xfe, 0x70, 0xbf, 0xf9, 0x92, 0x56, 0x04, + 0x2c, 0x75, 0x49, 0x2b, 0x19, 0x7e, 0x0d, 0x8e, 0xce, 0x1a, 0xef, 0x3e, 0x6b, 0xfd, 0xa0, 0xa7, + 0x30, 0xac, 0x4d, 0xe8, 0x9f, 0xd2, 0x6f, 0x07, 0x8e, 0x1e, 0x0e, 0xab, 0x69, 0x9b, 0x32, 0xfc, + 0x05, 0xc1, 0x07, 0x7b, 0xd7, 0xc1, 0x13, 0xe8, 0x98, 0xf7, 0x47, 0x41, 0x3b, 0x3a, 0x9a, 0xbe, + 0xde, 0x3f, 0xbc, 0xa1, 0xf4, 0x28, 0x10, 0xc3, 0xe1, 0x37, 0xe0, 0xac, 0xc5, 0xc6, 0x6f, 0x07, + 0xed, 0xff, 0xde, 0x95, 0x88, 0x0d, 0xd1, 0x55, 0xfc, 0x16, 0x60, 0x7e, 0x97, 0xf2, 0x25, 0x4d, + 0x34, 0xab, 0x27, 0xe6, 0x20, 0xeb, 0x5a, 0x88, 0x88, 0x4d, 0xf8, 0x0e, 0xfa, 0xf1, 0xf5, 0x55, + 0x9c, 0xaa, 0x14, 0x7f, 0x06, 0x3d, 0xf3, 0x30, 0xcd, 0x10, 0x7c, 0x74, 0x20, 0x4d, 0x52, 0x23, + 0xe1, 0x02, 0xfa, 0x71, 0x6c, 0xfb, 0xfe, 0xef, 0x0c, 0x1c, 0x83, 0x9b, 0x65, 0x2c, 0xb9, 0x2f, + 0xe9, 0xda, 0x4e, 0xf9, 0x90, 0x0c, 0xb2, 0x8c, 0x7d, 0xa7, 0x7f, 0x87, 0x4f, 0x08, 0x7a, 0xe7, + 0xe6, 0x02, 0x78, 0xfa, 0x92, 0x18, 0x8a, 0x8e, 0xfe, 0x3d, 0x24, 0x96, 0xd1, 0x79, 0x35, 0x7f, + 0x00, 0x93, 0xda, 0x29, 0xb8, 0x73, 0x51, 0x14, 0xb9, 0x4a, 0x94, 0xb4, 0x5f, 0x8f, 0xba, 0x3c, + 0xb0, 0xf2, 0xad, 0xc4, 0x6f, 0x61, 0x90, 0x15, 0x2c, 0xc9, 0x52, 0x95, 0xd6, 0x89, 0x7d, 0xbc, + 0xbf, 0x75, 0x9d, 0x0f, 0xe9, 0x67, 0x05, 0x33, 0x86, 0x75, 0x47, 0x56, 0x77, 0x74, 0x0e, 0x76, + 0xc4, 0x4d, 0x47, 0x66, 0x3b, 0x8e, 0xc1, 0x55, 0x79, 0x41, 0x93, 0x9f, 0x05, 0xb7, 0x5f, 0x17, + 0x97, 0x0c, 0xb4, 0xf0, 0xa3, 0xe0, 0xf4, 0x6c, 0x0a, 0xc3, 0xdd, 0xf7, 0xc6, 0x00, 0xbd, 0x0b, + 0x2e, 0xe9, 0x5a, 0x8d, 0x5a, 0x7a, 0xfd, 0xfd, 0x2a, 0x4b, 0x15, 0x1d, 0x21, 0xbd, 0x8e, 0x29, + 0xa3, 0x8a, 0x8e, 0xda, 0x67, 0x63, 0x80, 0xad, 0x63, 0xdc, 0x07, 0x27, 0xbe, 0xbe, 0x1a, 0xb5, + 0xcc, 0x22, 0xbe, 0x1a, 0xa1, 0xf3, 0xd1, 0xe3, 0xf3, 0x18, 0xfd, 0xfe, 0x3c, 0x46, 0x4f, 0xcf, + 0x63, 0xf4, 0xeb, 0x5f, 0xe3, 0xd6, 0x3f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x2f, 0xa6, 0x92, 0xaa, + 0xb1, 0x05, 0x00, 0x00, } func (m *Column) Marshal() (dAtA []byte, err error) { @@ -843,12 +844,12 @@ func (m *Column) MarshalTo(dAtA []byte) (int, error) { if m.Int64Value != nil { dAtA[i] = 0x10 i++ - i = encodeVarintBl(dAtA, i, uint64(*m.Int64Value)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(*m.Int64Value)) } if m.Uint64Value != nil { dAtA[i] = 0x18 i++ - i = encodeVarintBl(dAtA, i, uint64(*m.Uint64Value)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(*m.Uint64Value)) } if m.DoubleValue != nil { dAtA[i] = 0x21 @@ -859,13 +860,13 @@ func (m *Column) MarshalTo(dAtA []byte) (int, error) { if m.BytesValue != nil { dAtA[i] = 0x2a i++ - i = encodeVarintBl(dAtA, i, uint64(len(m.BytesValue))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(m.BytesValue))) i += copy(dAtA[i:], m.BytesValue) } if m.StringValue != nil { dAtA[i] = 0x32 i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.StringValue))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.StringValue))) i += copy(dAtA[i:], *m.StringValue) } if m.XXX_unrecognized != nil { @@ -891,11 +892,11 @@ func (m *ColumnInfo) MarshalTo(dAtA []byte) (int, error) { _ = l dAtA[i] = 0xa i++ - i = encodeVarintBl(dAtA, i, uint64(len(m.Name))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) dAtA[i] = 0x12 i++ - i = encodeVarintBl(dAtA, i, uint64(len(m.MysqlType))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(m.MysqlType))) i += copy(dAtA[i:], m.MysqlType) dAtA[i] = 0x18 i++ @@ -907,10 +908,10 @@ func (m *ColumnInfo) MarshalTo(dAtA []byte) (int, error) { i++ dAtA[i] = 0x20 i++ - i = encodeVarintBl(dAtA, i, uint64(m.Flen)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.Flen)) dAtA[i] = 0x28 i++ - i = encodeVarintBl(dAtA, i, uint64(m.Decimal)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.Decimal)) if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) } @@ -936,7 +937,7 @@ func (m *Row) MarshalTo(dAtA []byte) (int, error) { for _, msg := range m.Columns { dAtA[i] = 0xa i++ - i = encodeVarintBl(dAtA, i, uint64(msg.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -968,20 +969,20 @@ func (m *Table) MarshalTo(dAtA []byte) (int, error) { if m.SchemaName != nil { dAtA[i] = 0xa i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.SchemaName))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.SchemaName))) i += copy(dAtA[i:], *m.SchemaName) } if m.TableName != nil { dAtA[i] = 0x12 i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.TableName))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.TableName))) i += copy(dAtA[i:], *m.TableName) } if len(m.ColumnInfo) > 0 { for _, msg := range m.ColumnInfo { dAtA[i] = 0x1a i++ - i = encodeVarintBl(dAtA, i, uint64(msg.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -993,7 +994,7 @@ func (m *Table) MarshalTo(dAtA []byte) (int, error) { for _, msg := range m.Mutations { dAtA[i] = 0x22 i++ - i = encodeVarintBl(dAtA, i, uint64(msg.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1005,7 +1006,7 @@ func (m *Table) MarshalTo(dAtA []byte) (int, error) { for _, msg := range m.UniqueKeys { dAtA[i] = 0x2a i++ - i = encodeVarintBl(dAtA, i, uint64(msg.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1037,7 +1038,7 @@ func (m *Key) MarshalTo(dAtA []byte) (int, error) { if m.Name != nil { dAtA[i] = 0xa i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.Name))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.Name))) i += copy(dAtA[i:], *m.Name) } if len(m.ColumnNames) > 0 { @@ -1081,14 +1082,14 @@ func (m *TableMutation) MarshalTo(dAtA []byte) (int, error) { } else { dAtA[i] = 0x8 i++ - i = encodeVarintBl(dAtA, i, uint64(*m.Type)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(*m.Type)) } if m.Row == nil { return 0, new(github_com_golang_protobuf_proto.RequiredNotSetError) } else { dAtA[i] = 0x12 i++ - i = encodeVarintBl(dAtA, i, uint64(m.Row.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.Row.Size())) n1, err := m.Row.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1098,7 +1099,7 @@ func (m *TableMutation) MarshalTo(dAtA []byte) (int, error) { if m.ChangeRow != nil { dAtA[i] = 0x1a i++ - i = encodeVarintBl(dAtA, i, uint64(m.ChangeRow.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.ChangeRow.Size())) n2, err := m.ChangeRow.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1130,7 +1131,7 @@ func (m *DMLData) MarshalTo(dAtA []byte) (int, error) { for _, msg := range m.Tables { dAtA[i] = 0xa i++ - i = encodeVarintBl(dAtA, i, uint64(msg.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1162,19 +1163,19 @@ func (m *DDLData) MarshalTo(dAtA []byte) (int, error) { if m.SchemaName != nil { dAtA[i] = 0xa i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.SchemaName))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.SchemaName))) i += copy(dAtA[i:], *m.SchemaName) } if m.TableName != nil { dAtA[i] = 0x12 i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.TableName))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.TableName))) i += copy(dAtA[i:], *m.TableName) } if m.DdlQuery != nil { dAtA[i] = 0x1a i++ - i = encodeVarintBl(dAtA, i, uint64(len(m.DdlQuery))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(m.DdlQuery))) i += copy(dAtA[i:], m.DdlQuery) } if m.XXX_unrecognized != nil { @@ -1200,14 +1201,14 @@ func (m *Binlog) MarshalTo(dAtA []byte) (int, error) { _ = l dAtA[i] = 0x8 i++ - i = encodeVarintBl(dAtA, i, uint64(m.Type)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.Type)) dAtA[i] = 0x10 i++ - i = encodeVarintBl(dAtA, i, uint64(m.CommitTs)) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.CommitTs)) if m.DmlData != nil { dAtA[i] = 0x1a i++ - i = encodeVarintBl(dAtA, i, uint64(m.DmlData.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.DmlData.Size())) n3, err := m.DmlData.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1217,7 +1218,7 @@ func (m *Binlog) MarshalTo(dAtA []byte) (int, error) { if m.DdlData != nil { dAtA[i] = 0x22 i++ - i = encodeVarintBl(dAtA, i, uint64(m.DdlData.Size())) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(m.DdlData.Size())) n4, err := m.DdlData.MarshalTo(dAtA[i:]) if err != nil { return 0, err @@ -1227,7 +1228,7 @@ func (m *Binlog) MarshalTo(dAtA []byte) (int, error) { if m.TimeZone != nil { dAtA[i] = 0x2a i++ - i = encodeVarintBl(dAtA, i, uint64(len(*m.TimeZone))) + i = encodeVarintSecondaryBinlog(dAtA, i, uint64(len(*m.TimeZone))) i += copy(dAtA[i:], *m.TimeZone) } if m.XXX_unrecognized != nil { @@ -1236,7 +1237,7 @@ func (m *Binlog) MarshalTo(dAtA []byte) (int, error) { return i, nil } -func encodeVarintBl(dAtA []byte, offset int, v uint64) int { +func encodeVarintSecondaryBinlog(dAtA []byte, offset int, v uint64) int { for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 @@ -1255,21 +1256,21 @@ func (m *Column) Size() (n int) { n += 2 } if m.Int64Value != nil { - n += 1 + sovBl(uint64(*m.Int64Value)) + n += 1 + sovSecondaryBinlog(uint64(*m.Int64Value)) } if m.Uint64Value != nil { - n += 1 + sovBl(uint64(*m.Uint64Value)) + n += 1 + sovSecondaryBinlog(uint64(*m.Uint64Value)) } if m.DoubleValue != nil { n += 9 } if m.BytesValue != nil { l = len(m.BytesValue) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.StringValue != nil { l = len(*m.StringValue) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) @@ -1284,12 +1285,12 @@ func (m *ColumnInfo) Size() (n int) { var l int _ = l l = len(m.Name) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) l = len(m.MysqlType) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) n += 2 - n += 1 + sovBl(uint64(m.Flen)) - n += 1 + sovBl(uint64(m.Decimal)) + n += 1 + sovSecondaryBinlog(uint64(m.Flen)) + n += 1 + sovSecondaryBinlog(uint64(m.Decimal)) if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) } @@ -1305,7 +1306,7 @@ func (m *Row) Size() (n int) { if len(m.Columns) > 0 { for _, e := range m.Columns { l = e.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } } if m.XXX_unrecognized != nil { @@ -1322,28 +1323,28 @@ func (m *Table) Size() (n int) { _ = l if m.SchemaName != nil { l = len(*m.SchemaName) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.TableName != nil { l = len(*m.TableName) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if len(m.ColumnInfo) > 0 { for _, e := range m.ColumnInfo { l = e.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } } if len(m.Mutations) > 0 { for _, e := range m.Mutations { l = e.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } } if len(m.UniqueKeys) > 0 { for _, e := range m.UniqueKeys { l = e.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } } if m.XXX_unrecognized != nil { @@ -1360,12 +1361,12 @@ func (m *Key) Size() (n int) { _ = l if m.Name != nil { l = len(*m.Name) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if len(m.ColumnNames) > 0 { for _, s := range m.ColumnNames { l = len(s) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } } if m.XXX_unrecognized != nil { @@ -1381,15 +1382,15 @@ func (m *TableMutation) Size() (n int) { var l int _ = l if m.Type != nil { - n += 1 + sovBl(uint64(*m.Type)) + n += 1 + sovSecondaryBinlog(uint64(*m.Type)) } if m.Row != nil { l = m.Row.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.ChangeRow != nil { l = m.ChangeRow.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) @@ -1406,7 +1407,7 @@ func (m *DMLData) Size() (n int) { if len(m.Tables) > 0 { for _, e := range m.Tables { l = e.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } } if m.XXX_unrecognized != nil { @@ -1423,15 +1424,15 @@ func (m *DDLData) Size() (n int) { _ = l if m.SchemaName != nil { l = len(*m.SchemaName) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.TableName != nil { l = len(*m.TableName) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.DdlQuery != nil { l = len(m.DdlQuery) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) @@ -1445,19 +1446,19 @@ func (m *Binlog) Size() (n int) { } var l int _ = l - n += 1 + sovBl(uint64(m.Type)) - n += 1 + sovBl(uint64(m.CommitTs)) + n += 1 + sovSecondaryBinlog(uint64(m.Type)) + n += 1 + sovSecondaryBinlog(uint64(m.CommitTs)) if m.DmlData != nil { l = m.DmlData.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.DdlData != nil { l = m.DdlData.Size() - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.TimeZone != nil { l = len(*m.TimeZone) - n += 1 + l + sovBl(uint64(l)) + n += 1 + l + sovSecondaryBinlog(uint64(l)) } if m.XXX_unrecognized != nil { n += len(m.XXX_unrecognized) @@ -1465,7 +1466,7 @@ func (m *Binlog) Size() (n int) { return n } -func sovBl(x uint64) (n int) { +func sovSecondaryBinlog(x uint64) (n int) { for { n++ x >>= 7 @@ -1475,8 +1476,8 @@ func sovBl(x uint64) (n int) { } return n } -func sozBl(x uint64) (n int) { - return sovBl(uint64((x << 1) ^ uint64((int64(x) >> 63)))) +func sozSecondaryBinlog(x uint64) (n int) { + return sovSecondaryBinlog(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *Column) Unmarshal(dAtA []byte) error { l := len(dAtA) @@ -1486,7 +1487,7 @@ func (m *Column) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1514,7 +1515,7 @@ func (m *Column) Unmarshal(dAtA []byte) error { var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1535,7 +1536,7 @@ func (m *Column) Unmarshal(dAtA []byte) error { var v int64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1555,7 +1556,7 @@ func (m *Column) Unmarshal(dAtA []byte) error { var v uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1587,7 +1588,7 @@ func (m *Column) Unmarshal(dAtA []byte) error { var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1600,11 +1601,11 @@ func (m *Column) Unmarshal(dAtA []byte) error { } } if byteLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + byteLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -1621,7 +1622,7 @@ func (m *Column) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1635,11 +1636,11 @@ func (m *Column) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -1649,15 +1650,15 @@ func (m *Column) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -1680,7 +1681,7 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1708,7 +1709,7 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1722,11 +1723,11 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -1740,7 +1741,7 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1754,11 +1755,11 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -1772,7 +1773,7 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1792,7 +1793,7 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { m.Flen = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1811,7 +1812,7 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { m.Decimal = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1825,15 +1826,15 @@ func (m *ColumnInfo) Unmarshal(dAtA []byte) error { } default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -1856,7 +1857,7 @@ func (m *Row) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1884,7 +1885,7 @@ func (m *Row) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1897,11 +1898,11 @@ func (m *Row) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -1913,15 +1914,15 @@ func (m *Row) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -1944,7 +1945,7 @@ func (m *Table) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1972,7 +1973,7 @@ func (m *Table) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -1986,11 +1987,11 @@ func (m *Table) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2005,7 +2006,7 @@ func (m *Table) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2019,11 +2020,11 @@ func (m *Table) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2038,7 +2039,7 @@ func (m *Table) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2051,11 +2052,11 @@ func (m *Table) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2072,7 +2073,7 @@ func (m *Table) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2085,11 +2086,11 @@ func (m *Table) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2106,7 +2107,7 @@ func (m *Table) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2119,11 +2120,11 @@ func (m *Table) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2135,15 +2136,15 @@ func (m *Table) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -2166,7 +2167,7 @@ func (m *Key) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2194,7 +2195,7 @@ func (m *Key) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2208,11 +2209,11 @@ func (m *Key) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2227,7 +2228,7 @@ func (m *Key) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2241,11 +2242,11 @@ func (m *Key) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2254,15 +2255,15 @@ func (m *Key) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -2286,7 +2287,7 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2314,7 +2315,7 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { var v MutationType for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2335,7 +2336,7 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2348,11 +2349,11 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2372,7 +2373,7 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2385,11 +2386,11 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2403,15 +2404,15 @@ func (m *TableMutation) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -2440,7 +2441,7 @@ func (m *DMLData) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2468,7 +2469,7 @@ func (m *DMLData) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2481,11 +2482,11 @@ func (m *DMLData) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2497,15 +2498,15 @@ func (m *DMLData) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -2528,7 +2529,7 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2556,7 +2557,7 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2570,11 +2571,11 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2589,7 +2590,7 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2603,11 +2604,11 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2622,7 +2623,7 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { var byteLen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2635,11 +2636,11 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { } } if byteLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + byteLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2651,15 +2652,15 @@ func (m *DDLData) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -2682,7 +2683,7 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2710,7 +2711,7 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { m.Type = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2729,7 +2730,7 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { m.CommitTs = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2748,7 +2749,7 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2761,11 +2762,11 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2784,7 +2785,7 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2797,11 +2798,11 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { } } if msglen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + msglen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2820,7 +2821,7 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return ErrIntOverflowBl + return ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return io.ErrUnexpectedEOF @@ -2834,11 +2835,11 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { } intStringLen := int(stringLen) if intStringLen < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } postIndex := iNdEx + intStringLen if postIndex < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if postIndex > l { return io.ErrUnexpectedEOF @@ -2848,15 +2849,15 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { iNdEx = postIndex default: iNdEx = preIndex - skippy, err := skipBl(dAtA[iNdEx:]) + skippy, err := skipSecondaryBinlog(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) < 0 { - return ErrInvalidLengthBl + return ErrInvalidLengthSecondaryBinlog } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF @@ -2871,14 +2872,14 @@ func (m *Binlog) Unmarshal(dAtA []byte) error { } return nil } -func skipBl(dAtA []byte) (n int, err error) { +func skipSecondaryBinlog(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { - return 0, ErrIntOverflowBl + return 0, ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return 0, io.ErrUnexpectedEOF @@ -2895,7 +2896,7 @@ func skipBl(dAtA []byte) (n int, err error) { case 0: for shift := uint(0); ; shift += 7 { if shift >= 64 { - return 0, ErrIntOverflowBl + return 0, ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return 0, io.ErrUnexpectedEOF @@ -2913,7 +2914,7 @@ func skipBl(dAtA []byte) (n int, err error) { var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { - return 0, ErrIntOverflowBl + return 0, ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return 0, io.ErrUnexpectedEOF @@ -2926,11 +2927,11 @@ func skipBl(dAtA []byte) (n int, err error) { } } if length < 0 { - return 0, ErrInvalidLengthBl + return 0, ErrInvalidLengthSecondaryBinlog } iNdEx += length if iNdEx < 0 { - return 0, ErrInvalidLengthBl + return 0, ErrInvalidLengthSecondaryBinlog } return iNdEx, nil case 3: @@ -2939,7 +2940,7 @@ func skipBl(dAtA []byte) (n int, err error) { var start int = iNdEx for shift := uint(0); ; shift += 7 { if shift >= 64 { - return 0, ErrIntOverflowBl + return 0, ErrIntOverflowSecondaryBinlog } if iNdEx >= l { return 0, io.ErrUnexpectedEOF @@ -2955,13 +2956,13 @@ func skipBl(dAtA []byte) (n int, err error) { if innerWireType == 4 { break } - next, err := skipBl(dAtA[start:]) + next, err := skipSecondaryBinlog(dAtA[start:]) if err != nil { return 0, err } iNdEx = start + next if iNdEx < 0 { - return 0, ErrInvalidLengthBl + return 0, ErrInvalidLengthSecondaryBinlog } } return iNdEx, nil @@ -2978,6 +2979,6 @@ func skipBl(dAtA []byte) (n int, err error) { } var ( - ErrInvalidLengthBl = fmt.Errorf("proto: negative length found during unmarshaling") - ErrIntOverflowBl = fmt.Errorf("proto: integer overflow") + ErrInvalidLengthSecondaryBinlog = fmt.Errorf("proto: negative length found during unmarshaling") + ErrIntOverflowSecondaryBinlog = fmt.Errorf("proto: integer overflow") ) diff --git a/tidb-binlog/proto/proto/bl.proto b/tidb-binlog/proto/proto/secondary_binlog.proto similarity index 100% rename from tidb-binlog/proto/proto/bl.proto rename to tidb-binlog/proto/proto/secondary_binlog.proto