column

package
v2.23.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 21 Imported by: 19

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IPv6ToBytes added in v2.3.0 

func IPv6ToBytes(ip net.IP) [16]byte

func WithAllocBufferColStrProvider added in v2.18.0 

func WithAllocBufferColStrProvider(cap int)

issue: https://github.com/ClickHouse/clickhouse-go/issues/1164 WithAllocBufferColStrProvider allow pre alloc buffer cap for proto.ColStr 

It is more suitable for scenarios where a lot of data is written in batches

func WithColStrProvider added in v2.18.0 

func WithColStrProvider(provider ColStrProvider)

WithColStrProvider more flexible than WithAllocBufferColStrProvider, such as use sync.Pool

Types

type Array 

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

func (*Array) Append 

func (col *Array) Append(v any) (nulls []uint8, err error)

func (*Array) AppendRow 

func (col *Array) AppendRow(v any) error

func (*Array) Base 

func (col *Array) Base() Interface

func (*Array) Decode 

func (col *Array) Decode(reader *proto.Reader, rows int) error

func (*Array) Encode 

func (col *Array) Encode(buffer *proto.Buffer)

func (*Array) Name added in v2.1.0 

func (col *Array) Name() string

func (*Array) ReadStatePrefix 

func (col *Array) ReadStatePrefix(reader *proto.Reader) error

func (*Array) Reset added in v2.3.0 

func (col *Array) Reset()

func (*Array) Row 

func (col *Array) Row(i int, ptr bool) any

func (*Array) Rows 

func (col *Array) Rows() int

func (*Array) ScanRow 

func (col *Array) ScanRow(dest any, row int) error

func (*Array) ScanType 

func (col *Array) ScanType() reflect.Type

func (*Array) Type 

func (col *Array) Type() Type

func (*Array) WriteStatePrefix 

func (col *Array) WriteStatePrefix(buffer *proto.Buffer) error

type BigInt 

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

func (*BigInt) Append 

func (col *BigInt) Append(v any) (nulls []uint8, err error)

func (*BigInt) AppendRow 

func (col *BigInt) AppendRow(v any) error

func (*BigInt) Decode 

func (col *BigInt) Decode(reader *proto.Reader, rows int) error

func (*BigInt) Encode 

func (col *BigInt) Encode(buffer *proto.Buffer)

func (*BigInt) Name added in v2.1.0 

func (col *BigInt) Name() string

func (*BigInt) Reset added in v2.3.0 

func (col *BigInt) Reset()

func (*BigInt) Row 

func (col *BigInt) Row(i int, ptr bool) any

func (*BigInt) Rows 

func (col *BigInt) Rows() int

func (*BigInt) ScanRow 

func (col *BigInt) ScanRow(dest any, row int) error

func (*BigInt) ScanType 

func (col *BigInt) ScanType() reflect.Type

func (*BigInt) Type 

func (col *BigInt) Type() Type

type Bool 

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

func (*Bool) Append 

func (col *Bool) Append(v any) (nulls []uint8, err error)

func (*Bool) AppendRow 

func (col *Bool) AppendRow(v any) error

func (*Bool) Decode 

func (col *Bool) Decode(reader *proto.Reader, rows int) error

func (*Bool) Encode 

func (col *Bool) Encode(buffer *proto.Buffer)

func (*Bool) Name added in v2.1.0 

func (col *Bool) Name() string

func (*Bool) Reset added in v2.3.0 

func (col *Bool) Reset()

func (*Bool) Row 

func (col *Bool) Row(i int, ptr bool) any

func (*Bool) Rows 

func (col *Bool) Rows() int

func (*Bool) ScanRow 

func (col *Bool) ScanRow(dest any, row int) error

func (*Bool) ScanType 

func (col *Bool) ScanType() reflect.Type

func (*Bool) Type 

func (col *Bool) Type() Type

type ColStrProvider added in v2.18.0 

type ColStrProvider func() proto.ColStr

ColStrProvider defines provider of proto.ColStr

type ColumnConverterError 

type ColumnConverterError struct {
	Op       string
	Hint     string
	From, To string
}

func (*ColumnConverterError) Error 

func (e *ColumnConverterError) Error() string

type CustomSerialization 

type CustomSerialization interface {
	ReadStatePrefix(*proto.Reader) error
	WriteStatePrefix(*proto.Buffer) error
}

type Date 

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

func (*Date) Append 

func (col *Date) Append(v any) (nulls []uint8, err error)

func (*Date) AppendRow 

func (col *Date) AppendRow(v any) error

func (*Date) Decode 

func (col *Date) Decode(reader *proto.Reader, rows int) error

func (*Date) Encode 

func (col *Date) Encode(buffer *proto.Buffer)

func (*Date) Name added in v2.1.0 

func (col *Date) Name() string

func (*Date) Reset added in v2.3.0 

func (col *Date) Reset()

func (*Date) Row 

func (col *Date) Row(i int, ptr bool) any

func (*Date) Rows 

func (col *Date) Rows() int

func (*Date) ScanRow 

func (col *Date) ScanRow(dest any, row int) error

func (*Date) ScanType 

func (col *Date) ScanType() reflect.Type

func (*Date) Type 

func (col *Date) Type() Type

type Date32 

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

func (*Date32) Append 

func (col *Date32) Append(v any) (nulls []uint8, err error)

