column

package
v2.46.0 Latest Latest
Warning

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

 Go to latest Published: May 3, 2026 License: Apache-2.0 Imports: 25 Imported by: 64

Documentation

Index

Constants

View Source 
const DefaultMaxDynamicPaths = 1024
View Source 
const DefaultMaxDynamicTypes = 32
View Source 
const DynamicDeprecatedSerializationVersion = 1
View Source 
const DynamicNullDiscriminator = -1 // The Null index changes as data is being built, use -1 as placeholder for writes.
View Source 
const DynamicSerializationVersion = 3
View Source 
const (
	E
)
View Source 
const JSONDeprecatedObjectSerializationVersion uint64 = 0
View Source 
const JSONObjectSerializationVersion uint64 = 3
View Source 
const JSONStringSerializationVersion uint64 = 1
View Source 
const JSONUnsetSerializationVersion uint64 = math.MaxUint64
View Source 
const MaxMapPathDepth = 32
View Source 
const SupportedVariantSerializationVersion = 0
View Source 
const VariantNullDiscriminator uint8 = 255

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 BFloat16 added in v2.43.0 

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

func (*BFloat16) Append added in v2.43.0 

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

func (*BFloat16) AppendRow added in v2.43.0 

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

func (*BFloat16) Decode added in v2.43.0 

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

func (*BFloat16) Encode added in v2.43.0 

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

func (*BFloat16) Name added in v2.43.0 

func (col *BFloat16) Name() string

func (*BFloat16) Reset added in v2.43.0 

func (col *BFloat16) Reset()

func (*BFloat16) Row added in v2.43.0 

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

func (*BFloat16) Rows added in v2.43.0 

func (col *BFloat16) Rows() int

func (*BFloat16) ScanRow added in v2.43.0 

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

func (*BFloat16) ScanType added in v2.43.0 

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

func (*BFloat16) Type added in v2.43.0 

func (col *BFloat16) Type() Type

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(name string) 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 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) Precision added in v2.30.1 

func (col *DateTime64) Precision() (int64, bool)

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 Dynamic added in v2.30.1 

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

func (*Dynamic) Append added in v2.30.1 

func (c *Dynamic) Append(v any) (nulls []uint8, err error)

func (*Dynamic) AppendRow added in v2.30.1 

func (c *Dynamic) AppendRow(v any) error

func (*Dynamic) Decode added in v2.30.1 

func (c *Dynamic) Decode(reader *proto.Reader, rows int) error

func (*Dynamic) Encode added in v2.30.1 

func (c *Dynamic) Encode(buffer *proto.Buffer)

func (*Dynamic) Name added in v2.30.1 

func (c *Dynamic) Name() string

func (*Dynamic) ReadStatePrefix added in v2.32.1 

func (c *Dynamic) ReadStatePrefix(reader *proto.Reader) error

func (*Dynamic) Reset added in v2.30.1 

func (c *Dynamic) Reset()

func (*Dynamic) Row added in v2.30.1 

func (c *Dynamic) Row(i int, ptr bool) any

func (*Dynamic) Rows added in v2.30.1 

func (c *Dynamic) Rows() int

func (*Dynamic) ScanRow added in v2.30.1 

func (c *Dynamic) ScanRow(dest any, row int) error

func (*Dynamic) ScanType added in v2.30.1 

func (c *Dynamic) ScanType() reflect.Type

func (*Dynamic) Type added in v2.30.1 

func (c *Dynamic) Type() Type

func (*Dynamic) WriteStatePrefix added in v2.32.1 

func (c *Dynamic) WriteStatePrefix(buffer *proto.Buffer) error

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 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 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) 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 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 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 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 struct {
	// contains filtered or unexported fields
}

JSON implements ClickHouse JSON column on the native protocol layer. We choose how to encode the JSON based on serializationVersion. It can be either plain string or object type with newer server support.

func (*JSON) Append added in v2.30.1 

func (c *JSON) Append(v any) (nulls []uint8, err error)

func (*JSON) AppendRow added in v2.30.1 

func (c *JSON) AppendRow(v any) error

func (*JSON) Decode added in v2.30.1 

func (c *JSON) Decode(reader *proto.Reader, rows int) error

func (*JSON) Encode added in v2.30.1 

func (c *JSON) Encode(buffer *proto.Buffer)

func (*JSON) Name added in v2.30.1 

func (c *JSON) Name() string

func (*JSON) ReadStatePrefix added in v2.32.1 

func (c *JSON) ReadStatePrefix(reader *proto.Reader) error

func (*JSON) Reset added in v2.30.1 

func (c *JSON) Reset()

