Documentation ¶
Index ¶
- func ConnectNative(host string, cfg ConnParams, hosts ...string) (*sql.DB, error)
- func GetClickhouseOptions(cfg ConnParams, hosts []string) (*clickhouse.Options, error)
- func NewTLS(config ConnParams) (*tls.Config, error)
- func ResolveShards(config model.ChSinkParams, transfer *dp_model.Transfer) error
- type ConnParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConnectNative ¶
func GetClickhouseOptions ¶
func GetClickhouseOptions(cfg ConnParams, hosts []string) (*clickhouse.Options, error)
func ResolveShards ¶
func ResolveShards(config model.ChSinkParams, transfer *dp_model.Transfer) error
Types ¶
Click to show internal directories.
Click to hide internal directories.