streamer

Sep 6, 2019

Changes in this version

+ func CollectAllBinlogFiles(dir string) ([]string, error)

+ func CollectBinlogFilesCmp(dir, baseFile string, cmp FileCmp) ([]string, error)

+ type BinlogReader struct

+ func NewBinlogReader(tctx *tcontext.Context, cfg *BinlogReaderConfig) *BinlogReader

+ func (r *BinlogReader) Close()

+ func (r *BinlogReader) StartSync(pos mysql.Position) (Streamer, error)

+ type BinlogReaderConfig struct

+ RelayDir string

+ Timezone *time.Location

+ type FileCmp uint8

+ const FileCmpBigger

+ const FileCmpBiggerEqual

+ const FileCmpEqual

+ const FileCmpLess

+ const FileCmpLessEqual

+ type LocalStreamer struct

+ func (s *LocalStreamer) GetEvent(ctx context.Context) (*replication.BinlogEvent, error)

+ type ReaderHub struct

+ func GetReaderHub() *ReaderHub

+ func (h *ReaderHub) EarliestActiveRelayLog() *RelayLogInfo

+ func (h *ReaderHub) RemoveActiveRelayLog(taskName string)

+ func (h *ReaderHub) UpdateActiveRelayLog(taskName, uuid, filename string) error

+ type RelayLogInfo struct

+ Filename string

+ TaskName string

+ UUID string

+ UUIDSuffix int

+ func (info *RelayLogInfo) Earlier(other *RelayLogInfo) bool

+ func (info *RelayLogInfo) String() string

+ type Streamer interface

+ GetEvent func(ctx context.Context) (*replication.BinlogEvent, error)