proto

package

Go to main page

Versions in this module

v0

v0.39.0

Jun 3, 2022

Changes in this version

+ type ColDateTime64Auto struct

+ Precision Precision

+ func (c ColDateTime64Auto) Append(v time.Time)

+ func (c ColDateTime64Auto) AppendArr(v []time.Time)

+ func (c ColDateTime64Auto) Row(i int) time.Time

v0.38.0

May 25, 2022

Changes in this version

+ type ColNullableOf struct

+ Nulls ColUInt8

+ Values ColumnOf[T]

+ func (c *ColNullableOf[T]) Append(v Nullable[T])

+ func (c *ColNullableOf[T]) AppendArr(v []Nullable[T])

+ func (c *ColNullableOf[T]) DecodeColumn(r *Reader, rows int) error

+ func (c *ColNullableOf[T]) DecodeState(r *Reader) error

+ func (c *ColNullableOf[T]) Reset()

+ func (c ColNullableOf[T]) EncodeColumn(b *Buffer)

+ func (c ColNullableOf[T]) EncodeState(b *Buffer)

+ func (c ColNullableOf[T]) IsElemNull(i int) bool

+ func (c ColNullableOf[T]) Row(i int) Nullable[T]

+ func (c ColNullableOf[T]) Rows() int

+ func (c ColNullableOf[T]) Type() ColumnType

+ type ColPoint struct

+ X ColFloat64

+ Y ColFloat64

+ func (c *ColPoint) Append(v Point)

+ func (c *ColPoint) AppendArr(v []Point)

+ func (c *ColPoint) DecodeColumn(r *Reader, rows int) error

+ func (c *ColPoint) Reset()

+ func (c ColPoint) EncodeColumn(b *Buffer)

+ func (c ColPoint) Row(i int) Point

+ func (c ColPoint) Rows() int

+ func (c ColPoint) Type() ColumnType

type ColumnType

+ const ColumnTypePoint

+ type Nullable struct

+ Set bool

+ Value T

+ func NewNullable(v T) Nullable[T]

+ func Null() Nullable[T]

+ func (n Nullable[T]) IsSet() bool

+ func (n Nullable[T]) Or(v T) T

+ type Point struct

+ X float64

+ Y float64

v0.37.0

May 25, 2022

v0.36.1

May 24, 2022

v0.36.0

May 24, 2022

v0.35.0

May 24, 2022

v0.34.0

May 24, 2022

v0.33.0

May 24, 2022

Changes in this version

type ColMapOf

+ func (c *ColMapOf[K, V]) Append(v map[K]V)

+ func (c *ColMapOf[K, V]) AppendArr(v []map[K]V)

+ func (c *ColMapOf[K, V]) DecodeState(r *Reader) error

+ func (c ColMapOf[K, V]) EncodeState(b *Buffer)

+ func (c ColMapOf[K, V]) Row(i int) map[K]V

v0.32.0

May 16, 2022

Changes in this version

type ColUUID

+ func (c *ColUUID) Append(v uuid.UUID)

+ func (c *ColUUID) AppendArr(v []uuid.UUID)

+ func (c ColUUID) Row(i int) uuid.UUID

v0.31.0

May 2, 2022

Changes in this version

type ColAuto

+ DataType ColumnType

v0.30.0

Apr 28, 2022

Changes in this version

type ColBytes

+ func (c *ColBytes) Array() *ColArrOf[[]byte]

type ColDate

+ func (c *ColDate) Array() *ColArrOf[Date]

type ColDate32

+ func (c *ColDate32) Array() *ColArrOf[Date32]

type ColDateTime

+ func (c *ColDateTime) Array() *ColArrOf[DateTime]

type ColDateTime64

+ func (c *ColDateTime64) Array() *ColArrOf[DateTime64]

type ColDecimal128

+ func (c *ColDecimal128) Array() *ColArrOf[Decimal128]

type ColDecimal256

+ func (c *ColDecimal256) Array() *ColArrOf[Decimal256]

type ColDecimal32

+ func (c *ColDecimal32) Array() *ColArrOf[Decimal32]

type ColDecimal64

+ func (c *ColDecimal64) Array() *ColArrOf[Decimal64]

type ColEnum16

+ func (c *ColEnum16) Array() *ColArrOf[Enum16]

type ColEnum8

+ func (c *ColEnum8) Array() *ColArrOf[Enum8]

type ColFloat32

+ func (c *ColFloat32) Array() *ColArrOf[float32]

type ColFloat64

+ func (c *ColFloat64) Array() *ColArrOf[float64]

type ColIPv4

+ func (c *ColIPv4) Array() *ColArrOf[IPv4]

type ColIPv6

+ func (c *ColIPv6) Array() *ColArrOf[IPv6]

type ColInt128

+ func (c *ColInt128) Array() *ColArrOf[Int128]

type ColInt16

+ func (c *ColInt16) Array() *ColArrOf[int16]

type ColInt256

+ func (c *ColInt256) Array() *ColArrOf[Int256]

type ColInt32

+ func (c *ColInt32) Array() *ColArrOf[int32]

type ColInt64

+ func (c *ColInt64) Array() *ColArrOf[int64]

type ColInt8

+ func (c *ColInt8) Array() *ColArrOf[int8]

+ type ColRawOf []X — darwin/amd64, linux/amd64, windows/amd64

+ func (c *ColRawOf[X]) Append(v X)

+ func (c *ColRawOf[X]) AppendArr(v []X)

+ func (c *ColRawOf[X]) DecodeColumn(r *Reader, rows int) error

+ func (c *ColRawOf[X]) Reset()

+ func (c ColRawOf[X]) EncodeColumn(b *Buffer)

+ func (c ColRawOf[X]) Row(i int) X

+ func (c ColRawOf[X]) Rows() int

+ func (c ColRawOf[X]) Size() int

+ func (c ColRawOf[X]) Type() ColumnType

type ColUInt128

+ func (c *ColUInt128) Array() *ColArrOf[UInt128]

type ColUInt16

+ func (c *ColUInt16) Array() *ColArrOf[uint16]

type ColUInt256

+ func (c *ColUInt256) Array() *ColArrOf[UInt256]

type ColUInt32

+ func (c *ColUInt32) Array() *ColArrOf[uint32]

type ColUInt64

+ func (c *ColUInt64) Array() *ColArrOf[uint64]

type ColUInt8

+ func (c *ColUInt8) Array() *ColArrOf[uint8]

v0.29.1

Apr 19, 2022

Changes in this version

type ColArrOf

+ func (c *ColArrOf[T]) Prepare() error

v0.29.0

Apr 18, 2022

Changes in this version

+ type ColBytes struct

+ func (c *ColBytes) Append(v []byte)

+ func (c *ColBytes) AppendArr(v [][]byte)

+ func (c ColBytes) Row(i int) []byte

type ColStr

+ func (c ColStr) RowBytes(i int) []byte

v0.28.1

Apr 17, 2022

Changes in this version

type ColArrOf

+ func (c *ColArrOf[T]) DecodeState(r *Reader) error

+ func (c *ColArrOf[T]) EncodeState(b *Buffer)

v0.28.0

Apr 17, 2022

Changes in this version

type ColDate

+ func (c *ColDate) AppendArr(v []Date)

+ func (c *ColDate) LowCardinality() *ColLowCardinalityOf[Date]

type ColDate32

+ func (c *ColDate32) AppendArr(v []Date32)

+ func (c *ColDate32) LowCardinality() *ColLowCardinalityOf[Date32]

type ColDateTime

+ func (c *ColDateTime) AppendArr(v []DateTime)

+ func (c *ColDateTime) LowCardinality() *ColLowCardinalityOf[DateTime]

type ColDateTime64

+ func (c *ColDateTime64) AppendArr(v []DateTime64)

+ func (c *ColDateTime64) LowCardinality() *ColLowCardinalityOf[DateTime64]

type ColDecimal128

+ func (c *ColDecimal128) AppendArr(v []Decimal128)

+ func (c *ColDecimal128) LowCardinality() *ColLowCardinalityOf[Decimal128]

type ColDecimal256

+ func (c *ColDecimal256) AppendArr(v []Decimal256)

+ func (c *ColDecimal256) LowCardinality() *ColLowCardinalityOf[Decimal256]

type ColDecimal32

+ func (c *ColDecimal32) AppendArr(v []Decimal32)

+ func (c *ColDecimal32) LowCardinality() *ColLowCardinalityOf[Decimal32]

type ColDecimal64

+ func (c *ColDecimal64) AppendArr(v []Decimal64)

+ func (c *ColDecimal64) LowCardinality() *ColLowCardinalityOf[Decimal64]

type ColEnum16

+ func (c *ColEnum16) AppendArr(v []Enum16)

+ func (c *ColEnum16) LowCardinality() *ColLowCardinalityOf[Enum16]

type ColEnum8

+ func (c *ColEnum8) AppendArr(v []Enum8)

+ func (c *ColEnum8) LowCardinality() *ColLowCardinalityOf[Enum8]

type ColFloat32

