package column

import "github.com/ClickHouse/clickhouse-go/v2/lib/column"

Index

Constants 

const (
	E
)

Functions

func IPv6ToBytes 

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

func WithAllocBufferColStrProvider 

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 

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 

func (col *Array) Name() string

func (*Array) ReadStatePrefix 

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

func (*Array) Reset 

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 

func (col *BigInt) Name() string

func (*BigInt) Reset 

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 

func (col *Bool) Name() string

func (*Bool) Reset 

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 

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 

func (col *Date) Name() string

func (*Date) Reset 

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 

func (col *Date32) Name() string

func (*Date32) Reset 

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 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 

func (col *DateTime) Name() string

func (*DateTime) Reset 

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 

func (col *DateTime64) Name() string

func (*DateTime64) Reset 

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 

func (col *Decimal) Name() string

func (*Decimal) Precision 

func (col *Decimal) Precision() int64

func (*Decimal) Reset 

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 

func (col *Enum16) Name() string

func (*Enum16) Reset 

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 

func (col *Enum8) Name() string

func (*Enum8) Reset 

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 

func (col *FixedString) Name() string

func (*FixedString) Reset 

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 

func (col *Float32) Name() string

func (*Float32) Reset 

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 

func (col *Float64) Name() string

func (*Float64) Reset 

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 

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 

func (col *IPv4) Name() string

func (*IPv4) Reset 

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 

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 

func (col *IPv6) Name() string

func (*IPv6) Reset 

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 

func (col *Int16) Name() string

func (*Int16) Reset 

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 

func (col *Int32) Name() string

func (*Int32) Reset 

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 

func (col *Int64) Name() string

func (*Int64) Reset 

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 

func (col *Int8) Name() string

func (*Int8) Reset 

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 

func (col *Interval) Name() string

func (*Interval) Reset 

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 

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

type JSON 

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

type JSONList 

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

func (*JSONList) Name 

func (jCol *JSONList) Name() string

func (*JSONList) Type 

func (jCol *JSONList) Type() Type

type JSONObject 

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

func (*JSONObject) Append 

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

func (*JSONObject) AppendRow 

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

func (*JSONObject) Decode 

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

func (*JSONObject) Encode 

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

func (*JSONObject) FullType 

func (jCol *JSONObject) FullType() Type

func (*JSONObject) Name 

func (jCol *JSONObject) Name() string

func (*JSONObject) ReadStatePrefix 

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

func (*JSONObject) Reset 

func (jCol *JSONObject) Reset()

func (*JSONObject) Row 

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

func (*JSONObject) Rows 

func (jCol *JSONObject) Rows() int

func (*JSONObject) ScanRow 

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

func (*JSONObject) ScanType 

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

func (*JSONObject) Type 

func (jCol *JSONObject) Type() Type

func (*JSONObject) WriteStatePrefix 

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

type JSONParent 

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

type JSONValue 

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

func (*JSONValue) Reset 

func (jCol *JSONValue) Reset()

func (*JSONValue) Type 

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 

func (col *LowCardinality) Name() string

func (*LowCardinality) ReadStatePrefix 

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

func (*LowCardinality) Reset 

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 

func (col *Map) Name() string

func (*Map) ReadStatePrefix 

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

func (*Map) Reset 

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 

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 

func (col *MultiPolygon) Name() string

func (*MultiPolygon) Reset 

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 

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

func (*Nested) ReadStatePrefix 

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

func (*Nested) Reset 

func (col *Nested) Reset()

func (*Nested) WriteStatePrefix 

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

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 

func (col Nothing) Name() string

func (*Nothing) Reset 

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 

func (col *Nullable) Name() string

func (*Nullable) Reset 

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 

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 

func (col *Point) Name() string

func (*Point) Reset 

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 

func (col *Polygon) Name() string

func (*Polygon) Reset 

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 

func (col *Ring) Name() string

func (*Ring) Reset 

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 

func (col *SimpleAggregateFunction) Name() string

func (*SimpleAggregateFunction) Reset 

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 

func (col String) Name() string

func (*String) Reset 

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 

func (col *Tuple) Name() string

func (*Tuple) ReadStatePrefix 

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

func (*Tuple) Reset 

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 

func (col *UInt16) Name() string

func (*UInt16) Reset 

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 

func (col *UInt32) Name() string

func (*UInt32) Reset 

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 

func (col *UInt64) Name() string

func (*UInt64) Reset 

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 

func (col *UInt8) Name() string

func (*UInt8) Reset 

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 

func (col *UUID) Name() string

func (*UUID) Reset 

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 

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

func (*UnsupportedColumnTypeError) Error 

func (e *UnsupportedColumnTypeError) Error() string

Source Files

array.go array_gen.go bigint.go bool.go column.go column_gen.go column_gen_option.go date.go date32.go datetime.go datetime64.go decimal.go enum.go enum16.go enum8.go fixed_string.go geo_multi_polygon.go geo_point.go geo_polygon.go geo_ring.go interval.go ipv4.go ipv6.go json.go lowcardinality.go map.go nested.go nothing.go nullable.go simple_aggregate_function.go slice_helper.go string.go time_helper.go tuple.go uuid.go

Directories

PathSynopsis
lib/column/codegen
Version
v2.28.1
Published
Aug 27, 2024
Platform
linux/amd64
Imports
22 packages
Last checked
1 hour ago –

Tools for package owners.