func (*Date32) AppendRow 

func (col *Date32) AppendRow(v any) error

func (*Date32) Decode 

func (col *Date32) Decode(reader *proto.Reader, rows int) error

func (*Date32) Encode 

func (col *Date32) Encode(buffer *proto.Buffer)

func (*Date32) Name added in v2.1.0 

func (col *Date32) Name() string

func (*Date32) Reset added in v2.3.0 

func (col *Date32) Reset()

func (*Date32) Row 

func (col *Date32) Row(i int, ptr bool) any

func (*Date32) Rows 

func (col *Date32) Rows() int

func (*Date32) ScanRow 

func (col *Date32) ScanRow(dest any, row int) error

func (*Date32) ScanType 

func (col *Date32) ScanType() reflect.Type

func (*Date32) Type 

func (col *Date32) Type() Type

type DateOverflowError 

type DateOverflowError struct {
	Min, Max time.Time
	Value    time.Time
	Format   string
}

func (*DateOverflowError) Error 

func (e *DateOverflowError) Error() string

type DateTime 

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

func (*DateTime) Append 

func (col *DateTime) Append(v any) (nulls []uint8, err error)

func (*DateTime) AppendRow 

func (col *DateTime) AppendRow(v any) error

func (*DateTime) Decode 

func (col *DateTime) Decode(reader *proto.Reader, rows int) error

func (*DateTime) Encode 

func (col *DateTime) Encode(buffer *proto.Buffer)

func (*DateTime) Name added in v2.1.0 

func (col *DateTime) Name() string

func (*DateTime) Reset added in v2.3.0 

func (col *DateTime) Reset()

func (*DateTime) Row 

func (col *DateTime) Row(i int, ptr bool) any

func (*DateTime) Rows 

func (col *DateTime) Rows() int

func (*DateTime) ScanRow 

func (col *DateTime) ScanRow(dest any, row int) error

func (*DateTime) ScanType 

func (col *DateTime) ScanType() reflect.Type

func (*DateTime) Type 

func (col *DateTime) Type() Type

type DateTime64 

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

func (*DateTime64) Append 

func (col *DateTime64) Append(v any) (nulls []uint8, err error)

func (*DateTime64) AppendRow 

func (col *DateTime64) AppendRow(v any) error

func (*DateTime64) Decode 

func (col *DateTime64) Decode(reader *proto.Reader, rows int) error

func (*DateTime64) Encode 

func (col *DateTime64) Encode(buffer *proto.Buffer)

func (*DateTime64) Name added in v2.1.0 

func (col *DateTime64) Name() string

func (*DateTime64) Reset added in v2.3.0 

func (col *DateTime64) Reset()

func (*DateTime64) Row 

func (col *DateTime64) Row(i int, ptr bool) any

func (*DateTime64) Rows 

func (col *DateTime64) Rows() int

func (*DateTime64) ScanRow 

func (col *DateTime64) ScanRow(dest any, row int) error

func (*DateTime64) ScanType 

func (col *DateTime64) ScanType() reflect.Type

func (*DateTime64) Type 

func (col *DateTime64) Type() Type

type Decimal 

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

func (*Decimal) Append 

func (col *Decimal) Append(v any) (nulls []uint8, err error)

func (*Decimal) AppendRow 

func (col *Decimal) AppendRow(v any) error

func (*Decimal) Decode 

func (col *Decimal) Decode(reader *proto.Reader, rows int) error

func (*Decimal) Encode 

func (col *Decimal) Encode(buffer *proto.Buffer)

func (*Decimal) Name added in v2.1.0 

func (col *Decimal) Name() string

func (*Decimal) Precision 

func (col *Decimal) Precision() int64

func (*Decimal) Reset added in v2.3.0 

func (col *Decimal) Reset()

func (*Decimal) Row 

func (col *Decimal) Row(i int, ptr bool) any

func (*Decimal) Rows 

func (col *Decimal) Rows() int

func (*Decimal) Scale 

func (col *Decimal) Scale() int64

func (*Decimal) ScanRow 

func (col *Decimal) ScanRow(dest any, row int) error

func (*Decimal) ScanType 

func (col *Decimal) ScanType() reflect.Type

func (*Decimal) Type 

func (col *Decimal) Type() Type

type Enum16 

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

func (*Enum16) Append 

func (col *Enum16) Append(v any) (nulls []uint8, err error)

func (*Enum16) AppendRow 

func (col *Enum16) AppendRow(elem any) error

func (*Enum16) Decode 

func (col *Enum16) Decode(reader *proto.Reader, rows int) error

func (*Enum16) Encode 

func (col *Enum16) Encode(buffer *proto.Buffer)

func (*Enum16) Name added in v2.1.0 

func (col *Enum16) Name() string

func (*Enum16) Reset added in v2.3.0 

func (col *Enum16) Reset()

func (*Enum16) Row 

func (col *Enum16) Row(i int, ptr bool) any

func (*Enum16) Rows 

func (col *Enum16) Rows() int

func (*Enum16) ScanRow 

func (col *Enum16) ScanRow(dest any, row int) error

func (*Enum16) ScanType 

func (col *Enum16) ScanType() reflect.Type

func (*Enum16) Type 

func (col *Enum16) Type() Type

type Enum8 

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

func (*Enum8) Append 

func (col *Enum8) Append(v any) (nulls []uint8, err error)

