Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2019 Changes in this version + func ConvertColumn(w utils.Writer, column *config.PgColumn, tupleData *message.Tuple, ...) error + func ToClickHouseType(pgColumn *config.PgColumn) (string, error) + type CHConn struct + func MakeChConnection(c *config.CHConnConfig, useGzip bool) *CHConn + func (c *CHConn) Exec(query string) error + func (c *CHConn) PerformInsert(tableName config.ChTableName, columns []string, reqBody io.Reader) error + func (c *CHConn) Query(query string) ([][]string, error) + type CHConnector interface + Exec func(string) error + PerformInsert func(config.ChTableName, []string, io.Reader) error + Query func(string) ([][]string, error)
Go to main page