Skip to content

Commit ad3338a

Browse files
LIU HANRANLIU HANRAN
LIU HANRAN
authored and
LIU HANRAN
committed
Add ParseHeader and ParseEvent func
1 parent 1c55c36 commit ad3338a

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

replication/parser.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,11 @@ func (p *BinlogParser) SetFlavor(flavor string) {
212212
p.flavor = flavor
213213
}
214214

215+
//added by momo
216+
func (p *BinlogParser) ParseHeader(data []byte) (*EventHeader, error) {
217+
return p.parseHeader(data)
218+
}
219+
215220
func (p *BinlogParser) parseHeader(data []byte) (*EventHeader, error) {
216221
h := new(EventHeader)
217222
err := h.Decode(data)
@@ -222,6 +227,11 @@ func (p *BinlogParser) parseHeader(data []byte) (*EventHeader, error) {
222227
return h, nil
223228
}
224229

230+
// added by momo
231+
func (p *BinlogParser) ParseEvent(h *EventHeader, data []byte, rawData []byte) (Event, error) {
232+
return p.parseEvent(h, data, rawData)
233+
}
234+
225235
func (p *BinlogParser) parseEvent(h *EventHeader, data []byte, rawData []byte) (Event, error) {
226236
var e Event
227237

0 commit comments

Comments
 (0)