+ func (c *ColFloat32) AppendArr(v []float32)

+ func (c *ColFloat32) LowCardinality() *ColLowCardinalityOf[float32]

type ColFloat64

+ func (c *ColFloat64) AppendArr(v []float64)

+ func (c *ColFloat64) LowCardinality() *ColLowCardinalityOf[float64]

type ColIPv4

+ func (c *ColIPv4) AppendArr(v []IPv4)

+ func (c *ColIPv4) LowCardinality() *ColLowCardinalityOf[IPv4]

type ColIPv6

+ func (c *ColIPv6) AppendArr(v []IPv6)

+ func (c *ColIPv6) LowCardinality() *ColLowCardinalityOf[IPv6]

type ColInt128

+ func (c *ColInt128) AppendArr(v []Int128)

+ func (c *ColInt128) LowCardinality() *ColLowCardinalityOf[Int128]

type ColInt16

+ func (c *ColInt16) AppendArr(v []int16)

+ func (c *ColInt16) LowCardinality() *ColLowCardinalityOf[int16]

type ColInt256

+ func (c *ColInt256) AppendArr(v []Int256)

+ func (c *ColInt256) LowCardinality() *ColLowCardinalityOf[Int256]

type ColInt32

+ func (c *ColInt32) AppendArr(v []int32)

+ func (c *ColInt32) LowCardinality() *ColLowCardinalityOf[int32]

type ColInt64

+ func (c *ColInt64) AppendArr(v []int64)

+ func (c *ColInt64) LowCardinality() *ColLowCardinalityOf[int64]

type ColInt8

+ func (c *ColInt8) AppendArr(v []int8)

+ func (c *ColInt8) LowCardinality() *ColLowCardinalityOf[int8]

type ColLowCardinalityOf

+ func (c *ColLowCardinalityOf[T]) Append(v T)

+ func (c *ColLowCardinalityOf[T]) AppendArr(v []T)

+ func (c *ColLowCardinalityOf[T]) DecodeColumn(r *Reader, rows int) error

+ func (c *ColLowCardinalityOf[T]) DecodeState(r *Reader) error

+ func (c ColLowCardinalityOf[T]) EncodeColumn(b *Buffer)

+ func (c ColLowCardinalityOf[T]) EncodeState(b *Buffer)

+ func (c ColLowCardinalityOf[T]) Row(i int) T

+ func (c ColLowCardinalityOf[T]) Rows() int

+ func (c ColLowCardinalityOf[T]) Type() ColumnType

type ColUInt128

+ func (c *ColUInt128) AppendArr(v []UInt128)

+ func (c *ColUInt128) LowCardinality() *ColLowCardinalityOf[UInt128]

type ColUInt16

+ func (c *ColUInt16) AppendArr(v []uint16)

+ func (c *ColUInt16) LowCardinality() *ColLowCardinalityOf[uint16]

type ColUInt256

+ func (c *ColUInt256) AppendArr(v []UInt256)

+ func (c *ColUInt256) LowCardinality() *ColLowCardinalityOf[UInt256]

type ColUInt32

+ func (c *ColUInt32) AppendArr(v []uint32)

+ func (c *ColUInt32) LowCardinality() *ColLowCardinalityOf[uint32]

type ColUInt64

+ func (c *ColUInt64) AppendArr(v []uint64)

+ func (c *ColUInt64) LowCardinality() *ColLowCardinalityOf[uint64]

type ColUInt8

+ func (c *ColUInt8) AppendArr(v []uint8)

+ func (c *ColUInt8) LowCardinality() *ColLowCardinalityOf[uint8]

v0.27.0

Apr 15, 2022

v0.26.0

Apr 6, 2022

Changes in this version

type ColArrOf

+ func (c *ColArrOf[T]) Result(column string) ResultColumn

+ func (c *ColArrOf[T]) Results(column string) Results

v0.25.0

Apr 5, 2022

v0.24.0

Mar 24, 2022

v0.23.0

Mar 11, 2022

v0.22.0

Feb 20, 2022

v0.21.0

Feb 11, 2022

v0.20.0

Feb 10, 2022

v0.19.0

Feb 6, 2022

Changes in this version

type Block

+ func (b Block) EncodeRawBlock(buf *Buffer, input []InputColumn) error

+ type ColArrOf struct

+ Data ColumnOf[T]

+ Offsets ColUInt64

+ func ArrayOf(c ColumnOf[T]) *ColArrOf[T]

+ func (c *ColArrOf[T]) Append(v []T)

+ func (c *ColArrOf[T]) AppendArr(v [][]T)

+ func (c *ColArrOf[T]) Reset()

+ func (c ColArrOf[T]) DecodeColumn(r *Reader, rows int) error

+ func (c ColArrOf[T]) EncodeColumn(b *Buffer)

+ func (c ColArrOf[T]) Row(i int) []T

+ func (c ColArrOf[T]) RowAppend(i int, target []T) []T

+ func (c ColArrOf[T]) Rows() int

+ func (c ColArrOf[T]) Type() ColumnType

+ type ColLowCardinalityOf struct

+ Values []T

+ func LowCardinalityOf(c ColumnOf[T]) *ColLowCardinalityOf[T]

+ func (c *ColLowCardinalityOf[T]) Prepare() error

+ func (c *ColLowCardinalityOf[T]) Reset()

+ type ColMapOf struct

+ Keys ColumnOf[K]

+ Offsets ColUInt64

+ Values ColumnOf[V]

+ func (c *ColMapOf[K, V]) DecodeColumn(r *Reader, rows int) error

+ func (c *ColMapOf[K, V]) Reset()

+ func (c ColMapOf[K, V]) EncodeColumn(b *Buffer)

+ func (c ColMapOf[K, V]) Get(k K) (v V, ok bool)

+ func (c ColMapOf[K, V]) Rows() int

+ func (c ColMapOf[K, V]) Type() ColumnType

type ColStr

+ func (c *ColStr) Array() *ColArrOf[string]

+ func (c *ColStr) LowCardinality() *ColLowCardinalityOf[string]

+ type ColumnOf interface

+ Append func(v T)

+ AppendArr func(v []T)

+ Row func(i int) T

v0.18.3

Jan 31, 2022

v0.18.2

Jan 30, 2022

Changes in this version

type ColArr

+ func (c *ColArr) DecodeState(r *Reader) error

+ func (c *ColArr) EncodeState(b *Buffer)

type ColLowCardinality

+ func (c *ColLowCardinality) DecodeState(r *Reader) error

+ func (c ColLowCardinality) EncodeState(b *Buffer)

type ColMap

+ func (c *ColMap) DecodeState(r *Reader) error

+ func (c ColMap) EncodeState(b *Buffer)

type ColTuple

+ func (c ColTuple) DecodeState(r *Reader) error

+ func (c ColTuple) EncodeState(b *Buffer)

+ type StateDecoder interface

+ DecodeState func(r *Reader) error

+ type StateEncoder interface

+ EncodeState func(b *Buffer)

+ type StatefulColumn interface

v0.18.1

Jan 29, 2022

v0.18.0

Jan 29, 2022

Changes in this version

type ColArr

+ func (c *ColArr) AppendLowCardinality(data []int)

v0.17.2

Jan 29, 2022

v0.17.1

Jan 29, 2022

Changes in this version

type Error

+ const ErrAuthenticationFailed

v0.17.0

Jan 23, 2022

v0.17.0-alpha.0

Jan 23, 2022

v0.16.0

Jan 23, 2022

Changes in this version

+ const Patch

+ func ProfileEventTypeStrings() []string

type ColInfoInput

+ func (s *ColInfoInput) Reset()

type Date

+ func ToDate(t time.Time) Date

type Date32

+ func ToDate32(t time.Time) Date32

+ type Log struct

+ Host string

+ Priority int8

+ QueryID string

+ Source string

+ Text string

+ ThreadID uint64

+ Time time.Time

+ type Logs struct

+ HostName ColStr

+ Priority ColInt8

+ QueryID ColStr

+ Source ColStr

+ Text ColStr

+ ThreadID ColUInt64

+ Time ColDateTime

+ TimeMicro ColUInt32

+ func (s *Logs) Result() Results

+ func (s Logs) All() []Log

+ type ProfileEvent struct

+ Host string

+ Name string

+ ThreadID uint64

+ Time time.Time

+ Type ProfileEventType

+ Value int64

+ type ProfileEventType byte

+ const ProfileGauge

+ const ProfileIncrement

+ func ProfileEventTypeString(s string) (ProfileEventType, error)

+ func ProfileEventTypeValues() []ProfileEventType

+ func (i ProfileEventType) IsAProfileEventType() bool

+ func (i ProfileEventType) String() string

+ type ProfileEvents struct

+ Host ColStr

+ Name ColStr

+ ThreadID ColUInt64

+ Time ColDateTime

+ Type ColInt8

+ Value ColAuto

+ func (d *ProfileEvents) All() ([]ProfileEvent, error)

+ func (d *ProfileEvents) Result() Results

type Results

+ func (s Results) Rows() int

v0.15.0

