clickhouseclient

README

Usage idiom:

	creds := func(c *clickhouseclient.Creds) {
		c.Urls = []string{ENV_HOST + ":" + ENV_PORT}
		c.User = ENV_USER
		c.Password = ENV_PASSWORD
		c.Database = ENV_DATABASE
	}

	err := clickhouseclient.Exec(boot.Context, creds, clickhouseclient.SQL(`
		SHOW ${x}
	`, func(s string) string {
		switch s {
		case "x":
			return "TABLES"
		}
		return ""
	}))
	controlflow.Checkerr(err)

Documentation

Index

• func Exec(ctx context.Context, optsF func(c *Creds), prg *Program) (err error)
• type Creds
• type Program
  • func SQL(prgText string, replacerF func(s string) string) *Program
• type Statistics
  • func (s *Statistics) Humanize()
  • func (s *Statistics) JSON() string

Functions

func Exec

func Exec(ctx context.Context, optsF func(c *Creds), prg *Program) (err error)

Types

type Creds

type Creds struct {
	Urls        []string
	Port        string
	Database    string
	User        string
	Password    string
	MaxExecTime time.Duration
}

type Program

type Program string

func SQL

func SQL(prgText string, replacerF func(s string) string) *Program

type Statistics

type Statistics struct {
	Status  string
	Elapsed string
	Read    struct {
		Rows      string
		Bytes     string
		RowsRate  string
		BytesRate string
	}
	Write struct {
		Rows      string
		Bytes     string
		RowsRate  string
		BytesRate string
	}
	// contains filtered or unexported fields
}

func (*Statistics) Humanize

func (s *Statistics) Humanize()

func (*Statistics) JSON

func (s *Statistics) JSON() string