ch

Documentation

Index

• func ReplaceTables(query string, distributed bool) string
• type ClickHouseInfo
  • func (ci ClickHouseInfo) UseDistributed() bool
• type LowLevelClient
  • 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

Functions

func ReplaceTables

func ReplaceTables(query string, distributed bool) string

Types

type ClickHouseInfo

type ClickHouseInfo struct {
	Name  string
	Cloud bool
}

func (ClickHouseInfo) UseDistributed

func (ci ClickHouseInfo) UseDistributed() bool

type LowLevelClient

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

func NewLowLevelClient

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

func (*LowLevelClient) Close

func (c *LowLevelClient) Close()

func (*LowLevelClient) CreateDB

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

func (*LowLevelClient) Do

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

func (*LowLevelClient) Exec

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

func (*LowLevelClient) GetInfo

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

func (*LowLevelClient) Migrate

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