func (*Enum8) AppendRow 

func (col *Enum8) AppendRow(elem any) error

func (*Enum8) Decode 

func (col *Enum8) Decode(reader *proto.Reader, rows int) error

func (*Enum8) Encode 

func (col *Enum8) Encode(buffer *proto.Buffer)

func (*Enum8) Name added in v2.1.0 

func (col *Enum8) Name() string

func (*Enum8) Reset added in v2.3.0 

func (col *Enum8) Reset()

func (*Enum8) Row 

func (col *Enum8) Row(i int, ptr bool) any

func (*Enum8) Rows 

func (col *Enum8) Rows() int

func (*Enum8) ScanRow 

func (col *Enum8) ScanRow(dest any, row int) error

func (*Enum8) ScanType 

func (col *Enum8) ScanType() reflect.Type

func (*Enum8) Type 

func (col *Enum8) Type() Type

type Error 

type Error struct {
	ColumnType string
	Err        error
}

func (*Error) Error 

func (e *Error) Error() string

type FixedString 

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

func (*FixedString) Append 

func (col *FixedString) Append(v any) (nulls []uint8, err error)

func (*FixedString) AppendRow 

func (col *FixedString) AppendRow(v any) (err error)

func (*FixedString) Decode 

func (col *FixedString) Decode(reader *proto.Reader, rows int) error

func (*FixedString) Encode 

func (col *FixedString) Encode(buffer *proto.Buffer)

func (*FixedString) Name added in v2.1.0 

func (col *FixedString) Name() string

func (*FixedString) Reset added in v2.3.0 

func (col *FixedString) Reset()

func (*FixedString) Row 

func (col *FixedString) Row(i int, ptr bool) any

func (*FixedString) Rows 

func (col *FixedString) Rows() int

func (*FixedString) ScanRow 

func (col *FixedString) ScanRow(dest any, row int) error

func (*FixedString) ScanType 

func (col *FixedString) ScanType() reflect.Type

func (*FixedString) Type 

func (col *FixedString) Type() Type

type Float32 

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

func (*Float32) Append 

func (col *Float32) Append(v any) (nulls []uint8, err error)

func (*Float32) AppendRow 

func (col *Float32) AppendRow(v any) error

func (*Float32) Decode 

func (col *Float32) Decode(reader *proto.Reader, rows int) error

func (*Float32) Encode 

func (col *Float32) Encode(buffer *proto.Buffer)

func (*Float32) Name added in v2.1.0 

func (col *Float32) Name() string

func (*Float32) Reset added in v2.3.0 

func (col *Float32) Reset()

func (*Float32) Row 

func (col *Float32) Row(i int, ptr bool) any

func (*Float32) Rows 

func (col *Float32) Rows() int

func (*Float32) ScanRow 

func (col *Float32) ScanRow(dest any, row int) error

func (*Float32) ScanType 

func (col *Float32) ScanType() reflect.Type

func (*Float32) Type 

func (col *Float32) Type() Type

type Float64 

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

func (*Float64) Append 

func (col *Float64) Append(v any) (nulls []uint8, err error)

func (*Float64) AppendRow 

func (col *Float64) AppendRow(v any) error

func (*Float64) Decode 

func (col *Float64) Decode(reader *proto.Reader, rows int) error

func (*Float64) Encode 

func (col *Float64) Encode(buffer *proto.Buffer)

func (*Float64) Name added in v2.1.0 

func (col *Float64) Name() string

func (*Float64) Reset added in v2.3.0 

func (col *Float64) Reset()

func (*Float64) Row 

func (col *Float64) Row(i int, ptr bool) any

func (*Float64) Rows 

func (col *Float64) Rows() int

func (*Float64) ScanRow 

func (col *Float64) ScanRow(dest any, row int) error

func (*Float64) ScanType 

func (col *Float64) ScanType() reflect.Type

func (*Float64) Type 

func (col *Float64) Type() Type

type IPv4 

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

func (*IPv4) Append 

func (col *IPv4) Append(v any) (nulls []uint8, err error)

func (*IPv4) AppendRow 

func (col *IPv4) AppendRow(v any) (err error)

func (*IPv4) AppendV4IPs added in v2.3.0 

func (col *IPv4) AppendV4IPs(ips []netip.Addr)

func (*IPv4) Decode 

func (col *IPv4) Decode(reader *proto.Reader, rows int) error

func (*IPv4) Encode 

func (col *IPv4) Encode(buffer *proto.Buffer)

func (*IPv4) Name added in v2.1.0 

func (col *IPv4) Name() string

func (*IPv4) Reset added in v2.3.0 

func (col *IPv4) Reset()

func (*IPv4) Row 

func (col *IPv4) Row(i int, ptr bool) any

func (*IPv4) Rows 

func (col *IPv4) Rows() int

func (*IPv4) ScanRow 

func (col *IPv4) ScanRow(dest any, row int) error

func (*IPv4) ScanType 

func (col *IPv4) ScanType() reflect.Type

func (*IPv4) Type 

func (col *IPv4) Type() Type

type IPv6 

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

func (*IPv6) Append 

func (col *IPv6) Append(v any) (nulls []uint8, err error)

func (*IPv6) AppendRow 

func (col *IPv6) AppendRow(v any) (err error)

func (*IPv6) AppendV6IPs added in v2.3.0 

