Documentation ¶
Index ¶
- Variables
- type Canal
- type Instance
- func (ins *Instance) Check(ev *canal.RowsEvent) (ts []*Target)
- func (ins *Instance) Close()
- func (ins *Instance) Error() string
- func (ins *Instance) OnDDL(pos mysql.Position, qe *replication.QueryEvent) error
- func (ins *Instance) OnGTID(set mysql.GTIDSet) error
- func (ins *Instance) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error
- func (ins *Instance) OnRotate(re *replication.RotateEvent) error
- func (ins *Instance) OnRow(ev *canal.RowsEvent) error
- func (ins *Instance) OnTableChanged(schema string, table string) error
- func (ins *Instance) OnXID(pos mysql.Position) error
- func (ins *Instance) Start()
- func (ins *Instance) String() string
- type Target
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewCanal)
ProviderSet is service providers.
Functions ¶
This section is empty.
Types ¶
type Canal ¶
type Canal struct {
// contains filtered or unexported fields
}
Canal is canal.
func NewCanal ¶
func NewCanal(config *conf.Canal, ev *conf.CanalEv, logger zapcore.Core) (c *Canal, cf func(), err error)
NewCanal load config and start canal instance.
func (*Canal) CheckMaster ¶
CheckMaster check master status.
type Instance ¶
Instance canal instance
func NewInstance ¶
NewInstance new canal instance
func (*Instance) OnDDL ¶
func (ins *Instance) OnDDL(pos mysql.Position, qe *replication.QueryEvent) error
OnDDL OnDDL
func (*Instance) OnPosSynced ¶
OnPosSynced OnPosSynced
func (*Instance) OnRotate ¶
func (ins *Instance) OnRotate(re *replication.RotateEvent) error
OnRotate OnRotate
func (*Instance) OnTableChanged ¶
Click to show internal directories.
Click to hide internal directories.