column

package
v2.3.2 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2022 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IPv6ToBytes 

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

Types

type Array 

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

func (*Array) Append 

func (col *Array) Append(v interface{}) (nulls []uint8, err error)

func (*Array) AppendRow 

func (col *Array) AppendRow(v interface{}) 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) interface{}

func (*Array) Rows 

func (col *Array) Rows() int

func (*Array) ScanRow 

func (col *Array) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*BigInt) AppendRow 

func (col *BigInt) AppendRow(v interface{}) 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) interface{}

func (*BigInt) Rows 

func (col *BigInt) Rows() int

func (*BigInt) ScanRow 

func (col *BigInt) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Bool) AppendRow 

func (col *Bool) AppendRow(v interface{}) 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) interface{}

func (*Bool) Rows 

func (col *Bool) Rows() int

func (*Bool) ScanRow 

func (col *Bool) ScanRow(dest interface{}, row int) error

func (*Bool) ScanType 

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

func (*Bool) Type 

func (col *Bool) Type() Type

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 interface{}) (nulls []uint8, err error)

func (*Date) AppendRow 

func (col *Date) AppendRow(v interface{}) 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) interface{}

func (*Date) Rows 

func (col *Date) Rows() int

func (*Date) ScanRow 

func (col *Date) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Date32) AppendRow 

func (col *Date32) AppendRow(v interface{}) 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) interface{}

func (*Date32) Rows 

func (col *Date32) Rows() int

func (*Date32) ScanRow 

func (col *Date32) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*DateTime) AppendRow 

func (col *DateTime) AppendRow(v interface{}) 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) interface{}

func (*DateTime) Rows 

func (col *DateTime) Rows() int

func (*DateTime) ScanRow 

func (col *DateTime) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*DateTime64) AppendRow 

func (col *DateTime64) AppendRow(v interface{}) 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) interface{}

func (*DateTime64) Rows 

func (col *DateTime64) Rows() int

func (*DateTime64) ScanRow 

func (col *DateTime64) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Decimal) AppendRow 

func (col *Decimal) AppendRow(v interface{}) 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) interface{}

func (*Decimal) Rows 

func (col *Decimal) Rows() int

func (*Decimal) Scale 

func (col *Decimal) Scale() int64

func (*Decimal) ScanRow 

func (col *Decimal) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Enum16) AppendRow 

func (col *Enum16) AppendRow(elem interface{}) 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) interface{}

func (*Enum16) Rows 

func (col *Enum16) Rows() int

func (*Enum16) ScanRow 

func (col *Enum16) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Enum8) AppendRow 

func (col *Enum8) AppendRow(elem interface{}) 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) interface{}

func (*Enum8) Rows 

func (col *Enum8) Rows() int

func (*Enum8) ScanRow 

func (col *Enum8) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*FixedString) AppendRow 

func (col *FixedString) AppendRow(v interface{}) (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) interface{}

func (*FixedString) Rows 

func (col *FixedString) Rows() int

func (*FixedString) ScanRow 

func (col *FixedString) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Float32) AppendRow 

func (col *Float32) AppendRow(v interface{}) 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) interface{}

func (*Float32) Rows 

func (col *Float32) Rows() int

func (*Float32) ScanRow 

func (col *Float32) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Float64) AppendRow 

func (col *Float64) AppendRow(v interface{}) 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) interface{}

func (*Float64) Rows 

func (col *Float64) Rows() int

func (*Float64) ScanRow 

func (col *Float64) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*IPv4) AppendRow 

func (col *IPv4) AppendRow(v interface{}) (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) interface{}

func (*IPv4) Rows 

func (col *IPv4) Rows() int

func (*IPv4) ScanRow 

func (col *IPv4) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*IPv6) AppendRow 

func (col *IPv6) AppendRow(v interface{}) (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) interface{}

func (*IPv6) Rows 

func (col *IPv6) Rows() int

func (*IPv6) ScanRow 

func (col *IPv6) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Int16) AppendRow 

func (col *Int16) AppendRow(v interface{}) 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) interface{}

func (*Int16) Rows 

func (col *Int16) Rows() int

func (*Int16) ScanRow 

func (col *Int16) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Int32) AppendRow 

func (col *Int32) AppendRow(v interface{}) 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) interface{}

func (*Int32) Rows 

func (col *Int32) Rows() int

func (*Int32) ScanRow 

func (col *Int32) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Int64) AppendRow 

func (col *Int64) AppendRow(v interface{}) 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) interface{}

func (*Int64) Rows 

func (col *Int64) Rows() int

func (*Int64) ScanRow 

func (col *Int64) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Int8) AppendRow 

func (col *Int8) AppendRow(v interface{}) 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) interface{}

func (*Int8) Rows 

func (col *Int8) Rows() int

func (*Int8) ScanRow 

func (col *Int8) ScanRow(dest interface{}, 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) interface{}
	ScanRow(dest interface{}, row int) error
	Append(v interface{}) (nulls []uint8, err error)
	AppendRow(v interface{}) 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(interface{}) ([]uint8, error)

func (Interval) AppendRow 

func (Interval) AppendRow(interface{}) 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) interface{}

func (*Interval) Rows 

func (col *Interval) Rows() int

func (*Interval) ScanRow 