func (col *IPv6) AppendV6IPs(ips []netip.Addr)

func (*IPv6) Decode 

func (col *IPv6) Decode(reader *proto.Reader, rows int) error

func (*IPv6) Encode 

func (col *IPv6) Encode(buffer *proto.Buffer)

func (*IPv6) Name added in v2.1.0 

func (col *IPv6) Name() string

func (*IPv6) Reset added in v2.3.0 

func (col *IPv6) Reset()

func (*IPv6) Row 

func (col *IPv6) Row(i int, ptr bool) any

func (*IPv6) Rows 

func (col *IPv6) Rows() int

func (*IPv6) ScanRow 

func (col *IPv6) ScanRow(dest any, row int) error

func (*IPv6) ScanType 

func (col *IPv6) ScanType() reflect.Type

func (*IPv6) Type 

func (col *IPv6) Type() Type

type Int16 

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

func (*Int16) Append 

func (col *Int16) Append(v any) (nulls []uint8, err error)

func (*Int16) AppendRow 

func (col *Int16) AppendRow(v any) error

func (*Int16) Decode 

func (col *Int16) Decode(reader *proto.Reader, rows int) error

func (*Int16) Encode 

func (col *Int16) Encode(buffer *proto.Buffer)

func (*Int16) Name added in v2.1.0 

func (col *Int16) Name() string

func (*Int16) Reset added in v2.3.0 

func (col *Int16) Reset()

func (*Int16) Row 

func (col *Int16) Row(i int, ptr bool) any

func (*Int16) Rows 

func (col *Int16) Rows() int

func (*Int16) ScanRow 

func (col *Int16) ScanRow(dest any, row int) error

func (*Int16) ScanType 

func (col *Int16) ScanType() reflect.Type

func (*Int16) Type 

func (col *Int16) Type() Type

type Int32 

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

func (*Int32) Append 

func (col *Int32) Append(v any) (nulls []uint8, err error)

func (*Int32) AppendRow 

func (col *Int32) AppendRow(v any) error

func (*Int32) Decode 

func (col *Int32) Decode(reader *proto.Reader, rows int) error

func (*Int32) Encode 

func (col *Int32) Encode(buffer *proto.Buffer)

func (*Int32) Name added in v2.1.0 

func (col *Int32) Name() string

func (*Int32) Reset added in v2.3.0 

func (col *Int32) Reset()

func (*Int32) Row 

func (col *Int32) Row(i int, ptr bool) any

func (*Int32) Rows 

func (col *Int32) Rows() int

func (*Int32) ScanRow 

func (col *Int32) ScanRow(dest any, row int) error

func (*Int32) ScanType 

func (col *Int32) ScanType() reflect.Type

func (*Int32) Type 

func (col *Int32) Type() Type

type Int64 

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

func (*Int64) Append 

func (col *Int64) Append(v any) (nulls []uint8, err error)

func (*Int64) AppendRow 

func (col *Int64) AppendRow(v any) error

func (*Int64) Decode 

func (col *Int64) Decode(reader *proto.Reader, rows int) error

func (*Int64) Encode 

func (col *Int64) Encode(buffer *proto.Buffer)

func (*Int64) Name added in v2.1.0 

func (col *Int64) Name() string

func (*Int64) Reset added in v2.3.0 

func (col *Int64) Reset()

func (*Int64) Row 

func (col *Int64) Row(i int, ptr bool) any

func (*Int64) Rows 

func (col *Int64) Rows() int

func (*Int64) ScanRow 

func (col *Int64) ScanRow(dest any, row int) error

func (*Int64) ScanType 

func (col *Int64) ScanType() reflect.Type

func (*Int64) Type 

func (col *Int64) Type() Type

type Int8 

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

func (*Int8) Append 

func (col *Int8) Append(v any) (nulls []uint8, err error)

func (*Int8) AppendRow 

func (col *Int8) AppendRow(v any) error

func (*Int8) Decode 

func (col *Int8) Decode(reader *proto.Reader, rows int) error

func (*Int8) Encode 

func (col *Int8) Encode(buffer *proto.Buffer)

func (*Int8) Name added in v2.1.0 

func (col *Int8) Name() string

func (*Int8) Reset added in v2.3.0 

func (col *Int8) Reset()

func (*Int8) Row 

func (col *Int8) Row(i int, ptr bool) any

func (*Int8) Rows 

func (col *Int8) Rows() int

func (*Int8) ScanRow 

func (col *Int8) ScanRow(dest any, row int) error

func (*Int8) ScanType 

func (col *Int8) ScanType() reflect.Type

func (*Int8) Type 

func (col *Int8) Type() Type

type Interface 

type Interface interface {
	Name() string
	Type() Type
	Rows() int
	Row(i int, ptr bool) any
	ScanRow(dest any, row int) error
	Append(v any) (nulls []uint8, err error)
	AppendRow(v any) error
	Decode(reader *proto.Reader, rows int) error
	Encode(buffer *proto.Buffer)
	ScanType() reflect.Type
	Reset()
}

func Enum 

func Enum(chType Type, name string) (Interface, error)

type Interval 

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

func (Interval) Append 

func (Interval) Append(any) ([]uint8, error)

func (Interval) AppendRow 

func (Interval) AppendRow(any) error

func (*Interval) Decode 

func (col *Interval) Decode(reader *proto.Reader, rows int) error

