binlog-parser

Usage

func main() {
	decoder, err := binlog.NewBinFileDecoder("./testdata/mysql-bin.000004")
	if err != nil {
		panic(err)
	}
	err = decoder.WalkEvent(func(event *binlog.BinEvent) (isContinue bool, err error) {
		eventType, _ := event.GetType()
		fmt.Printf("Got %s\n", eventType)
		fmt.Println(event.Header)
		if event.Body != nil {
			fmt.Println(event.Body)
		}
		fmt.Println(strings.Repeat("=", 100))
		return true, nil
	})
	if err != nil {
		panic(err)
	}
}