Jan 12, 2022

Changes in this version

type ColFixedStr

+ func (c *ColFixedStr) Append(b []byte)

type IPv4

+ func (v IPv4) String() string

type IPv6

+ func (v IPv6) String() string

v0.14.0

Jan 6, 2022

Changes in this version

type Buffer

+ func (b *Buffer) EncodeAware(e AwareEncoder, version int)

v0.13.0

Jan 3, 2022

v0.12.1

Jan 2, 2022

v0.12.0

Dec 31, 2021

v0.11.0

Dec 30, 2021

v0.10.1

Dec 27, 2021

v0.10.0

Dec 27, 2021

Changes in this version

type ColDate

+ func (c *ColDate) Append(v Date)

+ func (c ColDate) Row(i int) Date

type ColDate32

+ func (c *ColDate32) Append(v Date32)

+ func (c ColDate32) Row(i int) Date32

type ColDateTime

+ func (c *ColDateTime) Append(v DateTime)

+ func (c ColDateTime) Row(i int) DateTime

type ColDateTime64

+ func (c *ColDateTime64) Append(v DateTime64)

+ func (c ColDateTime64) Row(i int) DateTime64

type ColDecimal128

+ func (c *ColDecimal128) Append(v Decimal128)

+ func (c ColDecimal128) Row(i int) Decimal128

type ColDecimal256

+ func (c *ColDecimal256) Append(v Decimal256)

+ func (c ColDecimal256) Row(i int) Decimal256

type ColDecimal32

+ func (c *ColDecimal32) Append(v Decimal32)

+ func (c ColDecimal32) Row(i int) Decimal32

type ColDecimal64

+ func (c *ColDecimal64) Append(v Decimal64)

+ func (c ColDecimal64) Row(i int) Decimal64

type ColEnum16

+ func (c *ColEnum16) Append(v Enum16)

+ func (c ColEnum16) Row(i int) Enum16

type ColEnum8

+ func (c *ColEnum8) Append(v Enum8)

+ func (c ColEnum8) Row(i int) Enum8

type ColFloat32

+ func (c *ColFloat32) Append(v float32)

+ func (c ColFloat32) Row(i int) float32

type ColFloat64

+ func (c *ColFloat64) Append(v float64)

+ func (c ColFloat64) Row(i int) float64

type ColIPv4

+ func (c *ColIPv4) Append(v IPv4)

+ func (c ColIPv4) Row(i int) IPv4

type ColIPv6

+ func (c *ColIPv6) Append(v IPv6)

+ func (c ColIPv6) Row(i int) IPv6

type ColInt128

+ func (c *ColInt128) Append(v Int128)

+ func (c ColInt128) Row(i int) Int128

type ColInt16

+ func (c *ColInt16) Append(v int16)

+ func (c ColInt16) Row(i int) int16

type ColInt256

+ func (c *ColInt256) Append(v Int256)

+ func (c ColInt256) Row(i int) Int256

type ColInt32

+ func (c *ColInt32) Append(v int32)

+ func (c ColInt32) Row(i int) int32

type ColInt64

+ func (c *ColInt64) Append(v int64)

+ func (c ColInt64) Row(i int) int64

type ColInt8

+ func (c *ColInt8) Append(v int8)

+ func (c ColInt8) Row(i int) int8

type ColUInt128

+ func (c *ColUInt128) Append(v UInt128)

+ func (c ColUInt128) Row(i int) UInt128

type ColUInt16

+ func (c *ColUInt16) Append(v uint16)

+ func (c ColUInt16) Row(i int) uint16

type ColUInt256

+ func (c *ColUInt256) Append(v UInt256)

+ func (c ColUInt256) Row(i int) UInt256

type ColUInt32

+ func (c *ColUInt32) Append(v uint32)

+ func (c ColUInt32) Row(i int) uint32

type ColUInt64

+ func (c *ColUInt64) Append(v uint64)

+ func (c ColUInt64) Row(i int) uint64

type ColUInt8

+ func (c *ColUInt8) Append(v uint8)

+ func (c ColUInt8) Row(i int) uint8

v0.9.0

Dec 26, 2021

Changes in this version

type ColEnum8Auto

+ Values []string

+ func (e *ColEnum8Auto) Append(v string)

+ func (e *ColEnum8Auto) Prepare() error

+ type ColInfo struct

+ Name string

+ Type ColumnType

+ type ColInfoInput []ColInfo

+ func (s *ColInfoInput) DecodeResult(r *Reader, b Block) error

v0.8.1

Dec 26, 2021

v0.8.0

Dec 25, 2021

Changes in this version

type ColStr

+ func (c *ColStr) AppendBytes(v []byte)

type Input

+ func (i Input) Columns() string

+ func (i Input) Into(table string) string

v0.7.0

Dec 25, 2021

v0.6.0

Dec 24, 2021

Changes in this version

+ type ColRaw struct

+ Count int

+ Data []byte

+ Size int

+ T ColumnType

+ func (c *ColRaw) DecodeColumn(r *Reader, rows int) error

+ func (c *ColRaw) Reset()

+ func (c ColRaw) EncodeColumn(b *Buffer)

+ func (c ColRaw) Rows() int

+ func (c ColRaw) Type() ColumnType

v0.5.1

Dec 23, 2021

Changes in this version

type ResultColumn

+ func (c ResultColumn) DecodeResult(r *Reader, b Block) error

v0.5.0

Dec 23, 2021

Changes in this version

+ type ColEnum8Auto struct

+ Str []string

+ func (e *ColEnum8Auto) DecodeColumn(r *Reader, rows int) error

+ func (e *ColEnum8Auto) Infer(t ColumnType) error

+ func (e *ColEnum8Auto) PrepareColumn() error

+ func (e *ColEnum8Auto) Reset()

+ func (e ColEnum8Auto) EncodeColumn(b *Buffer)

+ func (e ColEnum8Auto) Rows() int

+ func (e ColEnum8Auto) Type() ColumnType

+ type ColInput interface

+ EncodeColumn func(b *Buffer)

+ Rows func() int

+ Type func() ColumnType

+ type ColResult interface

+ DecodeColumn func(r *Reader, rows int) error

+ Reset func()

+ Rows func() int

+ Type func() ColumnType

type ColStr

+ func (c *ColStr) AppendArr(v []string)

+ type Preparable interface

+ Prepare func() error

type Result

+ DecodeResult func(r *Reader, b Block) error

+ type Results []ResultColumn

+ func (s *Results) Auto() Result

+ func (s Results) DecodeResult(r *Reader, b Block) error

v0.4.0

Dec 19, 2021

Changes in this version

type Block

+ func (b *Block) DecodeRawBlock(r *Reader, target []ResultColumn) error

+ func (b Block) EncodeBlock(buf *Buffer, version int, input []InputColumn) error

+ type ColAuto struct

+ Data Column

+ func (c *ColAuto) Infer(t ColumnType) error

+ func (c ColAuto) DecodeColumn(r *Reader, rows int) error

+ func (c ColAuto) EncodeColumn(b *Buffer)

+ func (c ColAuto) Reset()

+ func (c ColAuto) Rows() int

+ func (c ColAuto) Type() ColumnType

+ type InferColumn interface

+ Infer func(t ColumnType) error

type ResultColumn

+ func AutoResult(name string) ResultColumn

type ServerCode

+ const ServerPartUUIDs

+ const ServerProfileEvents

+ const ServerReadTaskRequest

type Stage

+ const StageFetchColumns

+ const StageWithMergeableState

v0.3.0

Dec 18, 2021

v0.2.0

Dec 18, 2021

Changes in this version

type ColArr

+ func NewArrDecimal128() *ColArr

+ func NewArrDecimal256() *ColArr

+ func NewArrDecimal32() *ColArr

+ func NewArrDecimal64() *ColArr

+ func NewArrInt256() *ColArr

+ func NewArrUInt256() *ColArr

+ func (c *ColArr) AppendDecimal128(data []Decimal128)

+ func (c *ColArr) AppendDecimal256(data []Decimal256)

+ func (c *ColArr) AppendDecimal32(data []Decimal32)

+ func (c *ColArr) AppendDecimal64(data []Decimal64)

+ func (c *ColArr) AppendInt256(data []Int256)

+ func (c *ColArr) AppendUInt256(data []UInt256)

+ type ColDecimal128 []Decimal128

+ func (ColDecimal128) Type() ColumnType

+ func (c *ColDecimal128) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDecimal128) Reset()

+ func (c ColDecimal128) EncodeColumn(b *Buffer)

+ func (c ColDecimal128) Rows() int

+ type ColDecimal256 []Decimal256

+ func (ColDecimal256) Type() ColumnType

+ func (c *ColDecimal256) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDecimal256) Reset()

+ func (c ColDecimal256) EncodeColumn(b *Buffer)

+ func (c ColDecimal256) Rows() int

+ type ColDecimal32 []Decimal32

+ func (ColDecimal32) Type() ColumnType

+ func (c *ColDecimal32) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDecimal32) Reset()

+ func (c ColDecimal32) EncodeColumn(b *Buffer)

