replicator

Documentation

Index

• type Replicator
  • func New(cfg config.Config) *Replicator
  • func (r *Replicator) GenerateChDDL() error
  • func (r *Replicator) HandleMessage(lsn utils.LSN, msg message.Message) error
  • func (r *Replicator) Run() error

Types

type Replicator

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

func New

func New(cfg config.Config) *Replicator

func (*Replicator) GenerateChDDL

func (r *Replicator) GenerateChDDL() error

GenerateChDDL generates clickhouse table DDLs TODO: refactor me

func (*Replicator) HandleMessage

func (r *Replicator) HandleMessage(lsn utils.LSN, msg message.Message) error

HandleMessage processes the incoming wal message

func (*Replicator) Run

func (r *Replicator) Run() error