ch

package

v1.17.9 Latest Latest Go to latest Published: Jan 13, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Details

View Source

const (
	ProtocolCoroot = "coroot"
)

This section is empty.

func GetConfigFromRemoteCoroot(cfg *db.IntegrationClickhouse) (*db.IntegrationClickhouse, error)

func ReplaceTables(query string, distributed bool) string

type ClickHouseInfo struct {
	Name  string
	Cloud bool
}

func (ci ClickHouseInfo) UseDistributed() bool

type Dialer struct {
	// contains filtered or unexported fields
}

func GetRemoteCorootDialer(cfg *db.IntegrationClickhouse) *Dialer

func (d *Dialer) Dial(ctx context.Context, address string) (net.Conn, error)

func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

type LowLevelClient struct {
	// contains filtered or unexported fields
}

func NewLowLevelClient(ctx context.Context, cfg *db.IntegrationClickhouse) (*LowLevelClient, error)

func (c *LowLevelClient) Close()

func (c *LowLevelClient) CreateDB(ctx context.Context, name string) error

func (c *LowLevelClient) Do(ctx context.Context, q ch.Query) (err error)

func (c *LowLevelClient) Exec(ctx context.Context, query string) error

func (c *LowLevelClient) GetInfo() (ClickHouseInfo, error)

func (c *LowLevelClient) Migrate(ctx context.Context, cfg config.CollectorConfig) error