+ func (c ColDecimal32) Rows() int

+ type ColDecimal64 []Decimal64

+ func (ColDecimal64) Type() ColumnType

+ func (c *ColDecimal64) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDecimal64) Reset()

+ func (c ColDecimal64) EncodeColumn(b *Buffer)

+ func (c ColDecimal64) Rows() int

+ type ColInt256 []Int256

+ func (ColInt256) Type() ColumnType

+ func (c *ColInt256) DecodeColumn(r *Reader, rows int) error

+ func (c *ColInt256) Reset()

+ func (c ColInt256) EncodeColumn(b *Buffer)

+ func (c ColInt256) Rows() int

+ type ColNullable struct

+ Nulls ColUInt8

+ Values Column

+ func (c *ColNullable) DecodeColumn(r *Reader, rows int) error

+ func (c *ColNullable) Reset()

+ func (c ColNullable) EncodeColumn(b *Buffer)

+ func (c ColNullable) IsElemNull(i int) bool

+ func (c ColNullable) Rows() int

+ func (c ColNullable) Type() ColumnType

+ type ColTuple []Column

+ func (c ColTuple) DecodeColumn(r *Reader, rows int) error

+ func (c ColTuple) EncodeColumn(b *Buffer)

+ func (c ColTuple) First() Column

+ func (c ColTuple) Reset()

+ func (c ColTuple) Rows() int

+ func (c ColTuple) Type() ColumnType

+ type ColUInt256 []UInt256

+ func (ColUInt256) Type() ColumnType

+ func (c *ColUInt256) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUInt256) Reset()

+ func (c ColUInt256) EncodeColumn(b *Buffer)

+ func (c ColUInt256) Rows() int

type Column

+ func Alias(c Column, t ColumnType) Column

+ func NewRawBool(raw *ColUInt8) Column

type ColumnType

+ const ColumnTypeDecimal128

+ const ColumnTypeDecimal256

+ const ColumnTypeDecimal32

+ const ColumnTypeDecimal64

+ const ColumnTypeInt256

+ const ColumnTypeNullable

+ const ColumnTypeTuple

+ const ColumnTypeUInt256

+ type Decimal128 Int128

+ type Decimal256 Int256

+ type Decimal32 int32

+ type Decimal64 int64

+ type Int256 struct

+ High UInt128

+ Low UInt128

+ func Int256FromInt(v int) Int256

+ type UInt256 struct

+ High UInt128

+ Low UInt128

+ func UInt256FromInt(v int) UInt256

+ func UInt256FromUInt64(v uint64) UInt256

v0.1.0

Dec 17, 2021

Changes in this version

+ const DateLayout

+ const Major

+ const Minor

+ const Name

+ const Version

+ func CardinalityKeyStrings() []string

+ func ClientCodeStrings() []string

+ func ClientQueryKindStrings() []string

+ func CompressionStrings() []string

+ func ErrorStrings() []string

+ func FeatureStrings() []string

+ func InterfaceStrings() []string

+ func ServerCodeStrings() []string

+ func StageStrings() []string

+ type AwareDecoder interface

+ DecodeAware func(r *Reader, version int) error

+ type AwareEncoder interface

+ EncodeAware func(b *Buffer, version int)

+ type Block struct

+ Columns int

+ Info BlockInfo

+ Rows int

+ func (b *Block) DecodeBlock(r *Reader, version int, target []ResultColumn) error

+ func (b *Block) End() bool

+ func (b Block) EncodeAware(buf *Buffer, version int)

+ type BlockInfo struct

+ BucketNum int

+ Overflows bool

+ func (i *BlockInfo) Decode(r *Reader) error

+ func (i BlockInfo) Encode(b *Buffer)

+ func (i BlockInfo) String() string

+ type Buffer struct

+ Buf []byte

+ func (b *Buffer) Encode(e Encoder)

+ func (b *Buffer) Ensure(n int)

+ func (b *Buffer) PutBool(v bool)

+ func (b *Buffer) PutByte(x byte)

+ func (b *Buffer) PutFloat32(v float32)

+ func (b *Buffer) PutFloat64(v float64)

+ func (b *Buffer) PutInt(x int)

+ func (b *Buffer) PutInt128(x Int128)

+ func (b *Buffer) PutInt16(v int16)

+ func (b *Buffer) PutInt32(x int32)

+ func (b *Buffer) PutInt64(x int64)

+ func (b *Buffer) PutInt8(v int8)

+ func (b *Buffer) PutLen(x int)

+ func (b *Buffer) PutRaw(v []byte)

+ func (b *Buffer) PutString(s string)

+ func (b *Buffer) PutUInt128(x UInt128)

+ func (b *Buffer) PutUInt16(x uint16)

+ func (b *Buffer) PutUInt32(x uint32)

+ func (b *Buffer) PutUInt64(x uint64)

+ func (b *Buffer) PutUInt8(x uint8)

+ func (b *Buffer) PutUVarInt(x uint64)

+ func (b *Buffer) Read(p []byte) (n int, err error)

+ func (b *Buffer) Reader() *Reader

+ func (b *Buffer) Reset()

+ type CardinalityKey byte

+ const KeyUInt16

+ const KeyUInt32

+ const KeyUInt64

+ const KeyUInt8

+ func CardinalityKeyString(s string) (CardinalityKey, error)

+ func CardinalityKeyValues() []CardinalityKey

+ func (i CardinalityKey) IsACardinalityKey() bool

+ func (i CardinalityKey) String() string

+ type ClientCode byte

+ const ClientCodeCancel

+ const ClientCodeData

+ const ClientCodeHello

+ const ClientCodePing

+ const ClientCodeQuery

+ const ClientTablesStatusRequest

+ func ClientCodeString(s string) (ClientCode, error)

+ func ClientCodeValues() []ClientCode

+ func (c ClientCode) Compressible() bool

+ func (c ClientCode) Encode(b *Buffer)

+ func (i ClientCode) IsAClientCode() bool

+ func (i ClientCode) String() string

+ type ClientData struct

+ TableName string

+ func (c *ClientData) DecodeAware(r *Reader, version int) error

+ func (c ClientData) EncodeAware(b *Buffer, version int)

+ type ClientHello struct

+ Database string

+ Major int

+ Minor int

+ Name string

+ Password string

+ ProtocolVersion int

+ User string

+ func (c *ClientHello) Decode(r *Reader) error

+ func (c ClientHello) Encode(b *Buffer)

+ type ClientInfo struct

+ ClientHostname string

+ ClientName string

+ DistributedDepth int

+ InitialAddress string

+ InitialQueryID string

+ InitialTime int64

+ InitialUser string

+ Interface Interface

+ Major int

+ Minor int

+ OSUser string

+ Patch int

+ ProtocolVersion int

+ Query ClientQueryKind

+ QuotaKey string

+ Span trace.SpanContext

+ func (c *ClientInfo) DecodeAware(r *Reader, version int) error

+ func (c ClientInfo) EncodeAware(b *Buffer, version int)

+ type ClientQueryKind byte

+ const ClientQueryInitial

+ const ClientQueryNone

+ const ClientQuerySecondary

+ func ClientQueryKindString(s string) (ClientQueryKind, error)

+ func ClientQueryKindValues() []ClientQueryKind

+ func (i ClientQueryKind) IsAClientQueryKind() bool

+ func (i ClientQueryKind) String() string

+ type ColArr struct

+ Data Column

+ Offsets ColUInt64

+ func NewArrDate() *ColArr

+ func NewArrDate32() *ColArr

+ func NewArrDateTime() *ColArr

+ func NewArrDateTime64() *ColArr

+ func NewArrEnum16() *ColArr

+ func NewArrEnum8() *ColArr

+ func NewArrFloat32() *ColArr

+ func NewArrFloat64() *ColArr

+ func NewArrIPv4() *ColArr

+ func NewArrIPv6() *ColArr

+ func NewArrInt128() *ColArr

+ func NewArrInt16() *ColArr

+ func NewArrInt32() *ColArr

+ func NewArrInt64() *ColArr

+ func NewArrInt8() *ColArr

+ func NewArrUInt128() *ColArr

+ func NewArrUInt16() *ColArr

+ func NewArrUInt32() *ColArr

+ func NewArrUInt64() *ColArr

+ func NewArrUInt8() *ColArr

+ func (c *ColArr) AppendDate(data []Date)

+ func (c *ColArr) AppendDate32(data []Date32)

+ func (c *ColArr) AppendDateTime(data []DateTime)

+ func (c *ColArr) AppendDateTime64(data []DateTime64)

+ func (c *ColArr) AppendEnum16(data []Enum16)

+ func (c *ColArr) AppendEnum8(data []Enum8)

+ func (c *ColArr) AppendFloat32(data []float32)

+ func (c *ColArr) AppendFloat64(data []float64)

+ func (c *ColArr) AppendIPv4(data []IPv4)

+ func (c *ColArr) AppendIPv6(data []IPv6)

+ func (c *ColArr) AppendInt128(data []Int128)

