clickhouse

Documentation

Index

• Variables
• func Connect(cfg ClickHouseConfig) (*sqlx.DB, error)
• type ClickHouseConfig
• type Clusters

Variables

var Db *sqlx.DB

Functions

func Connect

func Connect(cfg ClickHouseConfig) (*sqlx.DB, error)

Types

type ClickHouseConfig

type ClickHouseConfig struct {
	Database            string `default:"flow_tag" yaml:"database"`
	Host                string `default:"clickhouse" yaml:"host"`
	Port                uint32 `default:"9000" yaml:"port"`
	UserName            string `default:"default" yaml:"user-name"`
	UserPassword        string `default:"" yaml:"user-password"`
	TimeOut             uint32 `default:"30" yaml:"timeout"`
	EndpointTcpPortName string `default:"tcp-port" yaml:"endpoint-tcp-port-name"`
}

type Clusters

type Clusters struct {
	HostAddress string `db:"host_address"`
	Port        uint16 `db:"port"`
}