mariadb

Documentation

Index

• type MariaDBEventHandler
  • func (h *MariaDBEventHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, gs mysql.GTIDSet, ...) error
  • func (h *MariaDBEventHandler) OnRow(e *canal.RowsEvent) error
  • func (h *MariaDBEventHandler) String() string
• type MariaDBSyncer
  • func NewMariaDBSyncer(cfg config.SyncConfig, logger *logrus.Logger) *MariaDBSyncer
  • func (s *MariaDBSyncer) Start(ctx context.Context)

Types

type MariaDBEventHandler

type MariaDBEventHandler struct {
	canal.DummyEventHandler
	// contains filtered or unexported fields
}

func (*MariaDBEventHandler) OnPosSynced

func (h *MariaDBEventHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, gs mysql.GTIDSet, force bool) error

OnPosSynced does not write positions here; we use the timer approach instead

func (*MariaDBEventHandler) OnRow

func (h *MariaDBEventHandler) OnRow(e *canal.RowsEvent) error

func (*MariaDBEventHandler) String

func (h *MariaDBEventHandler) String() string

type MariaDBSyncer

type MariaDBSyncer struct {
	// contains filtered or unexported fields
}

MariaDBSyncer is the structure for MariaDB synchronization

func NewMariaDBSyncer

func NewMariaDBSyncer(cfg config.SyncConfig, logger *logrus.Logger) *MariaDBSyncer

func (*MariaDBSyncer) Start

func (s *MariaDBSyncer) Start(ctx context.Context)