+ func (c *ColArr) AppendInt16(data []int16)

+ func (c *ColArr) AppendInt32(data []int32)

+ func (c *ColArr) AppendInt64(data []int64)

+ func (c *ColArr) AppendInt8(data []int8)

+ func (c *ColArr) AppendUInt128(data []UInt128)

+ func (c *ColArr) AppendUInt16(data []uint16)

+ func (c *ColArr) AppendUInt32(data []uint32)

+ func (c *ColArr) AppendUInt64(data []uint64)

+ func (c *ColArr) AppendUInt8(data []uint8)

+ func (c *ColArr) DecodeColumn(r *Reader, rows int) error

+ func (c *ColArr) Reset()

+ func (c ColArr) EncodeColumn(b *Buffer)

+ func (c ColArr) Rows() int

+ func (c ColArr) Type() ColumnType

+ type ColBool []bool

+ func (ColBool) Type() ColumnType

+ func (c *ColBool) DecodeColumn(r *Reader, rows int) error

+ func (c *ColBool) Reset()

+ func (c ColBool) EncodeColumn(b *Buffer)

+ func (c ColBool) Rows() int

+ type ColDate []Date

+ func (ColDate) Type() ColumnType

+ func (c *ColDate) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDate) Reset()

+ func (c ColDate) EncodeColumn(b *Buffer)

+ func (c ColDate) Rows() int

+ type ColDate32 []Date32

+ func (ColDate32) Type() ColumnType

+ func (c *ColDate32) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDate32) Reset()

+ func (c ColDate32) EncodeColumn(b *Buffer)

+ func (c ColDate32) Rows() int

+ type ColDateTime []DateTime

+ func (ColDateTime) Type() ColumnType

+ func (c *ColDateTime) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDateTime) Reset()

+ func (c ColDateTime) EncodeColumn(b *Buffer)

+ func (c ColDateTime) Rows() int

+ type ColDateTime64 []DateTime64

+ func (ColDateTime64) Type() ColumnType

+ func (c *ColDateTime64) DecodeColumn(r *Reader, rows int) error

+ func (c *ColDateTime64) Reset()

+ func (c *ColDateTime64) Wrap(p Precision) Column

+ func (c ColDateTime64) EncodeColumn(b *Buffer)

+ func (c ColDateTime64) Rows() int

+ type ColEnum16 []Enum16

+ func (ColEnum16) Type() ColumnType

+ func (c *ColEnum16) DecodeColumn(r *Reader, rows int) error

+ func (c *ColEnum16) Reset()

+ func (c ColEnum16) EncodeColumn(b *Buffer)

+ func (c ColEnum16) Rows() int

+ type ColEnum8 []Enum8

+ func (ColEnum8) Type() ColumnType

+ func (c *ColEnum8) DecodeColumn(r *Reader, rows int) error

+ func (c *ColEnum8) Reset()

+ func (c ColEnum8) EncodeColumn(b *Buffer)

+ func (c ColEnum8) Rows() int

+ type ColFixedStr struct

+ Buf []byte

+ Size int

+ func (c *ColFixedStr) DecodeColumn(r *Reader, rows int) error

+ func (c *ColFixedStr) Reset()

+ func (c *ColFixedStr) SetSize(n int)

+ func (c ColFixedStr) EncodeColumn(b *Buffer)

+ func (c ColFixedStr) Row(i int) []byte

+ func (c ColFixedStr) Rows() int

+ func (c ColFixedStr) Type() ColumnType

+ type ColFloat32 []float32

+ func (ColFloat32) Type() ColumnType

+ func (c *ColFloat32) DecodeColumn(r *Reader, rows int) error

+ func (c *ColFloat32) Reset()

+ func (c ColFloat32) EncodeColumn(b *Buffer)

+ func (c ColFloat32) Rows() int

+ type ColFloat64 []float64

+ func (ColFloat64) Type() ColumnType

+ func (c *ColFloat64) DecodeColumn(r *Reader, rows int) error

+ func (c *ColFloat64) Reset()

+ func (c ColFloat64) EncodeColumn(b *Buffer)

+ func (c ColFloat64) Rows() int

+ type ColIPv4 []IPv4

+ func (ColIPv4) Type() ColumnType

+ func (c *ColIPv4) DecodeColumn(r *Reader, rows int) error

+ func (c *ColIPv4) Reset()

+ func (c ColIPv4) EncodeColumn(b *Buffer)

+ func (c ColIPv4) Rows() int

+ type ColIPv6 []IPv6

+ func (ColIPv6) Type() ColumnType

+ func (c *ColIPv6) DecodeColumn(r *Reader, rows int) error

+ func (c *ColIPv6) Reset()

+ func (c ColIPv6) EncodeColumn(b *Buffer)

+ func (c ColIPv6) Rows() int

+ type ColInt128 []Int128

+ func (ColInt128) Type() ColumnType

+ func (c *ColInt128) DecodeColumn(r *Reader, rows int) error

+ func (c *ColInt128) Reset()

+ func (c ColInt128) EncodeColumn(b *Buffer)

+ func (c ColInt128) Rows() int

+ type ColInt16 []int16

+ func (ColInt16) Type() ColumnType

+ func (c *ColInt16) DecodeColumn(r *Reader, rows int) error

+ func (c *ColInt16) Reset()

+ func (c ColInt16) EncodeColumn(b *Buffer)

+ func (c ColInt16) Rows() int

+ type ColInt32 []int32

+ func (ColInt32) Type() ColumnType

+ func (c *ColInt32) DecodeColumn(r *Reader, rows int) error

+ func (c *ColInt32) Reset()

+ func (c ColInt32) EncodeColumn(b *Buffer)

+ func (c ColInt32) Rows() int

+ type ColInt64 []int64

+ func (ColInt64) Type() ColumnType

+ func (c *ColInt64) DecodeColumn(r *Reader, rows int) error

+ func (c *ColInt64) Reset()

+ func (c ColInt64) EncodeColumn(b *Buffer)

+ func (c ColInt64) Rows() int

+ type ColInt8 []int8

+ func (ColInt8) Type() ColumnType

+ func (c *ColInt8) DecodeColumn(r *Reader, rows int) error

+ func (c *ColInt8) Reset()

+ func (c ColInt8) EncodeColumn(b *Buffer)

+ func (c ColInt8) Rows() int

+ type ColLowCardinality struct

+ Index Column

+ Key CardinalityKey

+ Keys16 ColUInt16

+ Keys32 ColUInt32

+ Keys64 ColUInt64

+ Keys8 ColUInt8

+ func (c *ColLowCardinality) AppendKey(i int)

+ func (c *ColLowCardinality) DecodeColumn(r *Reader, rows int) error

+ func (c *ColLowCardinality) Keys() Column

+ func (c *ColLowCardinality) Reset()

+ func (c ColLowCardinality) EncodeColumn(b *Buffer)

+ func (c ColLowCardinality) Rows() int

+ func (c ColLowCardinality) Type() ColumnType

+ type ColMap struct

+ Keys Column

+ Offsets ColUInt64

+ Values Column

+ func (c *ColMap) DecodeColumn(r *Reader, rows int) error

+ func (c *ColMap) Reset()

+ func (c ColMap) EncodeColumn(b *Buffer)

+ func (c ColMap) Rows() int

+ func (c ColMap) Type() ColumnType

+ type ColStr struct

+ Buf []byte

+ Pos []Position

+ func (ColStr) ArrAppend(arr *ColArr, data []string)

+ func (ColStr) Type() ColumnType

+ func (c *ColStr) Append(v string)

+ func (c *ColStr) DecodeColumn(r *Reader, rows int) error

+ func (c *ColStr) Reset()

+ func (c ColStr) EncodeColumn(b *Buffer)

+ func (c ColStr) First() string

+ func (c ColStr) ForEach(f func(i int, s string) error) error

+ func (c ColStr) ForEachBytes(f func(i int, b []byte) error) error

+ func (c ColStr) Row(i int) string

+ func (c ColStr) Rows() int

+ type ColUInt128 []UInt128

+ func (ColUInt128) Type() ColumnType

+ func (c *ColUInt128) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUInt128) Reset()

+ func (c ColUInt128) EncodeColumn(b *Buffer)

+ func (c ColUInt128) Rows() int

+ type ColUInt16 []uint16

+ func (ColUInt16) Type() ColumnType

+ func (c *ColUInt16) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUInt16) Reset()

+ func (c ColUInt16) EncodeColumn(b *Buffer)

+ func (c ColUInt16) Rows() int

+ type ColUInt32 []uint32

+ func (ColUInt32) Type() ColumnType

+ func (c *ColUInt32) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUInt32) Reset()

+ func (c ColUInt32) EncodeColumn(b *Buffer)

+ func (c ColUInt32) Rows() int

+ type ColUInt64 []uint64

+ func (ColUInt64) Type() ColumnType

+ func (c *ColUInt64) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUInt64) Reset()

+ func (c ColUInt64) EncodeColumn(b *Buffer)

+ func (c ColUInt64) Rows() int

+ type ColUInt8 []uint8