func (*JSON) Row added in v2.30.1 

func (c *JSON) Row(row int, ptr bool) any

func (*JSON) Rows added in v2.30.1 

func (c *JSON) Rows() int

func (*JSON) ScanRow added in v2.30.1 

func (c *JSON) ScanRow(dest any, row int) error

func (*JSON) ScanType added in v2.30.1 

func (c *JSON) ScanType() reflect.Type

func (*JSON) Type added in v2.30.1 

func (c *JSON) Type() Type

func (*JSON) WriteStatePrefix added in v2.32.1 

func (c *JSON) WriteStatePrefix(buffer *proto.Buffer) error

type LineString added in v2.43.0 

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

func (*LineString) Append added in v2.43.0 

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

func (*LineString) AppendRow added in v2.43.0 

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

func (*LineString) Decode added in v2.43.0 

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

func (*LineString) Encode added in v2.43.0 

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

func (*LineString) Name added in v2.43.0 

func (col *LineString) Name() string

func (*LineString) Reset added in v2.43.0 

func (col *LineString) Reset()

func (*LineString) Row added in v2.43.0 

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

func (*LineString) Rows added in v2.43.0 

func (col *LineString) Rows() int

func (*LineString) ScanRow added in v2.43.0 

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

func (*LineString) ScanType added in v2.43.0 

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

func (*LineString) Type added in v2.43.0 

func (col *LineString) 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 MultiLineString added in v2.43.0 

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

func (*MultiLineString) Append added in v2.43.0 

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

func (*MultiLineString) AppendRow added in v2.43.0 

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

func (*MultiLineString) Decode added in v2.43.0 

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

func (*MultiLineString) Encode added in v2.43.0 

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

func (*MultiLineString) Name added in v2.43.0 

func (col *MultiLineString) Name() string

func (*MultiLineString) Reset added in v2.43.0 

func (col *MultiLineString) Reset()

func (*MultiLineString) Row added in v2.43.0 

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

func (*MultiLineString) Rows added in v2.43.0 

func (col *MultiLineString) Rows() int

func (*MultiLineString) ScanRow added in v2.43.0 

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

func (*MultiLineString) ScanType added in v2.43.0 

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

func (*MultiLineString) Type added in v2.43.0 

func (col *MultiLineString) Type() Type

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) ReadStatePrefix added in v2.28.0 

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

func (*Nested) Reset added in v2.3.0 

func (col *Nested) Reset()

func (*Nested) WriteStatePrefix added in v2.28.0 

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 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) ReadStatePrefix added in v2.40.0 

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

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

func (*Nullable) WriteStatePrefix added in v2.40.0 

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

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 QBit added in v2.43.0 

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

QBit represents the QBit(T, N) column type for vector embeddings. QBit stores vectors in a bit-sliced format enabling runtime precision tuning for vector similarity searches.

Supported element types: BFloat16, Float32, Float64

Example usage: 

vectors := [][]float32{
    {1.0, 2.0, 3.0, 4.0},
    {5.0, 6.0, 7.0, 8.0},
}
batch.Append(vectors)

func (*QBit) Append added in v2.43.0 

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

func (*QBit) AppendRow added in v2.43.0 

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

func (*QBit) Decode added in v2.43.0 

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

func (*QBit) Encode added in v2.43.0 

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

func (*QBit) Name added in v2.43.0 

func (col *QBit) Name() string

func (*QBit) Reset added in v2.43.0 

func (col *QBit) Reset()

func (*QBit) Row added in v2.43.0 

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

func (*QBit) Rows added in v2.43.0 

func (col *QBit) Rows() int

func (*QBit) ScanRow added in v2.43.0 

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

func (*QBit) ScanType added in v2.43.0 

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

func (*QBit) Type added in v2.43.0 

func (col *QBit) 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 ServerContext added in v2.38.0 

type ServerContext struct {
	Revision     uint64
	VersionMajor uint64
	VersionMinor uint64
	VersionPatch uint64
	Timezone     *time.Location
}

type SharedVariant added in v2.30.1 

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

SharedVariant deprecated. Use Dynamic/JSON serialization version 3.

func (*SharedVariant) Append added in v2.30.1 

func (c *SharedVariant) Append(v any) (nulls []uint8, err error)

func (*SharedVariant) AppendRow added in v2.30.1 

func (c *SharedVariant) AppendRow(v any) error

func (*SharedVariant) Decode added in v2.30.1 

func (c *SharedVariant) Decode(reader *proto.Reader, rows int) error

func (*SharedVariant) Encode added in v2.30.1 

func (c *SharedVariant) Encode(buffer *proto.Buffer)

