clickhouse

Documentation

Index

• func Connect(logger log.Logger, cfg config.Clickhouse, maxRetry int) (conn driver.Conn)
• func ProvideEmbeddedSourceDriver(logger log.Logger) source.Driver
• type Ch
  • func ProvideCh(logger log.Logger, cfg config.Clickhouse, source source.Driver) Ch

Functions

func Connect

func Connect(logger log.Logger, cfg config.Clickhouse, maxRetry int) (conn driver.Conn)

Connect connects to clickhouse and returns a driver.Conn. This function panics if `maxRetry` Connect attempt fails.

func ProvideEmbeddedSourceDriver

func ProvideEmbeddedSourceDriver(logger log.Logger) source.Driver

ProvideEmbeddedSourceDriver is a wire provider for golang-migrate source driver.

Types

type Ch

type Ch struct {
	driver.Conn
}

func ProvideCh

func ProvideCh(logger log.Logger, cfg config.Clickhouse, source source.Driver) Ch

ProvideCh define a wire provider for Ch.