binary

package

v1.3.11 Latest Latest Go to latest Published: Aug 7, 2019 License: MIT Imports: 8 Imported by: 0

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/kshvakov/clickhouse

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewCompressReader(r io.Reader) *compressReader
func NewCompressWriter(w io.Writer) *compressWriter
func Str2Bytes(str string) []byte
type CompressionMethodByte
type Decoder
- func NewDecoder(input io.Reader) *Decoder
type Encoder
- func NewEncoder(w io.Writer) *Encoder
type FixedReader
type WriteFlusher

Constants ¶

View Source

const (
	NONE CompressionMethodByte = 0x02
	LZ4                        = 0x82
	ZSTD                       = 0x90
)

View Source

const (
	// ChecksumSize is 128bits for cityhash102 checksum
	ChecksumSize = 16
	// CompressHeader magic + compressed_size + uncompressed_size
	CompressHeaderSize = 1 + 4 + 4

	// HeaderSize
	HeaderSize = ChecksumSize + CompressHeaderSize
	// BlockMaxSize 1MB
	BlockMaxSize = 1 << 10
)

Variables ¶

This section is empty.

Functions ¶

func NewCompressReader ¶ added in v1.3.6

func NewCompressReader(r io.Reader) *compressReader

NewCompressReader wrap the io.Reader

func NewCompressWriter ¶ added in v1.3.6

func NewCompressWriter(w io.Writer) *compressWriter

NewCompressWriter wrap the io.Writer

func Str2Bytes ¶

func Str2Bytes(str string) []byte

Types ¶

type CompressionMethodByte ¶ added in v1.3.6

type CompressionMethodByte byte

type Decoder ¶

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

func NewDecoder ¶

func NewDecoder(input io.Reader) *Decoder

func (*Decoder) Bool ¶

func (decoder *Decoder) Bool() (bool, error)

func (*Decoder) Fixed ¶

func (decoder *Decoder) Fixed(ln int) ([]byte, error)

func (*Decoder) Float32 ¶

func (decoder *Decoder) Float32() (float32, error)

func (*Decoder) Float64 ¶

func (decoder *Decoder) Float64() (float64, error)

func (*Decoder) Get ¶ added in v1.3.6

func (decoder *Decoder) Get() io.Reader

func (*Decoder) Int16 ¶

func (decoder *Decoder) Int16() (int16, error)

func (*Decoder) Int32 ¶

func (decoder *Decoder) Int32() (int32, error)

func (*Decoder) Int64 ¶

func (decoder *Decoder) Int64() (int64, error)

func (*Decoder) Int8 ¶

func (decoder *Decoder) Int8() (int8, error)

func (*Decoder) ReadByte ¶

func (decoder *Decoder) ReadByte() (byte, error)

func (*Decoder) SelectCompress ¶ added in v1.3.6

func (decoder *Decoder) SelectCompress(compress bool)

func (*Decoder) String ¶

func (decoder *Decoder) String() (string, error)

func (*Decoder) UInt16 ¶

func (decoder *Decoder) UInt16() (uint16, error)

func (*Decoder) UInt32 ¶

func (decoder *Decoder) UInt32() (uint32, error)

func (*Decoder) UInt64 ¶

func (decoder *Decoder) UInt64() (uint64, error)

func (*Decoder) UInt8 ¶

func (decoder *Decoder) UInt8() (uint8, error)

func (*Decoder) Uvarint ¶

func (decoder *Decoder) Uvarint() (uint64, error)

type Encoder ¶

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

func NewEncoder ¶

func NewEncoder(w io.Writer) *Encoder

func (*Encoder) Bool ¶

func (enc *Encoder) Bool(v bool) error

func (*Encoder) Float32 ¶

func (enc *Encoder) Float32(v float32) error

func (*Encoder) Float64 ¶

func (enc *Encoder) Float64(v float64) error

func (*Encoder) Flush ¶ added in v1.3.6

func (enc *Encoder) Flush() error

func (*Encoder) Get ¶ added in v1.3.6

func (enc *Encoder) Get() io.Writer

func (*Encoder) Int16 ¶

func (enc *Encoder) Int16(v int16) error

func (*Encoder) Int32 ¶

func (enc *Encoder) Int32(v int32) error

func (*Encoder) Int64 ¶

func (enc *Encoder) Int64(v int64) error

func (*Encoder) Int8 ¶

func (enc *Encoder) Int8(v int8) error

func (*Encoder) RawString ¶

func (enc *Encoder) RawString(str []byte) error

func (*Encoder) SelectCompress ¶ added in v1.3.6

func (enc *Encoder) SelectCompress(compress bool)

func (*Encoder) String ¶

func (enc *Encoder) String(v string) error

func (*Encoder) UInt16 ¶

func (enc *Encoder) UInt16(v uint16) error

func (*Encoder) UInt32 ¶

func (enc *Encoder) UInt32(v uint32) error

func (*Encoder) UInt64 ¶

func (enc *Encoder) UInt64(v uint64) error

func (*Encoder) UInt8 ¶

func (enc *Encoder) UInt8(v uint8) error

func (*Encoder) Uvarint ¶

func (enc *Encoder) Uvarint(v uint64) error

func (*Encoder) Write ¶

func (enc *Encoder) Write(b []byte) (int, error)

type FixedReader ¶

type FixedReader interface {
	Fixed(ln int) ([]byte, error)
}

type WriteFlusher ¶ added in v1.3.6

type WriteFlusher interface {
	Flush() error
}

Source Files ¶

View all Source files

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