clickhouse

Documentation

Index

• Variables
• func Escape(s string) string
• func HandleError(w http.ResponseWriter, err error)
• func NewErrDataParse(err string, data string) error
• 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 Query(ctx context.Context, dsn string, query string, opts Options) ([]byte, error)
• func QueryBytes(b []byte) string
• func QueryString(s string) string
• func ReadUvarint(array []byte) (uint64, int, error)
• func Reader(ctx context.Context, dsn string, query string, opts Options) (io.ReadCloser, error)
• type ErrDataParse
  • func (e *ErrDataParse) Error() string
  • func (e *ErrDataParse) PrependDescription(test string)
• type Options
• type TestHandler
  • func (h *TestHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type TestRequest
• type TestServer
  • func NewTestServer() *TestServer
  • func (srv *TestServer) Requests() []TestRequest

Variables

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")

Functions

func Escape

func Escape(s string) string

func HandleError

func HandleError(w http.ResponseWriter, err error)

func NewErrDataParse

func NewErrDataParse(err string, data string) error

func Post

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

func PostGzip

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

func Query

func Query(ctx context.Context, dsn string, query string, opts Options) ([]byte, error)

func QueryBytes

func QueryBytes(b []byte) string

func QueryString

func QueryString(s string) string

func ReadUvarint

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

func Reader

func Reader(ctx context.Context, dsn string, query string, opts Options) (io.ReadCloser, error)

Types

type ErrDataParse

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

func (*ErrDataParse) Error

func (e *ErrDataParse) Error() string

func (*ErrDataParse) PrependDescription

func (e *ErrDataParse) PrependDescription(test string)

type Options

type Options struct {
	Timeout        time.Duration
	ConnectTimeout time.Duration
}

type TestHandler

type TestHandler struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*TestHandler) ServeHTTP

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

type TestRequest

type TestRequest struct {
	Query []byte
}

type TestServer

type TestServer struct {
	*httptest.Server
	// contains filtered or unexported fields
}

func NewTestServer

func NewTestServer() *TestServer

func (*TestServer) Requests

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