bridge

Documentation

Index

• Variables
• type Bridge
  • func New(cfg *config.Config, ehFactory EventHandlerFactory, logger zerolog.Logger) (*Bridge, error)
  • func (b *Bridge) Close() error
  • func (b *Bridge) Delay() uint32
  • func (b *Bridge) Dumping() bool
  • func (b *Bridge) Run() error
  • func (b *Bridge) Running() bool
  • func (b *Bridge) WaitDumpDone() <-chan struct{}
• type EventHandlerFactory
  • func NewEventHandlerPluginFactory(pluginDir string) EventHandlerFactory
• type EventHandlerPluginFactory
  • func (f *EventHandlerPluginFactory) New(name, cfgPath string) (mymy.EventHandler, error)

Variables

var ErrRuleNotExist = errors.New("rule is not exist")

Types

type Bridge

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

func New

func New(cfg *config.Config, ehFactory EventHandlerFactory, logger zerolog.Logger) (*Bridge, error)

func (*Bridge) Close

func (b *Bridge) Close() error

func (*Bridge) Delay

func (b *Bridge) Delay() uint32

func (*Bridge) Dumping

func (b *Bridge) Dumping() bool

func (*Bridge) Run

func (b *Bridge) Run() error

Run syncs the data from MySQL and inserts to another MySQL until closed or meets errors.

func (*Bridge) Running

func (b *Bridge) Running() bool

func (*Bridge) WaitDumpDone

func (b *Bridge) WaitDumpDone() <-chan struct{}

type EventHandlerFactory

type EventHandlerFactory interface {
	New(name, cfgPath string) (mymy.EventHandler, error)
}

func NewEventHandlerPluginFactory

func NewEventHandlerPluginFactory(pluginDir string) EventHandlerFactory

type EventHandlerPluginFactory

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

func (*EventHandlerPluginFactory) New

func (f *EventHandlerPluginFactory) New(name, cfgPath string) (mymy.EventHandler, error)