File tree Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change 99)
1010
1111var (
12- ErrNeedSyncAgain = errors .New ("Last sync error or closed, try sync and get event again" )
13- ErrSyncClosed = errors .New ("Sync was closed" )
14- ErrStreamerIsFull = errors .New ("streamer is full" )
12+ ErrNeedSyncAgain = errors .New ("Last sync error or closed, try sync and get event again" )
13+ ErrSyncClosed = errors .New ("Sync was closed" )
1514)
1615
1716// BinlogStreamer gets the streaming event.
@@ -102,8 +101,6 @@ func (s *BinlogStreamer) AddEventToStreamer(ev *BinlogEvent) error {
102101 return nil
103102 case err := <- s .ech :
104103 return err
105- default :
106- return ErrStreamerIsFull
107104 }
108105}
109106
Original file line number Diff line number Diff line change @@ -3,6 +3,7 @@ package server
33import (
44 "context"
55 "fmt"
6+
67 . "github.com/go-mysql-org/go-mysql/mysql"
78 "github.com/go-mysql-org/go-mysql/replication"
89)
You can’t perform that action at this time.
0 commit comments