clickhouse

Documentation

Index

• Variables
• func Escape(s string) string
• 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, timeout time.Duration) ([]byte, error)
• func ReadUvarint(array []byte) (uint64, int, error)
• 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 Post

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

func PostGzip

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

func Query

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

func ReadUvarint

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

Types

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