clickhouse

Documentation

Overview

Package clickhouse contains wire provider for clickhouse connection and migration.

Index

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

Functions

func Connect

func Connect(logger zerolog.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 zerolog.Logger) source.Driver

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

Types

type Ch

type Ch struct {
	driver.Conn
}

Ch define a connection to a ClickHouse instance.

func ProvideCh

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

ProvideCh define a wire provider for Ch.