internal

Documentation

Index

• func CreateRefreshableMaterializedView(ctx context.Context, client clickhouse.Conn, rmv Rmv) error
• func NewClickHouseClient(ctx context.Context, cfg Config) (driver.Conn, error)
• type Config
• type Rmv

Functions

func CreateRefreshableMaterializedView

func CreateRefreshableMaterializedView(ctx context.Context, client clickhouse.Conn, rmv Rmv) error

func NewClickHouseClient

func NewClickHouseClient(ctx context.Context, cfg Config) (driver.Conn, error)

Types

type Config

type Config struct {
	Host     string `env:"CLICKHOUSE_HOST,required"`
	Database string `env:"CLICKHOUSE_DB,required"`
	User     string `env:"CLICKHOUSE_USER,required"`
	Password string `env:"CLICKHOUSE_PASSWORD,required"`
}

type Rmv

type Rmv struct {
	Database        string
	TableName       string
	TableDefinition string
	SelectQuery     string
}