clickhouse

package

v0.13.4 Latest Latest Go to latest Published: Nov 18, 2022 License: MIT Imports: 23 Imported by: 9

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/lomik/graphite-clickhouse

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func HandleError(w http.ResponseWriter, err error) (status int)
func NewErrWithDescr(err string, data string) error
func Post(ctx context.Context, dsn string, query string, postBody io.Reader, ...) ([]byte, int64, int64, error)
func PostGzip(ctx context.Context, dsn string, query string, postBody io.Reader, ...) ([]byte, int64, int64, error)
func Query(ctx context.Context, dsn string, query string, opts Options, ...) ([]byte, int64, int64, error)
func ReadUvarint(array []byte) (uint64, int, error)
type Column
- func (c *Column) String() string
type ErrWithDescr
- func (e *ErrWithDescr) Error() string
- func (e *ErrWithDescr) PrependDescription(test string)
type ExternalData
- func NewExternalData(tables ...ExternalTable) *ExternalData
- func (e *ExternalData) SetDebug(debugDir string, perm os.FileMode)
type ExternalTable
type LoggedReader
- func Reader(ctx context.Context, dsn string, query string, opts Options, ...) (*LoggedReader, error)
type Options

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

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

View Source

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

View Source

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

Functions ¶

func HandleError ¶ added in v0.11.6

func HandleError(w http.ResponseWriter, err error) (status int)

func NewErrWithDescr ¶ added in v0.13.4

func NewErrWithDescr(err string, data string) error

func Post ¶ added in v0.3.0

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

func PostGzip ¶ added in v0.3.0

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

func Query ¶

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

func ReadUvarint ¶ added in v0.3.0

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

Types ¶

type Column ¶ added in v0.13.0

type Column struct {
	Name string
	// ClickHouse data type
	Type string
}

Column is a pair of Name and Type for temporary table structure

func (*Column) String ¶ added in v0.13.0

func (c *Column) String() string

type ErrWithDescr ¶ added in v0.13.4

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

func (*ErrWithDescr) Error ¶ added in v0.13.4

func (e *ErrWithDescr) Error() string

func (*ErrWithDescr) PrependDescription ¶ added in v0.13.4

func (e *ErrWithDescr) PrependDescription(test string)

type ExternalData ¶ added in v0.13.0

type ExternalData struct {
	Tables []ExternalTable
	// contains filtered or unexported fields
}

ExternalData is a type to use ClickHouse external data feature. You could use it to pass multiple temporary tables for a query.

func NewExternalData ¶ added in v0.13.0

func NewExternalData(tables ...ExternalTable) *ExternalData

NewExternalData returns the `*ExternalData` object for `tables`

func (*ExternalData) SetDebug ¶ added in v0.13.0

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

SetDebug sets the directory and file permission for an external table data dump. Works only if both `debugDir` and `perm` are set

type ExternalTable ¶ added in v0.13.0

type ExternalTable struct {
	// Table name
	Name    string
	Columns []Column
	// ClickHouse input/output format
	Format string
	Data   []byte
}

ExternalTable is a structure to use ClickHouse feature that creates a temporary table for a query

type LoggedReader ¶ added in v0.13.4

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

func Reader ¶ added in v0.6.2

func Reader(ctx context.Context, dsn string, query string, opts Options, extData *ExternalData) (*LoggedReader, error)

func (*LoggedReader) ChReadBytes ¶ added in v0.13.4

func (r *LoggedReader) ChReadBytes() int64

func (*LoggedReader) ChReadRows ¶ added in v0.13.4

func (r *LoggedReader) ChReadRows() int64

func (*LoggedReader) Close ¶ added in v0.13.4

func (r *LoggedReader) Close() error

func (*LoggedReader) Read ¶ added in v0.13.4

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

type Options ¶ added in v0.7.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL