ofsync

Documentation

Index

• type MySQL2ClickHouse
  • func (c *MySQL2ClickHouse) Run() (map[string]string, error)
  • func (c *MySQL2ClickHouse) Stop() error
• type OfSync
  • func Creator(iid int, nodeId int, content string) (OfSync, error)

Types

type MySQL2ClickHouse

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

func (*MySQL2ClickHouse) Run

func (c *MySQL2ClickHouse) Run() (map[string]string, error)

Run MaterializeMySQL CREATE DATABASE [IF NOT EXISTS] db_name [ON CLUSTER cluster] ENGINE = MySQL('host:port', 'database', 'user', 'password') 会产生一个冗余表

CREATE DATABASE [IF NOT EXISTS] db_name [ON CLUSTER cluster] ENGINE = MaterializeMySQL('host:port', 'database', 'user', 'password') [SETTINGS...]

where SETTINGS are: [ { include_tables | exclude_tables } ] [ skip_error_count ] [ skip_unsupported_tables ] [ order_by_only_primary_key ] [ enable_binlog_reserved ] [ shard_model ] [ rate_limiter_row_count_per_second ]

func (*MySQL2ClickHouse) Stop

func (c *MySQL2ClickHouse) Stop() error

type OfSync

type OfSync interface {
	Run() (map[string]string, error)
	Stop() error
}

func Creator

func Creator(iid int, nodeId int, content string) (OfSync, error)