func (Interval) Encode 

func (Interval) Encode(buffer *proto.Buffer)

func (*Interval) Name added in v2.1.0 

func (col *Interval) Name() string

func (*Interval) Reset added in v2.3.0 

func (col *Interval) Reset()

func (*Interval) Row 

func (col *Interval) Row(i int, ptr bool) any

func (*Interval) Rows 

func (col *Interval) Rows() int

func (*Interval) ScanRow 

func (col *Interval) ScanRow(dest any, row int) error

func (*Interval) ScanType 

func (col *Interval) ScanType() reflect.Type

func (*Interval) Type 

func (col *Interval) Type() Type

type IterableOrderedMap added in v2.17.0 

type IterableOrderedMap interface {
	Put(key any, value any)
	Iterator() MapIterator
}

type JSON added in v2.1.0 

type JSON interface {
	Interface
	// contains filtered or unexported methods
}

type JSONList added in v2.1.0 

type JSONList struct {
	Array
	// contains filtered or unexported fields
}

func (*JSONList) Name added in v2.1.0 

func (jCol *JSONList) Name() string

func (*JSONList) Type added in v2.1.0 

func (jCol *JSONList) Type() Type

type JSONObject added in v2.1.0 

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

func (*JSONObject) Append added in v2.1.0 

func (jCol *JSONObject) Append(v any) (nulls []uint8, err error)

func (*JSONObject) AppendRow added in v2.1.0 

func (jCol *JSONObject) AppendRow(v any) error

func (*JSONObject) Decode added in v2.1.0 

func (jCol *JSONObject) Decode(reader *proto.Reader, rows int) error

func (*JSONObject) Encode added in v2.1.0 

func (jCol *JSONObject) Encode(buffer *proto.Buffer)

func (*JSONObject) FullType added in v2.1.0 

func (jCol *JSONObject) FullType() Type

func (*JSONObject) Name added in v2.1.0 

func (jCol *JSONObject) Name() string

func (*JSONObject) ReadStatePrefix added in v2.1.0 

func (jCol *JSONObject) ReadStatePrefix(reader *proto.Reader) error

func (*JSONObject) Reset added in v2.3.0 

func (jCol *JSONObject) Reset()

func (*JSONObject) Row added in v2.1.0 

func (jCol *JSONObject) Row(i int, ptr bool) any

func (*JSONObject) Rows added in v2.1.0 

func (jCol *JSONObject) Rows() int

func (*JSONObject) ScanRow added in v2.1.0 

func (jCol *JSONObject) ScanRow(dest any, row int) error

func (*JSONObject) ScanType added in v2.1.0 

func (jCol *JSONObject) ScanType() reflect.Type

func (*JSONObject) Type added in v2.1.0 

func (jCol *JSONObject) Type() Type

func (*JSONObject) WriteStatePrefix added in v2.1.0 

func (jCol *JSONObject) WriteStatePrefix(buffer *proto.Buffer) error

type JSONParent added in v2.1.0 

type JSONParent interface {
	// contains filtered or unexported methods
}

type JSONValue added in v2.1.0 

type JSONValue struct {
	Interface
	// contains filtered or unexported fields
}

func (*JSONValue) Reset added in v2.3.0 

func (jCol *JSONValue) Reset()

func (*JSONValue) Type added in v2.1.0 

func (jCol *JSONValue) Type() Type

type LowCardinality 

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

https://github.com/ClickHouse/ClickHouse/blob/master/src/Columns/ColumnLowCardinality.cpp https://github.com/ClickHouse/clickhouse-cpp/blob/master/clickhouse/columns/lowcardinality.cpp

func (*LowCardinality) Append 

func (col *LowCardinality) Append(v any) (nulls []uint8, err error)

func (*LowCardinality) AppendRow 

func (col *LowCardinality) AppendRow(v any) error

func (*LowCardinality) Decode 

func (col *LowCardinality) Decode(reader *proto.Reader, rows int) error

func (*LowCardinality) Encode 

func (col *LowCardinality) Encode(buffer *proto.Buffer)

func (*LowCardinality) Name added in v2.1.0 

func (col *LowCardinality) Name() string

func (*LowCardinality) ReadStatePrefix 

func (col *LowCardinality) ReadStatePrefix(reader *proto.Reader) error

func (*LowCardinality) Reset added in v2.3.0 

func (col *LowCardinality) Reset()

func (*LowCardinality) Row 

func (col *LowCardinality) Row(i int, ptr bool) any

func (*LowCardinality) Rows 

func (col *LowCardinality) Rows() int

func (*LowCardinality) ScanRow 

func (col *LowCardinality) ScanRow(dest any, row int) error

func (*LowCardinality) ScanType 

func (col *LowCardinality) ScanType() reflect.Type

func (*LowCardinality) Type 

func (col *LowCardinality) Type() Type

func (*LowCardinality) WriteStatePrefix 

func (col *LowCardinality) WriteStatePrefix(buffer *proto.Buffer) error

type Map 

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

https://github.com/ClickHouse/ClickHouse/blob/master/src/Columns/ColumnMap.cpp

func (*Map) Append 

func (col *Map) Append(v any) (nulls []uint8, err error)

func (*Map) AppendRow 

func (col *Map) AppendRow(v any) error

func (*Map) Decode 

func (col *Map) Decode(reader *proto.Reader, rows int) error

