clickhouse

Documentation

Index

• type ClickhouseConfig
• type ClickhouseConnector
  • func NewClickhouseConnector(cfg ClickhouseConfig) (*ClickhouseConnector, error)
  • func (conn *ClickhouseConnector) GetNativeConn() driver.Conn
• type DBConnector
  • func NewClickhouseDBConnector(cfg ClickhouseConfig) (*DBConnector, error)
  • func NewMockedClickHouseConnector(conn *sql.DB) *DBConnector

Types

type ClickhouseConfig

type ClickhouseConfig struct {
	Host            string
	Port            int
	UserName        string
	Password        string
	DBName          string
	ConnectTimeout  time.Duration
	MaxIdleConns    int
	MaxOpenConns    int
	ConnMaxLifetime time.Duration
}

type ClickhouseConnector

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

ConnectionConnector return driver.Conn

func NewClickhouseConnector

func NewClickhouseConnector(cfg ClickhouseConfig) (*ClickhouseConnector, error)

func (*ClickhouseConnector) GetNativeConn

func (conn *ClickhouseConnector) GetNativeConn() driver.Conn

type DBConnector

type DBConnector struct {
	DBConn *sql.DB
}

DBConnector to return db connection

func NewClickhouseDBConnector

func NewClickhouseDBConnector(cfg ClickhouseConfig) (*DBConnector, error)

func NewMockedClickHouseConnector

func NewMockedClickHouseConnector(conn *sql.DB) *DBConnector

NewMockedClickHouseConnector return mockclient with setting client to given connection its expected to provide mocked conn while calling this api