func (col *Interval) ScanRow(dest interface{}, row int) error

func (*Interval) ScanType 

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

func (*Interval) Type 

func (col *Interval) Type() Type

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 interface{}) (nulls []uint8, err error)

func (*JSONObject) AppendRow 

func (jCol *JSONObject) AppendRow(v interface{}) 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) interface{}

func (*JSONObject) Rows 

func (jCol *JSONObject) Rows() int

func (*JSONObject) ScanRow 

func (jCol *JSONObject) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*LowCardinality) AppendRow 

func (col *LowCardinality) AppendRow(v interface{}) 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) interface{}

func (*LowCardinality) Rows 

func (col *LowCardinality) Rows() int

func (*LowCardinality) ScanRow 

func (col *LowCardinality) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Map) AppendRow 

func (col *Map) AppendRow(v interface{}) 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) interface{}

func (*Map) Rows 

func (col *Map) Rows() int

func (*Map) ScanRow 

func (col *Map) ScanRow(dest interface{}, 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 MultiPolygon 

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

func (*MultiPolygon) Append 

func (col *MultiPolygon) Append(v interface{}) (nulls []uint8, err error)

func (*MultiPolygon) AppendRow 

func (col *MultiPolygon) AppendRow(v interface{}) 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) interface{}

func (*MultiPolygon) Rows 

func (col *MultiPolygon) Rows() int

func (*MultiPolygon) ScanRow 

func (col *MultiPolygon) ScanRow(dest interface{}, 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) Reset 

func (col *Nested) Reset()

type Nothing 

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

func (Nothing) Append 

func (Nothing) Append(interface{}) ([]uint8, error)

func (Nothing) AppendRow 

func (col Nothing) AppendRow(interface{}) 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) interface{}

func (Nothing) Rows 

func (Nothing) Rows() int

func (Nothing) ScanRow 

func (Nothing) ScanRow(interface{}, 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 interface{}) ([]uint8, error)

func (*Nullable) AppendRow 

func (col *Nullable) AppendRow(v interface{}) 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) interface{}

func (*Nullable) Rows 

func (col *Nullable) Rows() int

func (*Nullable) ScanRow 

func (col *Nullable) ScanRow(dest interface{}, 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 interface{}) (interface{}, bool)
	Put(key interface{}, value interface{})
	Keys() <-chan interface{}
}

type Point 

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

func (*Point) Append 

func (col *Point) Append(v interface{}) (nulls []uint8, err error)

func (*Point) AppendRow 

func (col *Point) AppendRow(v interface{}) 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) interface{}

func (*Point) Rows 

func (col *Point) Rows() int

func (*Point) ScanRow 

func (col *Point) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Polygon) AppendRow 

func (col *Polygon) AppendRow(v interface{}) 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) interface{}

func (*Polygon) Rows 

func (col *Polygon) Rows() int

func (*Polygon) ScanRow 

func (col *Polygon) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Ring) AppendRow 

func (col *Ring) AppendRow(v interface{}) 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) interface{}

func (*Ring) Rows 

func (col *Ring) Rows() int

func (*Ring) ScanRow 

func (col *Ring) ScanRow(dest interface{}, 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 interface{}) ([]uint8, error)

func (*SimpleAggregateFunction) AppendRow 

func (col *SimpleAggregateFunction) AppendRow(v interface{}) 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) interface{}

func (*SimpleAggregateFunction) Rows 

func (col *SimpleAggregateFunction) Rows() int

func (*SimpleAggregateFunction) ScanRow 

func (col *SimpleAggregateFunction) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*String) AppendRow 

func (col *String) AppendRow(v interface{}) 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) interface{}

func (*String) Rows 

func (col *String) Rows() int

func (*String) ScanRow 

func (col *String) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*Tuple) AppendRow 

func (col *Tuple) AppendRow(v interface{}) 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) interface{}

func (*Tuple) Rows 

func (col *Tuple) Rows() int

func (*Tuple) ScanRow 

func (col *Tuple) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*UInt16) AppendRow 

func (col *UInt16) AppendRow(v interface{}) 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) interface{}

func (*UInt16) Rows 

func (col *UInt16) Rows() int

func (*UInt16) ScanRow 

func (col *UInt16) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*UInt32) AppendRow 

func (col *UInt32) AppendRow(v interface{}) 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) interface{}

func (*UInt32) Rows 

func (col *UInt32) Rows() int

func (*UInt32) ScanRow 

func (col *UInt32) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*UInt64) AppendRow 

func (col *UInt64) AppendRow(v interface{}) 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) interface{}

func (*UInt64) Rows 

func (col *UInt64) Rows() int

func (*UInt64) ScanRow 

func (col *UInt64) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*UInt8) AppendRow 

func (col *UInt8) AppendRow(v interface{}) 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) interface{}

func (*UInt8) Rows 

func (col *UInt8) Rows() int

func (*UInt8) ScanRow 

func (col *UInt8) ScanRow(dest interface{}, 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 interface{}) (nulls []uint8, err error)

func (*UUID) AppendRow 

func (col *UUID) AppendRow(v interface{}) 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) interface{}

func (*UUID) Rows 

func (col *UUID) Rows() int

func (*UUID) ScanRow 

func (col *UUID) ScanRow(dest interface{}, 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

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.