replication

Documentation

Index

• func ConnectClickHouse() *sql.DB
• func GetStatus() string
• func InsertDataToClickHouse(data []interface{}, dbConfig config.DBConfig)
• func MySQLConnector(name string, host string, port int, user string, password string) (*sql.DB, error)
• func MySQLReplicationService(name string, host string, port int, user string, password string, ...) error
• func MySQLStartReplicator(name string, host string, port uint16, user string, password string) error
• func ReplicationInit(dbType string, dbConfig config.DBConfig) error
• func StartReplication(dbType string, dbAlias string)
• func StopReplication()
• type ReplicationService

Functions

func ConnectClickHouse

func ConnectClickHouse() *sql.DB

func GetStatus

func GetStatus() string

func InsertDataToClickHouse

func InsertDataToClickHouse(data []interface{}, dbConfig config.DBConfig)

func MySQLConnector

func MySQLConnector(name string, host string, port int, user string, password string) (*sql.DB, error)

func MySQLReplicationService

func MySQLReplicationService(name string, host string, port int, user string, password string, dbName string, stop chan struct{}) error

Start starts the MySQL replication service.

func MySQLStartReplicator

func MySQLStartReplicator(name string, host string, port uint16, user string, password string) error

func ReplicationInit

func ReplicationInit(dbType string, dbConfig config.DBConfig) error

ReplicationService simulates replication service with database credentials

func StartReplication

func StartReplication(dbType string, dbAlias string)

func StopReplication

func StopReplication()

Types

type ReplicationService

type ReplicationService interface {
	Start() error
	Stop() error
}

ReplicationService is the interface for replication services.