func (*Map) Encode 

func (col *Map) Encode(buffer *proto.Buffer)

func (*Map) Name added in v2.1.0 

func (col *Map) Name() string

func (*Map) ReadStatePrefix 

func (col *Map) ReadStatePrefix(reader *proto.Reader) error

func (*Map) Reset added in v2.3.0 

func (col *Map) Reset()

func (*Map) Row 

func (col *Map) Row(i int, ptr bool) any

func (*Map) Rows 

func (col *Map) Rows() int

func (*Map) ScanRow 

func (col *Map) ScanRow(dest any, i int) error

func (*Map) ScanType 

func (col *Map) ScanType() reflect.Type

func (*Map) Type 

func (col *Map) Type() Type

func (*Map) WriteStatePrefix 

func (col *Map) WriteStatePrefix(encoder *proto.Buffer) error

type MapIterator added in v2.17.0 

type MapIterator interface {
	Next() bool
	Key() any
	Value() any
}

type MultiPolygon 

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

func (*MultiPolygon) Append 

func (col *MultiPolygon) Append(v any) (nulls []uint8, err error)

func (*MultiPolygon) AppendRow 

func (col *MultiPolygon) AppendRow(v any) error

func (*MultiPolygon) Decode 

func (col *MultiPolygon) Decode(reader *proto.Reader, rows int) error

func (*MultiPolygon) Encode 

func (col *MultiPolygon) Encode(buffer *proto.Buffer)

func (*MultiPolygon) Name added in v2.1.0 

func (col *MultiPolygon) Name() string

func (*MultiPolygon) Reset added in v2.3.0 

func (col *MultiPolygon) Reset()

func (*MultiPolygon) Row 

func (col *MultiPolygon) Row(i int, ptr bool) any

func (*MultiPolygon) Rows 

func (col *MultiPolygon) Rows() int

func (*MultiPolygon) ScanRow 

func (col *MultiPolygon) ScanRow(dest any, row int) error

func (*MultiPolygon) ScanType 

func (col *MultiPolygon) ScanType() reflect.Type

func (*MultiPolygon) Type 

func (col *MultiPolygon) Type() Type

type Nested added in v2.0.9 

type Nested struct {
	Interface
	// contains filtered or unexported fields
}

func (*Nested) Reset added in v2.3.0 

func (col *Nested) Reset()

type Nothing 

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

func (Nothing) Append 

func (Nothing) Append(any) ([]uint8, error)

func (Nothing) AppendRow 

func (col Nothing) AppendRow(any) error

func (Nothing) Decode 

func (col Nothing) Decode(reader *proto.Reader, rows int) error

func (Nothing) Encode 

func (Nothing) Encode(buffer *proto.Buffer)

func (Nothing) Name added in v2.1.0 

func (col Nothing) Name() string

func (*Nothing) Reset added in v2.3.0 

func (col *Nothing) Reset()

func (Nothing) Row 

func (Nothing) Row(int, bool) any

func (Nothing) Rows 

func (Nothing) Rows() int

func (Nothing) ScanRow 

func (Nothing) ScanRow(any, int) error

func (Nothing) ScanType 

func (Nothing) ScanType() reflect.Type

func (Nothing) Type 

func (Nothing) Type() Type

type Nullable 

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

func (*Nullable) Append 

func (col *Nullable) Append(v any) ([]uint8, error)

func (*Nullable) AppendRow 

func (col *Nullable) AppendRow(v any) error

func (*Nullable) Base 

func (col *Nullable) Base() Interface

func (*Nullable) Decode 

func (col *Nullable) Decode(reader *proto.Reader, rows int) error

func (*Nullable) Encode 

func (col *Nullable) Encode(buffer *proto.Buffer)

func (*Nullable) Name added in v2.1.0 

func (col *Nullable) Name() string

func (*Nullable) Reset added in v2.3.0 

func (col *Nullable) Reset()

func (*Nullable) Row 

func (col *Nullable) Row(i int, ptr bool) any

func (*Nullable) Rows 

func (col *Nullable) Rows() int

func (*Nullable) ScanRow 

func (col *Nullable) ScanRow(dest any, row int) error

func (*Nullable) ScanType 

func (col *Nullable) ScanType() reflect.Type

func (*Nullable) Type 

func (col *Nullable) Type() Type

type OrderedMap added in v2.4.0 

type OrderedMap interface {
	Get(key any) (any, bool)
	Put(key any, value any)
	Keys() <-chan any
}

type Point 

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

func (*Point) Append 

func (col *Point) Append(v any) (nulls []uint8, err error)

func (*Point) AppendRow 

func (col *Point) AppendRow(v any) error

func (*Point) Decode 

func (col *Point) Decode(reader *proto.Reader, rows int) error

func (*Point) Encode 

func (col *Point) Encode(buffer *proto.Buffer)

func (*Point) Name added in v2.1.0 

func (col *Point) Name() string

func (*Point) Reset added in v2.3.0 

func (col *Point) Reset()

func (*Point) Row 

func (col *Point) Row(i int, ptr bool) any

func (*Point) Rows 

func (col *Point) Rows() int

func (*Point) ScanRow 

func (col *Point) ScanRow(dest any, row int) error

func (*Point) ScanType 

func (col *Point) ScanType() reflect.Type

func (*Point) Type 