+ func (ColUInt8) Type() ColumnType

+ func (c *ColUInt8) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUInt8) Reset()

+ func (c ColUInt8) EncodeColumn(b *Buffer)

+ func (c ColUInt8) Rows() int

+ type ColUUID []uuid.UUID

+ func (c *ColUUID) DecodeColumn(r *Reader, rows int) error

+ func (c *ColUUID) Reset()

+ func (c ColUUID) EncodeColumn(b *Buffer)

+ func (c ColUUID) Rows() int

+ func (c ColUUID) Type() ColumnType

+ type Column interface

+ func Wrap(c Column, args ...interface{}) Column

+ type ColumnType string

+ const ColumnTypeArray

+ const ColumnTypeBool

+ const ColumnTypeDate

+ const ColumnTypeDate32

+ const ColumnTypeDateTime

+ const ColumnTypeDateTime64

+ const ColumnTypeEnum16

+ const ColumnTypeEnum8

+ const ColumnTypeFixedString

+ const ColumnTypeFloat32

+ const ColumnTypeFloat64

+ const ColumnTypeIPv4

+ const ColumnTypeIPv6

+ const ColumnTypeInt128

+ const ColumnTypeInt16

+ const ColumnTypeInt32

+ const ColumnTypeInt64

+ const ColumnTypeInt8

+ const ColumnTypeLowCardinality

+ const ColumnTypeMap

+ const ColumnTypeNone

+ const ColumnTypeString

+ const ColumnTypeUInt128

+ const ColumnTypeUInt16

+ const ColumnTypeUInt32

+ const ColumnTypeUInt64

+ const ColumnTypeUInt8

+ const ColumnTypeUUID

+ func (c ColumnType) Array() ColumnType

+ func (c ColumnType) Base() ColumnType

+ func (c ColumnType) Conflicts(b ColumnType) bool

+ func (c ColumnType) Elem() ColumnType

+ func (c ColumnType) IsArray() bool

+ func (c ColumnType) String() string

+ func (c ColumnType) Sub(subtypes ...ColumnType) ColumnType

+ func (c ColumnType) With(params ...string) ColumnType

+ type Compression byte

+ const CompressionDisabled

+ const CompressionEnabled

+ func CompressionString(s string) (Compression, error)

+ func CompressionValues() []Compression

+ func (c Compression) Encode(b *Buffer)

+ func (i Compression) IsACompression() bool

+ func (i Compression) String() string

+ type Date uint16

+ func NewDate(year int, month time.Month, day int) Date

+ func TimeToDate(t time.Time) Date

+ func (d Date) String() string

+ func (d Date) Time() time.Time

+ func (d Date) Unix() int64

+ type Date32 uint32

+ func NewDate32(year int, month time.Month, day int) Date32

+ func TimeToDate32(t time.Time) Date32

+ func (d Date32) String() string

+ func (d Date32) Time() time.Time

+ func (d Date32) Unix() int64

+ type DateTime int32

+ func ToDateTime(t time.Time) DateTime

+ func (d DateTime) Time() time.Time

+ type DateTime64 int64

+ func ToDateTime64(t time.Time, p Precision) DateTime64

+ func (d DateTime64) Time(p Precision) time.Time

+ type Decoder interface

+ Decode func(r *Reader) error

+ type Encoder interface

+ Encode func(b *Buffer)

+ type Enum16 int16

+ type Enum8 int8

+ type Error int

+ const ErrAborted

+ const ErrAddingReplicaToNonEmptyTable

+ const ErrAggregateFunctionDoesntAllowParameters

+ const ErrAggregateFunctionNotApplicable

+ const ErrAioCompletionError

+ const ErrAioReadError

+ const ErrAioSubmitError

+ const ErrAioWriteError

+ const ErrAliasRequired

+ const ErrAllConnectionTriesFailed

+ const ErrAllReplicasAreStale

+ const ErrAllRequestedColumnsAreMissing

+ const ErrAmbiguousColumnName

+ const ErrAmbiguousIdentifier

+ const ErrAmbiguousTableName

+ const ErrArgumentOutOfBound

+ const ErrAttemptToReadAfterEOF

+ const ErrBadArguments

+ const ErrBadCast

+ const ErrBadCollation

+ const ErrBadDataPartName

+ const ErrBadGet

+ const ErrBadLambda

+ const ErrBadSizeOfFileInDataPart

+ const ErrBadTypeOfField

+ const ErrBarrierTimeout

+ const ErrBlocksHaveDifferentStructure

+ const ErrCPUIDError

+ const ErrCannotAllocateMemory

+ const ErrCannotAppendHistory

+ const ErrCannotApplyCatboostModel

+ const ErrCannotAssignOptimize

+ const ErrCannotBlockSignal

+ const ErrCannotClockGettime

+ const ErrCannotCloseFile

+ const ErrCannotCompileCode

+ const ErrCannotCompress

+ const ErrCannotConvertCharset

+ const ErrCannotConvertType

+ const ErrCannotCreateCharsetConverter

+ const ErrCannotCreateChildProcess

+ const ErrCannotCreateDirectory

+ const ErrCannotCreateIoBuffer

+ const ErrCannotCreateTableFromMetadata

+ const ErrCannotDecompress

+ const ErrCannotDlopen

+ const ErrCannotDlsym

+ const ErrCannotFork

+ const ErrCannotFsync

+ const ErrCannotGetCreateTableQuery

+ const ErrCannotGetReturnType

+ const ErrCannotGetSizeOfField

+ const ErrCannotInsertElementIntoConstantColumn

+ const ErrCannotInsertNullInOrdinaryColumn

+ const ErrCannotInsertValueOfDifferentSizeIntoTuple

+ const ErrCannotKill

+ const ErrCannotLoadCatboostModel

+ const ErrCannotLoadConfig

+ const ErrCannotManipulateSigset

+ const ErrCannotMergeDifferentAggregatedDataVariants

+ const ErrCannotMremap

+ const ErrCannotMunmap

+ const ErrCannotOpenFile

+ const ErrCannotParseAllValueFromTabSeparatedInput

+ const ErrCannotParseDate

+ const ErrCannotParseDatetime

+ const ErrCannotParseDomainValueFromString

+ const ErrCannotParseEscapeSequence

+ const ErrCannotParseInputAssertionFailed

+ const ErrCannotParseNumber

+ const ErrCannotParseQuotedString

+ const ErrCannotParseText

+ const ErrCannotParseUUID

+ const ErrCannotPipe

+ const ErrCannotPrintFloatOrDoubleNumber

+ const ErrCannotPrintInteger

+ const ErrCannotReadAggregateFunctionFromText

+ const ErrCannotReadAllData

+ const ErrCannotReadAllDataFromChunkedInput

+ const ErrCannotReadAllDataFromTabSeparatedInput

+ const ErrCannotReadArrayFromText

+ const ErrCannotReadCompressedChunk

+ const ErrCannotReadFromFileDescriptor

+ const ErrCannotReadFromIstream

+ const ErrCannotReadFromSocket

+ const ErrCannotReadHistory

+ const ErrCannotReadSizeOfCompressedChunk

+ const ErrCannotSeekThroughFile

+ const ErrCannotSelect

+ const ErrCannotStatvfs

+ const ErrCannotTruncateFile

+ const ErrCannotUnblockSignal

+ const ErrCannotWaitForSignal

+ const ErrCannotWaitpid

+ const ErrCannotWriteAfterEndOfBuffer

+ const ErrCannotWriteAggregateFunctionAsText

+ const ErrCannotWriteToEmptyBlockOutputStream

+ const ErrCannotWriteToFileDescriptor

+ const ErrCannotWriteToOstream

+ const ErrCannotWriteToSocket

+ const ErrChecksumDoesntMatch

+ const ErrChildWasNotExitedNormally

+ const ErrChunkNotFound

+ const ErrClientHasConnectedToWrongPort

+ const ErrClientOutputFormatSpecified

+ const ErrCollationComparisonFailed

+ const ErrColumnQueriedMoreThanOnce

+ const ErrConditionalTreeParentNotFound

+ const ErrCorruptedData

+ const ErrCurrentWriteBufferIsExhausted

+ const ErrCyclicAliases

+ const ErrDNSError

+ const ErrDataTypeCannotBeUsedInTables

+ const ErrDataTypeCannotHaveArguments

+ const ErrDatabaseAccessDenied

+ const ErrDatabaseAlreadyExists

+ const ErrDatabaseNotEmpty

+ const ErrDdlGuardIsActive

+ const ErrDelimiterInStringLiteralDoesntMatch

+ const ErrDictionariesWasNotLoaded

+ const ErrDictionaryIsEmpty

+ const ErrDirectoryAlreadyExists

+ const ErrDirectoryDoesntExist

+ const ErrDistributedInJoinSubqueryDenied

+ const ErrDuplicateChunkName

+ const ErrDuplicateColumn

+ const ErrDuplicateDataPart

+ const ErrDuplicateInterserverIoEndpoint

+ const ErrEmptyDataPassed

