relay

Documentation

Index

• type Reader
  • func NewReader(dir string, readBufferSize int) (Reader, error)
• type Relayer
  • func NewRelayer(dir string, maxFileSize int64, tableInfoGetter translator.TableInfoGetter) (Relayer, error)

Types

type Reader

type Reader interface {
	// Run reads relay log.
	Run() context.CancelFunc

	//  Binlogs returns the channel for reading parsed binlogs.
	Binlogs() <-chan *obinlog.Binlog

	// Close releases resources.
	Close() error

	// Error returns error occurs in reading.
	Error() <-chan error
}

Reader is the interface for reading relay log.

func NewReader

func NewReader(dir string, readBufferSize int) (Reader, error)

NewReader creates a relay reader.

type Relayer

type Relayer interface {
	// WriteBinlog writes binlog to relay log file.
	WriteBinlog(schema string, table string, tiBinlog *tb.Binlog, pv *tb.PrewriteValue) (tb.Pos, error)

	// GCBinlog removes unused relay log files.
	GCBinlog(pos tb.Pos)

	// Close releases resources.
	Close() error
}

Relayer is the interface for writing relay log.

func NewRelayer

func NewRelayer(dir string, maxFileSize int64, tableInfoGetter translator.TableInfoGetter) (Relayer, error)

NewRelayer creates a relayer.