func (col *Point) Type() Type

type Polygon 

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

func (*Polygon) Append 

func (col *Polygon) Append(v any) (nulls []uint8, err error)

func (*Polygon) AppendRow 

func (col *Polygon) AppendRow(v any) error

func (*Polygon) Decode 

func (col *Polygon) Decode(reader *proto.Reader, rows int) error

func (*Polygon) Encode 

func (col *Polygon) Encode(buffer *proto.Buffer)

func (*Polygon) Name added in v2.1.0 

func (col *Polygon) Name() string

func (*Polygon) Reset added in v2.3.0 

func (col *Polygon) Reset()

func (*Polygon) Row 

func (col *Polygon) Row(i int, ptr bool) any

func (*Polygon) Rows 

func (col *Polygon) Rows() int

func (*Polygon) ScanRow 

func (col *Polygon) ScanRow(dest any, row int) error

func (*Polygon) ScanType 

func (col *Polygon) ScanType() reflect.Type

func (*Polygon) Type 

func (col *Polygon) Type() Type

type Ring 

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

func (*Ring) Append 

func (col *Ring) Append(v any) (nulls []uint8, err error)

func (*Ring) AppendRow 

func (col *Ring) AppendRow(v any) error

func (*Ring) Decode 

func (col *Ring) Decode(reader *proto.Reader, rows int) error

func (*Ring) Encode 

func (col *Ring) Encode(buffer *proto.Buffer)

func (*Ring) Name added in v2.1.0 

func (col *Ring) Name() string

func (*Ring) Reset added in v2.3.0 

func (col *Ring) Reset()

func (*Ring) Row 

func (col *Ring) Row(i int, ptr bool) any

func (*Ring) Rows 

func (col *Ring) Rows() int

func (*Ring) ScanRow 

func (col *Ring) ScanRow(dest any, row int) error

func (*Ring) ScanType 

func (col *Ring) ScanType() reflect.Type

func (*Ring) Type 

func (col *Ring) Type() Type

type SimpleAggregateFunction 

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

func (*SimpleAggregateFunction) Append 

func (col *SimpleAggregateFunction) Append(v any) ([]uint8, error)

func (*SimpleAggregateFunction) AppendRow 

func (col *SimpleAggregateFunction) AppendRow(v any) error

func (*SimpleAggregateFunction) Decode 

func (col *SimpleAggregateFunction) Decode(reader *proto.Reader, rows int) error

func (*SimpleAggregateFunction) Encode 

func (col *SimpleAggregateFunction) Encode(buffer *proto.Buffer)

func (*SimpleAggregateFunction) Name added in v2.1.0 

func (col *SimpleAggregateFunction) Name() string

func (*SimpleAggregateFunction) Reset added in v2.3.0 

func (col *SimpleAggregateFunction) Reset()

func (*SimpleAggregateFunction) Row 

func (col *SimpleAggregateFunction) Row(i int, ptr bool) any

func (*SimpleAggregateFunction) Rows 

func (col *SimpleAggregateFunction) Rows() int

func (*SimpleAggregateFunction) ScanRow 

func (col *SimpleAggregateFunction) ScanRow(dest any, rows int) error

func (*SimpleAggregateFunction) ScanType 

func (col *SimpleAggregateFunction) ScanType() reflect.Type

func (*SimpleAggregateFunction) Type 

func (col *SimpleAggregateFunction) Type() Type

type String 

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

func (*String) Append 

func (col *String) Append(v any) (nulls []uint8, err error)

func (*String) AppendRow 

func (col *String) AppendRow(v any) error

func (*String) Decode 

func (col *String) Decode(reader *proto.Reader, rows int) error

func (*String) Encode 

func (col *String) Encode(buffer *proto.Buffer)

func (String) Name added in v2.1.0 

func (col String) Name() string

func (*String) Reset added in v2.3.0 

func (col *String) Reset()

func (*String) Row 

func (col *String) Row(i int, ptr bool) any

func (*String) Rows 

func (col *String) Rows() int

func (*String) ScanRow 

func (col *String) ScanRow(dest any, row int) error

func (String) ScanType 

func (String) ScanType() reflect.Type

func (String) Type 

func (String) Type() Type

type Tuple 

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

func (*Tuple) Append 

func (col *Tuple) Append(v any) (nulls []uint8, err error)

func (*Tuple) AppendRow 

func (col *Tuple) AppendRow(v any) error

func (*Tuple) Decode 

func (col *Tuple) Decode(reader *proto.Reader, rows int) error

func (*Tuple) Encode 

func (col *Tuple) Encode(buffer *proto.Buffer)

func (*Tuple) Name added in v2.1.0 

func (col *Tuple) Name() string

func (*Tuple) ReadStatePrefix 

func (col *Tuple) ReadStatePrefix(reader *proto.Reader) error

func (*Tuple) Reset added in v2.3.0 

func (col *Tuple) Reset()

func (*Tuple) Row 

func (col *Tuple) Row(i int, ptr bool) any

func (*Tuple) Rows 

func (col *Tuple) Rows() int

func (*Tuple) ScanRow 

func (col *Tuple) ScanRow(dest any, row int) error

func (Tuple) ScanType 

func (col Tuple) ScanType() reflect.Type

func (*Tuple) Type 

func (col *Tuple) Type() Type

func (*Tuple) WriteStatePrefix 