+ const ErrEmptyListOfColumnsPassed

+ const ErrEmptyListOfColumnsQueried

+ const ErrEmptyNestedTable

+ const ErrEmptyQuery

+ const ErrEngineRequired

+ const ErrExcessiveElementInConfig

+ const ErrExpectedEndOfFile

+ const ErrExternalLibraryError

+ const ErrExternalLoadableAlreadyExists

+ const ErrFileDoesntExist

+ const ErrFirstDateIsBiggerThanLastDate

+ const ErrFormatIsNotSuitableForInput

+ const ErrFormatVersionTooOld

+ const ErrFoundMoreThanOneNode

+ const ErrFunctionCannotHaveParameters

+ const ErrFunctionIsSpecial

+ const ErrFunctionThrowIfValueIsNonZero

+ const ErrHTTPLengthRequired

+ const ErrIPAddressNotAllowed

+ const ErrIllegalAggregation

+ const ErrIllegalColumn

+ const ErrIllegalDivision

+ const ErrIllegalFinal

+ const ErrIllegalIndex

+ const ErrIllegalKeyOfAggregation

+ const ErrIllegalNumberOfResultColumns

+ const ErrIllegalOverflowMode

+ const ErrIllegalPrewhere

+ const ErrIllegalProjectionManipulator

+ const ErrIllegalSyntaxForDataType

+ const ErrIllegalTypeOfArgument

+ const ErrIllegalTypeOfColumnForFilter

+ const ErrIncompatibleColumns

+ const ErrIncompatibleSourceTables

+ const ErrIncompatibleTypeOfJoin

+ const ErrInconsistentClusterDefinition

+ const ErrIncorrectData

+ const ErrIncorrectElementOfSet

+ const ErrIncorrectFileName

+ const ErrIncorrectIndex

+ const ErrIncorrectMark

+ const ErrIncorrectNumberOfColumns

+ const ErrIncorrectQuery

+ const ErrIncorrectResultOfScalarSubquery

+ const ErrIndexNotUsed

+ const ErrIndexOfColumnInSortClauseIsOutOfRange

+ const ErrIndexOfPositionalArgumentIsOutOfRange

+ const ErrInfiniteLoop

+ const ErrInsertWasDeduplicated

+ const ErrIntoOutfileNotAllowed

+ const ErrInvalidBlockExtraInfo

+ const ErrInvalidConfigParameter

+ const ErrInvalidPartitionValue

+ const ErrInvalidSessionTimeout

+ const ErrInvalidShardWeight

+ const ErrKeeperException

+ const ErrLeadershipChanged

+ const ErrLeadershipLost

+ const ErrLimitExceeded

+ const ErrLogicalError

+ const ErrMemoryLimitExceeded

+ const ErrMetadataMismatch

+ const ErrMismatchReplicasDataSources

+ const ErrMongodbCannotAuthenticate

+ const ErrMultipleAliasesForExpression

+ const ErrMultipleExpressionsForAlias

+ const ErrMultipleStreamsRequired

+ const ErrNestedTypeTooDeep

+ const ErrNetworkError

+ const ErrNoActiveReplicas

+ const ErrNoAttributesListed

+ const ErrNoAvailableData

+ const ErrNoAvailableReplica

+ const ErrNoCommonType

+ const ErrNoDataToInsert

+ const ErrNoElementsInConfig

+ const ErrNoFileInDataPart

+ const ErrNoFreeConnection

+ const ErrNoRemoteShardFound

+ const ErrNoReplicaHasPart

+ const ErrNoReplicaNameGiven

+ const ErrNoSuchColumnInTable

+ const ErrNoSuchDataPart

+ const ErrNoSuchInterserverIoEndpoint

+ const ErrNoSuchReplica

+ const ErrNoZookeeper

+ const ErrNotAColumn

+ const ErrNotAnAggregate

+ const ErrNotEnoughBlockNumbers

+ const ErrNotEnoughSpace

+ const ErrNotFoundColumnInBlock

+ const ErrNotFoundExpectedDataPart

+ const ErrNotFoundFunctionElementForAggregate

+ const ErrNotFoundNode

+ const ErrNotFoundRHSElementForCondition

+ const ErrNotFoundRelationElementForCondition

+ const ErrNotImplemented

+ const ErrNumberOfArgumentsDoesntMatch

+ const ErrNumberOfColumnsDoesntMatch

+ const ErrOnlyFilterColumnInBlock

+ const ErrOutputIsNotSorted

+ const ErrParameterOutOfBound

+ const ErrParametersToAggregateFunctionsMustBeLiterals

+ const ErrPartIsTemporarilyLocked

+ const ErrPartitionAlreadyExists

+ const ErrPartitionDoesntExist

+ const ErrPocoException

+ const ErrPositionOutOfBound

+ const ErrQueryIsNotSupportedInMaterializedView

+ const ErrQueryIsProhibited

+ const ErrQueryIsTooLarge

+ const ErrQuerySectionDoesntMakeSense

+ const ErrQueryWasCancelled

+ const ErrQueryWithSameIDIsAlreadyRunning

+ const ErrQuotaDoesntAllowKeys

+ const ErrQuotaExpired

+ const ErrReadonly

+ const ErrReceivedDataForWrongQueryID

+ const ErrReceivedEmptyData

+ const ErrReceivedErrorFromRemoteIoServer

+ const ErrReceivedErrorTooManyRequests

+ const ErrReplicaIsAlreadyActive

+ const ErrReplicaIsAlreadyExist

+ const ErrReplicaIsNotInQuorum

+ const ErrRequiredPassword

+ const ErrReservedIdentifierName

+ const ErrSamplingNotSupported

+ const ErrSeekPositionOutOfBound

+ const ErrServerRevisionIsTooOld

+ const ErrSessionIsLocked

+ const ErrSessionNotFound

+ const ErrSetSizeLimitExceeded

+ const ErrShardHasNoConnections

+ const ErrSizeOfFixedStringDoesntMatch

+ const ErrSizesOfArraysDoesntMatch

+ const ErrSizesOfColumnsDoesntMatch

+ const ErrSizesOfColumnsInTupleDoesntMatch

+ const ErrSizesOfMarksFilesAreInconsistent

+ const ErrSizesOfNestedColumnsAreInconsistent

+ const ErrSocketTimeout

+ const ErrStdException

+ const ErrStorageDoesntAllowParameters

+ const ErrStorageDoesntSupportParallelReplicas

+ const ErrStorageRequiresParameter

+ const ErrSupportIsDisabled

+ const ErrSyntaxError

+ const ErrTableAlreadyExists

+ const ErrTableDiffersTooMuch

+ const ErrTableIsDropped

+ const ErrTableIsReadOnly

+ const ErrTableMetadataAlreadyExists

+ const ErrTableMustNotBeCreatedManually

+ const ErrTableSizeExceedsMaxDropSizeLimit

+ const ErrTableWasNotDropped

+ const ErrThereIsNoColumn

+ const ErrThereIsNoDefaultValue

+ const ErrThereIsNoProfile

+ const ErrThereIsNoQuery

+ const ErrThereIsNoSession

+ const ErrTimeoutExceeded

+ const ErrTooBigAst

+ const ErrTooDeepAst

+ const ErrTooDeepPipeline

+ const ErrTooDeepRecursion

+ const ErrTooDeepSubqueries

+ const ErrTooLargeArraySize

+ const ErrTooLargeSizeCompressed

+ const ErrTooLargeStringSize

+ const ErrTooLessArgumentsForFunction

+ const ErrTooLessLiveReplicas

+ const ErrTooManyArgumentsForFunction

+ const ErrTooManyBytes

+ const ErrTooManyColumns

+ const ErrTooManyFetches

+ const ErrTooManyParts

+ const ErrTooManyRetriesToFetchParts

+ const ErrTooManyRows

+ const ErrTooManyRowsOrBytes

+ const ErrTooManySimultaneousQueries

+ const ErrTooManyTemporaryColumns

+ const ErrTooManyTemporaryNonConstColumns

+ const ErrTooManyUnexpectedDataParts

+ const ErrTooSlow

+ const ErrTooSmallBufferSize

+ const ErrTypeMismatch

+ const ErrUnexpectedAstStructure

+ const ErrUnexpectedEndOfFile

+ const ErrUnexpectedExpression

+ const ErrUnexpectedFileInDataPart

+ const ErrUnexpectedNodeInZookeeper

+ const ErrUnexpectedPacketFromClient

+ const ErrUnexpectedPacketFromServer

+ const ErrUnexpectedZookeeperError

+ const ErrUnfinished

+ const ErrUnionAllResultStructuresMismatch

+ const ErrUnknownAction

+ const ErrUnknownAddressPatternType

+ const ErrUnknownAggregateFunction

+ const ErrUnknownAggregatedDataVariant

+ const ErrUnknownBlockInfoField

+ const ErrUnknownCompressionMethod

+ const ErrUnknownDatabase

+ const ErrUnknownDatabaseEngine

+ const ErrUnknownDirectionOfSorting

+ const ErrUnknownDistributedProductMode

