clickhouse

Nov 18, 2022

Changes in this version

+ var ErrInvalidTimeRange = errors.New("Invalid or empty time range")

+ func NewErrWithDescr(err string, data string) error

+ type ErrWithDescr struct

+ func (e *ErrWithDescr) Error() string

+ func (e *ErrWithDescr) PrependDescription(test string)

+ type LoggedReader struct

+ func (r *LoggedReader) ChReadBytes() int64

+ func (r *LoggedReader) ChReadRows() int64

+ func (r *LoggedReader) Close() error

+ func (r *LoggedReader) Read(p []byte) (int, error)

Jun 21, 2021

Changes in this version

+ type Column struct

+ Name string

+ Type string

+ func (c *Column) String() string

+ type ExternalData struct

+ Tables []ExternalTable

+ func NewExternalData(tables ...ExternalTable) *ExternalData

+ func (e *ExternalData) SetDebug(debugDir string, perm os.FileMode)

+ type ExternalTable struct

+ Columns []Column

+ Data []byte

+ Format string

+ Name string

Oct 12, 2020

Changes in this version

+ func NewErrorWithCode(err string, code int) error

+ type ErrorWithCode struct

+ Code int

+ func (e *ErrorWithCode) Error() string

Jul 14, 2019

Changes in this version

+ func HandleError(w http.ResponseWriter, err error)

+ func NewErrDataParse(err string, data string) error

+ func QueryBytes(b []byte) string

+ func QueryString(s string) string

+ type ErrDataParse struct

+ func (e *ErrDataParse) Error() string

+ func (e *ErrDataParse) PrependDescription(test string)

Sep 13, 2018

Changes in this version

+ type Options struct

+ ConnectTimeout time.Duration

+ Timeout time.Duration

Mar 5, 2018

Changes in this version

+ func Reader(ctx context.Context, dsn string, query string, timeout time.Duration) (io.ReadCloser, error)

Jan 11, 2017

Changes in this version

+ var ErrClickHouseResponse = errors.New("Malformed response from clickhouse")

+ var ErrUvarintOverflow = errors.New("ReadUvarint: varint overflows a 64-bit integer")

+ var ErrUvarintRead = errors.New("ReadUvarint: Malformed array")

+ func Post(ctx context.Context, dsn string, query string, postBody io.Reader, ...) ([]byte, error)

+ func PostGzip(ctx context.Context, dsn string, query string, postBody io.Reader, ...) ([]byte, error)

+ func ReadUvarint(array []byte) (uint64, int, error)

+ type TestHandler struct

+ func (h *TestHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type TestRequest struct

+ Query []byte

+ type TestServer struct

+ func NewTestServer() *TestServer

+ func (srv *TestServer) Requests() []TestRequest

Dec 15, 2016

Changes in this version

+ func Escape(s string) string

+ func Query(ctx context.Context, dsn string, query string, timeout time.Duration) (body []byte, err error)