core

Documentation

Index

• type CanalOption
• type ReplicationDMLHandler
• type ReplicationMessage
• type ReplicationSyncer
  • func NewReplicationSyncer(canalOption CanalOption, dmlHandler ReplicationDMLHandler) *ReplicationSyncer
  • func (t *ReplicationSyncer) Start() error

Types

type CanalOption

type CanalOption struct {
	Host        string
	Port        int
	Username    string
	Password    string
	Destination string
	SoTimOut    int32
	IdleTimeOut int32
	Filter      string
	BatchSize   int32
}

type ReplicationDMLHandler

type ReplicationDMLHandler func(msg ReplicationMessage)

type ReplicationMessage

type ReplicationMessage struct {
	LogfileName   string
	LogfileOffset int64
	SchemaName    string
	TableName     string
	EventType     entry.EventType
	Body          map[string]interface{}
	Columns       []string // the column about updated
}

type ReplicationSyncer

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

func NewReplicationSyncer

func NewReplicationSyncer(canalOption CanalOption, dmlHandler ReplicationDMLHandler) *ReplicationSyncer

func (*ReplicationSyncer) Start

func (t *ReplicationSyncer) Start() error