func (col *Tuple) WriteStatePrefix(buffer *proto.Buffer) error

type Type 

type Type string

func (Type) Column 

func (t Type) Column(name string, tz *time.Location) (Interface, error)

type UInt16 

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

func (*UInt16) Append 

func (col *UInt16) Append(v any) (nulls []uint8, err error)

func (*UInt16) AppendRow 

func (col *UInt16) AppendRow(v any) error

func (*UInt16) Decode 

func (col *UInt16) Decode(reader *proto.Reader, rows int) error

func (*UInt16) Encode 

func (col *UInt16) Encode(buffer *proto.Buffer)

func (*UInt16) Name added in v2.1.0 

func (col *UInt16) Name() string

func (*UInt16) Reset added in v2.3.0 

func (col *UInt16) Reset()

func (*UInt16) Row 

func (col *UInt16) Row(i int, ptr bool) any

func (*UInt16) Rows 

func (col *UInt16) Rows() int

func (*UInt16) ScanRow 

func (col *UInt16) ScanRow(dest any, row int) error

func (*UInt16) ScanType 

func (col *UInt16) ScanType() reflect.Type

func (*UInt16) Type 

func (col *UInt16) Type() Type

type UInt32 

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

func (*UInt32) Append 

func (col *UInt32) Append(v any) (nulls []uint8, err error)

func (*UInt32) AppendRow 

func (col *UInt32) AppendRow(v any) error

func (*UInt32) Decode 

func (col *UInt32) Decode(reader *proto.Reader, rows int) error

func (*UInt32) Encode 

func (col *UInt32) Encode(buffer *proto.Buffer)

func (*UInt32) Name added in v2.1.0 

func (col *UInt32) Name() string

func (*UInt32) Reset added in v2.3.0 

func (col *UInt32) Reset()

func (*UInt32) Row 

func (col *UInt32) Row(i int, ptr bool) any

func (*UInt32) Rows 

func (col *UInt32) Rows() int

func (*UInt32) ScanRow 

func (col *UInt32) ScanRow(dest any, row int) error

func (*UInt32) ScanType 

func (col *UInt32) ScanType() reflect.Type

func (*UInt32) Type 

func (col *UInt32) Type() Type

type UInt64 

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

func (*UInt64) Append 

func (col *UInt64) Append(v any) (nulls []uint8, err error)

func (*UInt64) AppendRow 

func (col *UInt64) AppendRow(v any) error

func (*UInt64) Decode 

func (col *UInt64) Decode(reader *proto.Reader, rows int) error

func (*UInt64) Encode 

func (col *UInt64) Encode(buffer *proto.Buffer)

func (*UInt64) Name added in v2.1.0 

func (col *UInt64) Name() string

func (*UInt64) Reset added in v2.3.0 

func (col *UInt64) Reset()

func (*UInt64) Row 

func (col *UInt64) Row(i int, ptr bool) any

func (*UInt64) Rows 

func (col *UInt64) Rows() int

func (*UInt64) ScanRow 

func (col *UInt64) ScanRow(dest any, row int) error

func (*UInt64) ScanType 

func (col *UInt64) ScanType() reflect.Type

func (*UInt64) Type 

func (col *UInt64) Type() Type

type UInt8 

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

func (*UInt8) Append 

func (col *UInt8) Append(v any) (nulls []uint8, err error)

func (*UInt8) AppendRow 

func (col *UInt8) AppendRow(v any) error

func (*UInt8) Decode 

func (col *UInt8) Decode(reader *proto.Reader, rows int) error

func (*UInt8) Encode 

func (col *UInt8) Encode(buffer *proto.Buffer)

func (*UInt8) Name added in v2.1.0 

func (col *UInt8) Name() string

func (*UInt8) Reset added in v2.3.0 

func (col *UInt8) Reset()

func (*UInt8) Row 

func (col *UInt8) Row(i int, ptr bool) any

func (*UInt8) Rows 

func (col *UInt8) Rows() int

func (*UInt8) ScanRow 

func (col *UInt8) ScanRow(dest any, row int) error

func (*UInt8) ScanType 

func (col *UInt8) ScanType() reflect.Type

func (*UInt8) Type 

func (col *UInt8) Type() Type

type UUID 

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

func (*UUID) Append 

func (col *UUID) Append(v any) (nulls []uint8, err error)

func (*UUID) AppendRow 

func (col *UUID) AppendRow(v any) error

func (*UUID) Decode 

func (col *UUID) Decode(reader *proto.Reader, rows int) error

func (*UUID) Encode 

func (col *UUID) Encode(buffer *proto.Buffer)

func (*UUID) Name added in v2.1.0 

func (col *UUID) Name() string

func (*UUID) Reset added in v2.3.0 

func (col *UUID) Reset()

func (*UUID) Row 

func (col *UUID) Row(i int, ptr bool) any

func (*UUID) Rows 

func (col *UUID) Rows() int

func (*UUID) ScanRow 

func (col *UUID) ScanRow(dest any, row int) error

func (*UUID) ScanType 

func (col *UUID) ScanType() reflect.Type

func (*UUID) Type 

func (col *UUID) Type() Type

type UnsupportedColumnTypeError added in v2.0.10 

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

func (*UnsupportedColumnTypeError) Error added in v2.0.10 

func (e *UnsupportedColumnTypeError) Error() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.