func (*SharedVariant) Name added in v2.30.1 

func (c *SharedVariant) Name() string

func (*SharedVariant) Reset added in v2.30.1 

func (c *SharedVariant) Reset()

func (*SharedVariant) Row added in v2.30.1 

func (c *SharedVariant) Row(i int, ptr bool) any

func (*SharedVariant) Rows added in v2.30.1 

func (c *SharedVariant) Rows() int

func (*SharedVariant) ScanRow added in v2.30.1 

func (c *SharedVariant) ScanRow(dest any, row int) error

func (*SharedVariant) ScanType added in v2.30.1 

func (c *SharedVariant) ScanType() reflect.Type

func (*SharedVariant) Type added in v2.30.1 

func (c *SharedVariant) 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) ReadStatePrefix added in v2.41.0 

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

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

func (*SimpleAggregateFunction) WriteStatePrefix added in v2.41.0 

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

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 Time added in v2.41.0 

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

func (*Time) Append added in v2.41.0 

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

Append implements column.Interface. It is used for columnar inserts. Insert multiple Go value for single ClickHouse Time type.

func (*Time) AppendRow added in v2.41.0 

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

AppendRow implements column.Interface. It is used to insert column value in a row. Converts Go type into ClickHouse type to be inserted.

func (*Time) Decode added in v2.41.0 

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

func (*Time) Encode added in v2.41.0 

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

func (*Time) Name added in v2.41.0 

func (col *Time) Name() string

func (*Time) Reset added in v2.41.0 

func (col *Time) Reset()

func (*Time) Row added in v2.41.0 

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

func (*Time) Rows added in v2.41.0 

func (col *Time) Rows() int

func (*Time) ScanRow added in v2.41.0 

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

ScanRow implements column.Interface. It is used to read a single column value of the row and store in `dest` Go variable.

func (*Time) ScanType added in v2.41.0 

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

func (*Time) Type added in v2.41.0 

func (col *Time) Type() Type

type Time64 added in v2.41.0 

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

func (*Time64) Append added in v2.41.0 

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

Append implements column.Interface. It is used for columnar inserts. Insert multiple Go value for single ClickHouse Time64 type.

func (*Time64) AppendRow added in v2.41.0 

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

AppendRow implements column.Interface. It is used to insert column value in a row. Converts Go type into ClickHouse type to be inserted.

func (*Time64) Decode added in v2.41.0 

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

func (*Time64) Encode added in v2.41.0 

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

func (*Time64) Name added in v2.41.0 

func (col *Time64) Name() string

func (*Time64) Precision added in v2.41.0 

func (col *Time64) Precision() (int64, bool)

func (*Time64) Reset added in v2.41.0 

func (col *Time64) Reset()

func (*Time64) Row added in v2.41.0 

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

func (*Time64) Rows added in v2.41.0 

func (col *Time64) Rows() int

func (*Time64) ScanRow added in v2.41.0 

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

ScanRow implements column.Interface. It is used to read a single column value of the row and store in `dest` Go variable.

func (*Time64) ScanType added in v2.41.0 

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

func (*Time64) Type added in v2.41.0 

func (col *Time64) 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, sc *ServerContext) (Interface, error)

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

type Variant added in v2.30.1 

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

func (*Variant) Append added in v2.30.1 

func (c *Variant) Append(v any) (nulls []uint8, err error)

func (*Variant) AppendRow added in v2.30.1 

func (c *Variant) AppendRow(v any) error

func (*Variant) Decode added in v2.30.1 

func (c *Variant) Decode(reader *proto.Reader, rows int) error

func (*Variant) Encode added in v2.30.1 

func (c *Variant) Encode(buffer *proto.Buffer)

func (*Variant) Name added in v2.30.1 

func (c *Variant) Name() string

func (*Variant) ReadStatePrefix added in v2.32.1 

func (c *Variant) ReadStatePrefix(reader *proto.Reader) error

func (*Variant) Reset added in v2.30.1 

func (c *Variant) Reset()

func (*Variant) Row added in v2.30.1 

func (c *Variant) Row(i int, ptr bool) any

func (*Variant) Rows added in v2.30.1 

func (c *Variant) Rows() int

func (*Variant) ScanRow added in v2.30.1 

func (c *Variant) ScanRow(dest any, row int) error

func (*Variant) ScanType added in v2.30.1 

func (c *Variant) ScanType() reflect.Type

func (*Variant) Type added in v2.30.1 

func (c *Variant) Type() Type

func (*Variant) WriteStatePrefix added in v2.32.1 

func (c *Variant) WriteStatePrefix(buffer *proto.Buffer) error

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.