clickhouse

Documentation

Index

• Variables
• func HandleError(w http.ResponseWriter, err error)
• func NewErrDataParse(err string, data string) error
• func NewErrorWithCode(err string, code int) 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 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 ErrorWithCode
  • func (e *ErrorWithCode) Error() 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 HandleError

func HandleError(w http.ResponseWriter, err error)

func NewErrDataParse

func NewErrDataParse(err string, data string) error

func NewErrorWithCode

func NewErrorWithCode(err string, code int) 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 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 ErrorWithCode

type ErrorWithCode struct {
	Code int // error code
	// contains filtered or unexported fields
}

func (*ErrorWithCode) Error

func (e *ErrorWithCode) Error() 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