+ const ErrUnknownElementInAst

+ const ErrUnknownElementInConfig

+ const ErrUnknownException

+ const ErrUnknownFormat

+ const ErrUnknownFormatVersion

+ const ErrUnknownFunction

+ const ErrUnknownGlobalSubqueriesMethod

+ const ErrUnknownIdentifier

+ const ErrUnknownLoadBalancing

+ const ErrUnknownOverflowMode

+ const ErrUnknownPacketFromClient

+ const ErrUnknownPacketFromServer

+ const ErrUnknownQuota

+ const ErrUnknownRelation

+ const ErrUnknownSetDataVariant

+ const ErrUnknownSetting

+ const ErrUnknownStatusOfDistributedDdlTask

+ const ErrUnknownStatusOfInsert

+ const ErrUnknownStorage

+ const ErrUnknownTable

+ const ErrUnknownTotalsMode

+ const ErrUnknownType

+ const ErrUnknownTypeOfAstNode

+ const ErrUnknownTypeOfQuery

+ const ErrUnknownUser

+ const ErrUnsatisfiedQuorumForPreviousWrite

+ const ErrUnsupportedCollationLocale

+ const ErrUnsupportedMethod

+ const ErrUnsupportedMyisamBlockType

+ const ErrUnsupportedParameter

+ const ErrValueIsOutOfRangeOfDataType

+ const ErrWrongPassword

+ const ErrZeroArrayOrTupleIndex

+ const ErrZlibDeflateFailed

+ const ErrZlibInflateFailed

+ func ErrorString(s string) (Error, error)

+ func ErrorValues() []Error

+ func (e Error) Error() string

+ func (i Error) IsAError() bool

+ func (i Error) String() string

+ type Exception struct

+ Code Error

+ Message string

+ Name string

+ Nested bool

+ Stack string

+ func (e *Exception) DecodeAware(r *Reader, _ int) error

+ func (e *Exception) EncodeAware(b *Buffer, _ int)

+ type Feature int

+ const FeatureBlockInfo

+ const FeatureClientWriteInfo

+ const FeatureColumnDefaultsMetadata

+ const FeatureDisplayName

+ const FeatureDistributedDepth

+ const FeatureInterServerSecret

+ const FeatureOpenTelemetry

+ const FeatureProfileEvents

+ const FeatureQueryStartTime

+ const FeatureQuotaKeyInClientInfo

+ const FeatureRefererInClientInfo

+ const FeatureServerLogs

+ const FeatureSettingsSerializedAsStrings

+ const FeatureTempTables

+ const FeatureTimezone

+ const FeatureVersionPatch

+ const FeatureXForwardedForInClientInfo

+ func FeatureString(s string) (Feature, error)

+ func FeatureValues() []Feature

+ func (f Feature) In(v int) bool

+ func (f Feature) Version() int

+ func (i Feature) IsAFeature() bool

+ func (i Feature) String() string

+ type IPv4 uint32

+ func ToIPv4(ip netaddr.IP) IPv4

+ func (v IPv4) ToIP() netaddr.IP

+ type IPv6 UInt128

+ func ToIPv6(ip netaddr.IP) IPv6

+ func (v IPv6) ToIP() netaddr.IP

+ type Input interface

+ EncodeColumn func(b *Buffer)

+ Rows func() int

+ Type func() ColumnType

+ type InputColumn struct

+ Data Input

+ Name string

+ func (c InputColumn) EncodeStart(buf *Buffer)

+ type Int128 struct

+ High uint64

+ Low uint64

+ func Int128FromInt(v int) Int128

+ func Int128FromUInt64(v uint64) Int128

+ func (i Int128) Int() int

+ func (i Int128) UInt64() uint64

+ type Interface byte

+ const InterfaceHTTP

+ const InterfaceTCP

+ func InterfaceString(s string) (Interface, error)

+ func InterfaceValues() []Interface

+ func (i Interface) IsAInterface() bool

+ func (i Interface) String() string

+ type Position struct

+ End int

+ Start int

+ type Precision byte

+ const PrecisionMax

+ const PrecisionMicro

+ const PrecisionMilli

+ const PrecisionNano

+ const PrecisionSecond

+ func (p Precision) Duration() time.Duration

+ func (p Precision) Valid() bool

+ type Profile struct

+ AppliedLimit bool

+ Blocks uint64

+ Bytes uint64

+ CalculatedRowsBeforeLimit bool

+ Rows uint64

+ RowsBeforeLimit uint64

+ func (p *Profile) DecodeAware(r *Reader, _ int) error

+ func (p Profile) EncodeAware(b *Buffer, _ int)

+ type Progress struct

+ Bytes uint64

+ Rows uint64

+ TotalRows uint64

+ WroteBytes uint64

+ WroteRows uint64

+ func (p *Progress) DecodeAware(r *Reader, version int) error

+ func (p Progress) EncodeAware(b *Buffer, version int)

+ type Query struct

+ Body string

+ Compression Compression

+ ID string

+ Info ClientInfo

+ Secret string

+ Settings []Setting

+ Stage Stage

+ func (q *Query) DecodeAware(r *Reader, version int) error

+ func (q Query) EncodeAware(b *Buffer, version int)

+ type Reader struct

+ func NewReader(r io.Reader) *Reader

+ func (r *Reader) Bool() (bool, error)

+ func (r *Reader) Byte() (byte, error)

+ func (r *Reader) Decode(v Decoder) error

+ func (r *Reader) DisableCompression()

+ func (r *Reader) EnableCompression()

+ func (r *Reader) Float32() (float32, error)

+ func (r *Reader) Float64() (float64, error)

+ func (r *Reader) Int() (int, error)

+ func (r *Reader) Int128() (Int128, error)

+ func (r *Reader) Int16() (int16, error)

+ func (r *Reader) Int32() (int32, error)

+ func (r *Reader) Int64() (int64, error)

+ func (r *Reader) Int8() (int8, error)

+ func (r *Reader) Read(p []byte) (n int, err error)

+ func (r *Reader) ReadByte() (byte, error)

+ func (r *Reader) ReadFull(buf []byte) error

+ func (r *Reader) ReadRaw(n int) ([]byte, error)

+ func (r *Reader) Str() (string, error)

+ func (r *Reader) StrAppend(buf []byte) ([]byte, error)

+ func (r *Reader) StrBytes() ([]byte, error)

+ func (r *Reader) StrLen() (int, error)

+ func (r *Reader) StrRaw() ([]byte, error)

+ func (r *Reader) UInt128() (UInt128, error)

+ func (r *Reader) UInt16() (uint16, error)

+ func (r *Reader) UInt32() (uint32, error)

+ func (r *Reader) UInt64() (uint64, error)

+ func (r *Reader) UInt8() (uint8, error)

+ func (r *Reader) UVarInt() (uint64, error)

+ type Result interface

+ DecodeColumn func(r *Reader, rows int) error

+ Reset func()

+ Rows func() int

+ Type func() ColumnType

+ type ResultColumn struct

+ Data Result

+ Name string

+ type ServerCode byte

+ const ServerCodeData

+ const ServerCodeEndOfStream

+ const ServerCodeException

+ const ServerCodeExtremes

+ const ServerCodeHello

+ const ServerCodeLog

+ const ServerCodePong

+ const ServerCodeProfile

+ const ServerCodeProgress

+ const ServerCodeTableColumns

+ const ServerCodeTablesStatus

+ const ServerCodeTotals

+ func ServerCodeString(s string) (ServerCode, error)

+ func ServerCodeValues() []ServerCode

+ func (c ServerCode) Compressible() bool

+ func (c ServerCode) Encode(b *Buffer)

+ func (i ServerCode) IsAServerCode() bool

+ func (i ServerCode) String() string

+ type ServerHello struct

+ DisplayName string

+ Major int

+ Minor int

+ Name string

+ Patch int

+ Revision int

+ Timezone string

+ func (s *ServerHello) DecodeAware(r *Reader, v int) error

+ func (s *ServerHello) EncodeAware(b *Buffer, v int)

+ func (s ServerHello) Features() []Feature

+ func (s ServerHello) Has(f Feature) bool

+ func (s ServerHello) String() string

+ type Setting struct

+ Important bool

+ Key string

+ Value string

+ func (s *Setting) Decode(r *Reader) error

+ func (s Setting) Encode(b *Buffer)

+ type Stage byte

+ const StageComplete

+ func StageString(s string) (Stage, error)

+ func StageValues() []Stage

+ func (i Stage) IsAStage() bool

+ func (i Stage) String() string

+ func (s Stage) Encode(b *Buffer)

+ type TableColumns struct

+ First string

+ Second string

+ func (c *TableColumns) DecodeAware(r *Reader, _ int) error

+ func (c TableColumns) EncodeAware(b *Buffer, _ int)

+ type UInt128 struct

+ High uint64

+ Low uint64

+ func UInt128FromInt(v int) UInt128

+ func UInt128FromUInt64(v uint64) UInt128

+ func (i UInt128) Int() int

+ func (i UInt128) UInt64() uint64

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