chschema

package

Go to main page

Versions in this module

v0

v0.3.1

Feb 16, 2023

v0.3.0

Jan 21, 2023

Changes in this version

+ type ArrayArrayBoolColumn struct

+ func (c *ArrayArrayBoolColumn) Init(chType string) error

+ func (c *ArrayArrayBoolColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayBoolColumn) Type() reflect.Type

+ func (c *ArrayArrayBoolColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayBoolColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayBoolColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayBytesColumn struct

+ func (c *ArrayArrayBytesColumn) Init(chType string) error

+ func (c *ArrayArrayBytesColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayBytesColumn) Type() reflect.Type

+ func (c *ArrayArrayBytesColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayBytesColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayBytesColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayDateTimeColumn struct

+ func (c *ArrayArrayDateTimeColumn) Init(chType string) error

+ func (c *ArrayArrayDateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayDateTimeColumn) Type() reflect.Type

+ func (c *ArrayArrayDateTimeColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayDateTimeColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayDateTimeColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayEnumColumn struct

+ func (c *ArrayArrayEnumColumn) Init(chType string) error

+ func (c *ArrayArrayEnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayEnumColumn) Type() reflect.Type

+ func (c *ArrayArrayEnumColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayEnumColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayEnumColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayFloat32Column struct

+ func (c *ArrayArrayFloat32Column) Init(chType string) error

+ func (c *ArrayArrayFloat32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayFloat32Column) Type() reflect.Type

+ func (c *ArrayArrayFloat32Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayFloat32Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayFloat32Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayFloat64Column struct

+ func (c *ArrayArrayFloat64Column) Init(chType string) error

+ func (c *ArrayArrayFloat64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayFloat64Column) Type() reflect.Type

+ func (c *ArrayArrayFloat64Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayFloat64Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayFloat64Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayInt16Column struct

+ func (c *ArrayArrayInt16Column) Init(chType string) error

+ func (c *ArrayArrayInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayInt16Column) Type() reflect.Type

+ func (c *ArrayArrayInt16Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayInt16Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayInt32Column struct

+ func (c *ArrayArrayInt32Column) Init(chType string) error

+ func (c *ArrayArrayInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayInt32Column) Type() reflect.Type

+ func (c *ArrayArrayInt32Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayInt32Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayInt64Column struct

+ func (c *ArrayArrayInt64Column) Init(chType string) error

+ func (c *ArrayArrayInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayInt64Column) Type() reflect.Type

+ func (c *ArrayArrayInt64Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayInt64Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayInt8Column struct

+ func (c *ArrayArrayInt8Column) Init(chType string) error

+ func (c *ArrayArrayInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayInt8Column) Type() reflect.Type

+ func (c *ArrayArrayInt8Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayInt8Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayStringColumn struct

+ func (c *ArrayArrayStringColumn) Init(chType string) error

+ func (c *ArrayArrayStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayStringColumn) Type() reflect.Type

+ func (c *ArrayArrayStringColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayStringColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayStringColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayUInt16Column struct

+ func (c *ArrayArrayUInt16Column) Init(chType string) error

+ func (c *ArrayArrayUInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayUInt16Column) Type() reflect.Type

+ func (c *ArrayArrayUInt16Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayUInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayUInt16Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayUInt32Column struct

+ func (c *ArrayArrayUInt32Column) Init(chType string) error

+ func (c *ArrayArrayUInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayUInt32Column) Type() reflect.Type

+ func (c *ArrayArrayUInt32Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayUInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayUInt32Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayUInt64Column struct

+ func (c *ArrayArrayUInt64Column) Init(chType string) error

+ func (c *ArrayArrayUInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayUInt64Column) Type() reflect.Type

+ func (c *ArrayArrayUInt64Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayUInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayUInt64Column) WriteTo(wr *chproto.Writer) error

+ type ArrayArrayUInt8Column struct

+ func (c *ArrayArrayUInt8Column) Init(chType string) error

+ func (c *ArrayArrayUInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayArrayUInt8Column) Type() reflect.Type

+ func (c *ArrayArrayUInt8Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayArrayUInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayArrayUInt8Column) WriteTo(wr *chproto.Writer) error

+ type ArrayBoolColumn struct

+ func (c *ArrayBoolColumn) Init(chType string) error

+ func (c *ArrayBoolColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayBoolColumn) Type() reflect.Type

+ func (c *ArrayBoolColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayBoolColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayBoolColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayBytesColumn struct

+ func (c *ArrayBytesColumn) Init(chType string) error

+ func (c *ArrayBytesColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayBytesColumn) Type() reflect.Type

+ func (c *ArrayBytesColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayBytesColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayBytesColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayDateTimeColumn struct

+ func (c *ArrayDateTimeColumn) Init(chType string) error

+ func (c *ArrayDateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayDateTimeColumn) Type() reflect.Type

+ func (c *ArrayDateTimeColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayDateTimeColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayDateTimeColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayEnumColumn struct

+ func (c *ArrayEnumColumn) Init(chType string) error

+ func (c *ArrayEnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayEnumColumn) Type() reflect.Type

+ func (c *ArrayEnumColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayEnumColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayEnumColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayFloat32Column struct

+ func (c *ArrayFloat32Column) Init(chType string) error

+ func (c *ArrayFloat32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayFloat32Column) Type() reflect.Type

+ func (c *ArrayFloat32Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayFloat32Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayFloat32Column) WriteTo(wr *chproto.Writer) error

+ type ArrayFloat64Column struct

+ func (c *ArrayFloat64Column) Init(chType string) error

+ func (c *ArrayFloat64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayFloat64Column) Type() reflect.Type

+ func (c *ArrayFloat64Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayFloat64Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayFloat64Column) WriteTo(wr *chproto.Writer) error

+ type ArrayInt16Column struct

+ func (c *ArrayInt16Column) Init(chType string) error

+ func (c *ArrayInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayInt16Column) Type() reflect.Type

+ func (c *ArrayInt16Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayInt16Column) WriteTo(wr *chproto.Writer) error

+ type ArrayInt32Column struct

+ func (c *ArrayInt32Column) Init(chType string) error

+ func (c *ArrayInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayInt32Column) Type() reflect.Type

+ func (c *ArrayInt32Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayInt32Column) WriteTo(wr *chproto.Writer) error

+ type ArrayInt64Column struct

+ func (c *ArrayInt64Column) Init(chType string) error

+ func (c *ArrayInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayInt64Column) Type() reflect.Type

+ func (c *ArrayInt64Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayInt64Column) WriteTo(wr *chproto.Writer) error

+ type ArrayInt8Column struct

+ func (c *ArrayInt8Column) Init(chType string) error

+ func (c *ArrayInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayInt8Column) Type() reflect.Type

+ func (c *ArrayInt8Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayInt8Column) WriteTo(wr *chproto.Writer) error

type ArrayLCStringColumn

+ func (c *ArrayLCStringColumn) ConvertAssign(idx int, dest reflect.Value) error

+ func (c *ArrayLCStringColumn) WriteData(wr *chproto.Writer) error

+ type ArrayStringColumn struct

+ func (c *ArrayStringColumn) Init(chType string) error

+ func (c *ArrayStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayStringColumn) Type() reflect.Type

+ func (c *ArrayStringColumn) WriteData(wr *chproto.Writer) error

+ func (c *ArrayStringColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayStringColumn) WriteTo(wr *chproto.Writer) error

+ type ArrayUInt16Column struct

+ func (c *ArrayUInt16Column) Init(chType string) error

+ func (c *ArrayUInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayUInt16Column) Type() reflect.Type

+ func (c *ArrayUInt16Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayUInt16Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayUInt16Column) WriteTo(wr *chproto.Writer) error

+ type ArrayUInt32Column struct

+ func (c *ArrayUInt32Column) Init(chType string) error

+ func (c *ArrayUInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayUInt32Column) Type() reflect.Type

+ func (c *ArrayUInt32Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayUInt32Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayUInt32Column) WriteTo(wr *chproto.Writer) error

+ type ArrayUInt64Column struct

+ func (c *ArrayUInt64Column) Init(chType string) error

+ func (c *ArrayUInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayUInt64Column) Type() reflect.Type

+ func (c *ArrayUInt64Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayUInt64Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayUInt64Column) WriteTo(wr *chproto.Writer) error

+ type ArrayUInt8Column struct

+ func (c *ArrayUInt8Column) Init(chType string) error

+ func (c *ArrayUInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayUInt8Column) Type() reflect.Type

+ func (c *ArrayUInt8Column) WriteData(wr *chproto.Writer) error

+ func (c *ArrayUInt8Column) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayUInt8Column) WriteTo(wr *chproto.Writer) error

type ColumnOf

+ func (c *ColumnOf[T]) AllocForReading(numRow int)

+ func (c *ColumnOf[T]) Init(chType string) error

+ func (c *ColumnOf[T]) ResetForWriting(numRow int)

type Columnar

+ func NewArrayArrayBoolColumn() Columnar

+ func NewArrayArrayBytesColumn() Columnar

+ func NewArrayArrayDateTimeColumn() Columnar

+ func NewArrayArrayEnumColumn() Columnar

+ func NewArrayArrayFloat32Column() Columnar

+ func NewArrayArrayFloat64Column() Columnar

+ func NewArrayArrayInt16Column() Columnar

+ func NewArrayArrayInt32Column() Columnar

+ func NewArrayArrayInt64Column() Columnar

+ func NewArrayArrayInt8Column() Columnar

+ func NewArrayArrayStringColumn() Columnar

+ func NewArrayArrayUInt16Column() Columnar

+ func NewArrayArrayUInt32Column() Columnar

+ func NewArrayArrayUInt64Column() Columnar

+ func NewArrayArrayUInt8Column() Columnar

+ func NewArrayBoolColumn() Columnar

+ func NewArrayBytesColumn() Columnar

+ func NewArrayDateTimeColumn() Columnar

+ func NewArrayEnumColumn() Columnar

+ func NewArrayFloat32Column() Columnar

+ func NewArrayFloat64Column() Columnar

+ func NewArrayInt16Column() Columnar

+ func NewArrayInt32Column() Columnar

+ func NewArrayInt64Column() Columnar

+ func NewArrayInt8Column() Columnar

+ func NewArrayLCStringColumn() Columnar

+ func NewArrayStringColumn() Columnar

+ func NewArrayUInt16Column() Columnar

+ func NewArrayUInt32Column() Columnar

+ func NewArrayUInt64Column() Columnar

+ func NewArrayUInt8Column() Columnar

+ AllocForReading func(numRow int)

+ Init func(chType string) error

+ ResetForWriting func(numRow int)

type DateTime64Column

+ func (c *DateTime64Column) Init(chType string) error

type EnumColumn

+ func (c *EnumColumn) Init(chType string) error

type JSONColumn

+ func (c *JSONColumn) ResetForWriting(numRow int)

type NewColumnFunc

+ func NewNullableColumnFunc(fn NewColumnFunc) NewColumnFunc

type NullableColumn

+ func (c *NullableColumn) AllocForReading(numRow int)

+ func (c *NullableColumn) Init(chType string) error

+ func (c *NullableColumn) ResetForWriting(numRow int)

type QueryWithArgs

+ func (q QueryWithArgs) IsEmpty() bool

v0.2.9

Aug 30, 2022

Changes in this version

+ type BFloat16HistColumn struct

+ func (c *BFloat16HistColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c BFloat16HistColumn) Type() reflect.Type

+ func (c BFloat16HistColumn) WriteTo(wr *chproto.Writer) error

type Columnar

+ func NewBFloat16HistColumn(typ reflect.Type, chType string, numRow int) Columnar

v0.2.8

May 29, 2022

v0.2.7

May 2, 2022

v0.2.6

Apr 30, 2022

Changes in this version

+ type ArrayColumnOf struct

+ Column [][]T

+ func (c *ArrayColumnOf[T]) AppendPointer(typ reflect.Type, ptr unsafe.Pointer)

+ func (c *ArrayColumnOf[T]) AppendValue(v reflect.Value)

+ func (c *ArrayColumnOf[T]) ConvertAssign(idx int, v reflect.Value) error

+ func (c *ArrayColumnOf[T]) Index(idx int) any

+ func (c *ArrayColumnOf[T]) Len() int

+ func (c *ArrayColumnOf[T]) Nullable(nulls UInt8Column) any

+ func (c *ArrayColumnOf[T]) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayColumnOf[T]) Reset(numRow int)

+ func (c *ArrayColumnOf[T]) Set(v any)

+ func (c *ArrayColumnOf[T]) Slice(s, e int) any

+ func (c *ArrayColumnOf[T]) Value() any

+ func (c *ArrayColumnOf[T]) WriteData(wr *chproto.Writer) error

+ func (c *ArrayColumnOf[T]) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayColumnOf[T]) WriteTo(wr *chproto.Writer) error

type Columnar

+ func NewDateTime64Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewFloat64ArrayColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewGenericArrayColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewInt64ArrayColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUInt16Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUInt32Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUInt64Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUInt8Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUint64ArrayColumn(typ reflect.Type, chType string, numRow int) Columnar

+ type DateTime64Column struct

+ func (c *DateTime64Column) ConvertAssign(idx int, v reflect.Value) error

+ func (c *DateTime64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *DateTime64Column) Type() reflect.Type

+ func (c *DateTime64Column) WriteTo(wr *chproto.Writer) error

+ type Float64ArrayColumn struct

+ func (c *Float64ArrayColumn) Type() reflect.Type

+ type GenericArrayColumn struct

+ Column reflect.Value

+ func (c *GenericArrayColumn) AppendPointer(typ reflect.Type, ptr unsafe.Pointer)

+ func (c *GenericArrayColumn) AppendValue(v reflect.Value)

+ func (c *GenericArrayColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c *GenericArrayColumn) Index(idx int) any

+ func (c *GenericArrayColumn) Len() int

+ func (c *GenericArrayColumn) Nullable(nulls UInt8Column) any

+ func (c *GenericArrayColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *GenericArrayColumn) Reset(numRow int)

+ func (c *GenericArrayColumn) Set(v any)

+ func (c *GenericArrayColumn) Value() any

+ func (c *GenericArrayColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *GenericArrayColumn) WriteTo(wr *chproto.Writer) error

+ func (c GenericArrayColumn) Slice(s, e int) any

+ func (c GenericArrayColumn) Type() reflect.Type

+ type Int64ArrayColumn struct

+ func (c *Int64ArrayColumn) Type() reflect.Type

type StringArrayColumn

+ func (c *StringArrayColumn) AppendPointer(typ reflect.Type, ptr unsafe.Pointer)

+ type UInt16Column struct

+ func (c *UInt16Column) AppendValue(v reflect.Value)

+ func (c *UInt16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *UInt16Column) WriteTo(wr *chproto.Writer) error

+ func (c UInt16Column) Type() reflect.Type

+ type UInt32Column struct

+ func (c *UInt32Column) AppendValue(v reflect.Value)

+ func (c *UInt32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *UInt32Column) WriteTo(wr *chproto.Writer) error

+ func (c UInt32Column) Type() reflect.Type

+ type UInt64Column struct

+ func (c *UInt64Column) AppendValue(v reflect.Value)

+ func (c *UInt64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *UInt64Column) WriteTo(wr *chproto.Writer) error

+ func (c UInt64Column) Type() reflect.Type

+ type UInt8Column struct

+ func (c *UInt8Column) AppendValue(v reflect.Value)

+ func (c *UInt8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *UInt8Column) WriteTo(wr *chproto.Writer) error

+ func (c UInt8Column) Type() reflect.Type

+ type Uint64ArrayColumn struct

+ func (c *Uint64ArrayColumn) Type() reflect.Type

v0.2.5

Mar 29, 2022

v0.2.4

Mar 23, 2022

v0.2.3

Mar 23, 2022

v0.2.2

Mar 21, 2022

v0.2.1

Mar 21, 2022

v0.2.0

Mar 21, 2022

v0.1.1

Mar 17, 2022

v0.1.0

Mar 9, 2022

Changes in this version

+ func Append(fmter Formatter, b []byte, v any) []byte

+ func AppendBool(dst []byte, v bool) []byte

+ func AppendBytes(b []byte, bytes []byte) []byte

+ func AppendError(b []byte, err error) []byte

+ func AppendFQN(b []byte, field string) []byte

+ func AppendFloat(dst []byte, v float64) []byte

+ func AppendIdent(b []byte, field string) []byte

+ func AppendNull(b []byte) []byte

+ func AppendQuery(b []byte, query string, args ...any) []byte

+ func AppendQueryAppender(fmter Formatter, b []byte, app QueryAppender) []byte

+ func AppendString(b []byte, s string) []byte

+ func AppendTime(b []byte, tm time.Time) []byte

+ func AppendValue(fmter Formatter, b []byte, v reflect.Value) []byte

+ func FormatQuery(query string, args ...any) string

+ func SetTableNameInflector(fn func(string) string)

+ type AfterScanRowHook interface

+ AfterScanRow func(context.Context) error

+ type AppenderFunc func(fmter Formatter, b []byte, v reflect.Value) []byte

+ func Appender(typ reflect.Type) AppenderFunc

+ type ArrayColumn struct

+ Column reflect.Value

+ func (c *ArrayColumn) AppendValue(v reflect.Value)

+ func (c *ArrayColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c *ArrayColumn) Index(idx int) any

+ func (c *ArrayColumn) Len() int

+ func (c *ArrayColumn) Nullable(nulls Uint8Column) any

+ func (c *ArrayColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayColumn) Reset(numRow int)

+ func (c *ArrayColumn) Set(v any)

+ func (c *ArrayColumn) Value() any

+ func (c *ArrayColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *ArrayColumn) WriteTo(wr *chproto.Writer) error

+ func (c ArrayColumn) Slice(s, e int) any

+ func (c ArrayColumn) Type() reflect.Type

+ type ArrayColumnar interface

+ WriteData func(wr *chproto.Writer) error

+ WriteOffset func(wr *chproto.Writer, offset int) int

+ type ArrayLCStringColumn struct

+ func (c *ArrayLCStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *ArrayLCStringColumn) WriteTo(wr *chproto.Writer) error

+ func (c ArrayLCStringColumn) Type() reflect.Type

+ type Block struct

+ Columns []*Column

+ NumColumn int

+ NumRow int

+ Table *Table

+ func NewBlock(table *Table, numCol, numRow int) *Block

+ func (b *Block) Column(colName, colType string) *Column

+ func (b *Block) ColumnForField(field *Field) *Column

+ func (b *Block) WriteTo(wr *chproto.Writer) error

+ type BoolColumn struct

+ func (c *BoolColumn) AppendValue(v reflect.Value)

+ func (c *BoolColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c BoolColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c BoolColumn) Type() reflect.Type

+ func (c BoolColumn) WriteTo(wr *chproto.Writer) error

+ type BytesColumn struct

+ func (c *BytesColumn) AppendValue(v reflect.Value)

+ func (c *BytesColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *BytesColumn) Reset(numRow int)

+ func (c BytesColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c BytesColumn) Type() reflect.Type

+ func (c BytesColumn) WriteTo(wr *chproto.Writer) error

+ type CHModel struct

+ type Column struct

+ Field *Field

+ Name string

+ Type string

+ func (c *Column) String() string

+ type ColumnOf struct

+ Column []T

+ func NewColumnOf(numRow int) ColumnOf[T]

+ func (c *ColumnOf[T]) Alloc(numRow int)

+ func (c *ColumnOf[T]) AppendValue(v reflect.Value)

+ func (c *ColumnOf[T]) ConvertAssign(idx int, dest reflect.Value) error

+ func (c *ColumnOf[T]) Reset(numRow int)

+ func (c *ColumnOf[T]) Set(v any)

+ func (c ColumnOf[T]) Index(idx int) any

+ func (c ColumnOf[T]) Len() int

+ func (c ColumnOf[T]) Nullable(nulls Uint8Column) any

+ func (c ColumnOf[T]) Slice(s, e int) any

+ func (c ColumnOf[T]) Value() any

+ type Columnar interface

+ AppendValue func(v reflect.Value)

+ ConvertAssign func(idx int, dest reflect.Value) error

+ Index func(idx int) any

+ Len func() int

+ Nullable func(nulls Uint8Column) any

+ ReadFrom func(rd *chproto.Reader, numRow int) error

+ Set func(v any)

+ Slice func(s, e int) any

+ Type func() reflect.Type

+ Value func() any

+ WriteTo func(wr *chproto.Writer) error

+ func NewArrayColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewBoolColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewBytesColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewColumnFromCHType(chType string, numRow int) Columnar

+ func NewDateColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewDateTimeColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewEnumColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewFloat32Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewFloat64Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewIPColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewInt16Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewInt32Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewInt64Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewInt64TimeColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewInt8Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewJSONColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewLCStringColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewStringArrayColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewStringColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewTimeColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUUIDColumn(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUint16Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUint32Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUint64Column(typ reflect.Type, chType string, numRow int) Columnar

+ func NewUint8Column(typ reflect.Type, chType string, numRow int) Columnar

+ type ColumnsAppender interface

+ AppendColumns func(fmter Formatter, b []byte) ([]byte, error)

+ type DateColumn struct

+ func (c *DateColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c DateColumn) WriteTo(wr *chproto.Writer) error

+ type DateTimeColumn struct

+ func (c *DateTimeColumn) AppendValue(v reflect.Value)

+ func (c *DateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c DateTimeColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c DateTimeColumn) Type() reflect.Type

+ func (c DateTimeColumn) WriteTo(wr *chproto.Writer) error

+ type EnumColumn struct

+ func (c *EnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *EnumColumn) WriteTo(wr *chproto.Writer) error

+ type FQN string

+ func (s FQN) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

+ type Field struct

+ CHDefault Safe

+ CHName string

+ CHType string

+ Column Safe

+ Field reflect.StructField

+ GoName string

+ Index []int

+ IsPK bool

+ NewColumn NewColumnFunc

+ NotNull bool

+ Type reflect.Type

+ func (f *Field) AppendValue(fmter Formatter, b []byte, strct reflect.Value) []byte

+ func (f *Field) String() string

+ func (f *Field) Value(strct reflect.Value) reflect.Value

+ type Float32Column struct

+ func (c *Float32Column) AppendValue(v reflect.Value)

+ func (c *Float32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Float32Column) Type() reflect.Type

+ func (c Float32Column) WriteTo(wr *chproto.Writer) error

+ type Float64Column struct

+ func (c *Float64Column) AppendValue(v reflect.Value)

+ func (c *Float64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Float64Column) Type() reflect.Type

+ func (c Float64Column) WriteTo(wr *chproto.Writer) error

+ type Formatter struct

+ func NewFormatter() Formatter

+ func (f Formatter) AppendIdent(b []byte, ident string) []byte

+ func (f Formatter) AppendQuery(b []byte, query string, args ...any) []byte

+ func (f Formatter) FormatQuery(query string, args ...any) string

+ func (f Formatter) WithArg(arg NamedArgAppender) Formatter

+ func (f Formatter) WithNamedArg(name string, value any) Formatter

+ type IPColumn struct

+ func (c *IPColumn) AppendValue(v reflect.Value)

+ func (c *IPColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c IPColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c IPColumn) Type() reflect.Type

+ func (c IPColumn) WriteTo(wr *chproto.Writer) error

+ type Ident string

+ func (s Ident) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

+ type Int16Column struct

+ func (c *Int16Column) AppendValue(v reflect.Value)

+ func (c *Int16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Int16Column) Type() reflect.Type

+ func (c Int16Column) WriteTo(wr *chproto.Writer) error

+ type Int32Column struct

+ func (c *Int32Column) AppendValue(v reflect.Value)

+ func (c *Int32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Int32Column) Type() reflect.Type

+ func (c Int32Column) WriteTo(wr *chproto.Writer) error

+ type Int64Column struct

+ func (c *Int64Column) AppendValue(v reflect.Value)

+ func (c *Int64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Int64Column) Type() reflect.Type

+ func (c Int64Column) WriteTo(wr *chproto.Writer) error

+ type Int64TimeColumn struct

+ func (c *Int64TimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Int64TimeColumn) WriteTo(wr *chproto.Writer) error

+ type Int8Column struct

+ func (c *Int8Column) AppendValue(v reflect.Value)

+ func (c *Int8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Int8Column) Type() reflect.Type

+ func (c Int8Column) WriteTo(wr *chproto.Writer) error

+ type JSONColumn struct

+ Values []reflect.Value

+ func (c *JSONColumn) AppendValue(v reflect.Value)

+ func (c *JSONColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c *JSONColumn) Len() int

+ func (c *JSONColumn) Reset(numRow int)

+ func (c *JSONColumn) WriteTo(wr *chproto.Writer) error

+ type LCStringColumn struct

+ func (c *LCStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *LCStringColumn) WriteTo(wr *chproto.Writer) error

+ type Model interface

+ ScanBlock func(*Block) error

+ type NamedArgAppender interface

+ AppendNamedArg func(fmter Formatter, b []byte, name string) ([]byte, bool)

+ type NewColumnFunc func(typ reflect.Type, chType string, numRow int) Columnar

+ func ColumnFactory(typ reflect.Type, chType string) NewColumnFunc

+ func NullableNewColumnFunc(fn NewColumnFunc) NewColumnFunc

+ type NullableColumn struct

+ Nulls Uint8Column

+ Values Columnar

+ func (c *NullableColumn) AppendValue(v reflect.Value)

+ func (c *NullableColumn) ConvertAssign(idx int, dest reflect.Value) error

+ func (c *NullableColumn) Index(idx int) any

+ func (c *NullableColumn) Len() int

+ func (c *NullableColumn) Nullable(nulls Uint8Column) any

+ func (c *NullableColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *NullableColumn) Set(v any)

+ func (c *NullableColumn) Slice(s, e int) any

+ func (c *NullableColumn) Type() reflect.Type

+ func (c *NullableColumn) Value() any

+ func (c *NullableColumn) WriteTo(wr *chproto.Writer) error

+ type NumericColumnOf struct

+ func NewNumericColumnOf(numRow int) NumericColumnOf[T]

+ func (c NumericColumnOf[T]) ConvertAssign(idx int, v reflect.Value) error

+ type Query interface

+ GetModel func() Model

+ GetTableName func() string

+ Operation func() string

+ type QueryAppender interface

+ AppendQuery func(fmter Formatter, b []byte) ([]byte, error)

+ type QueryWithArgs struct

+ Args []any

+ Query string

+ func SafeQuery(query string, args []any) QueryWithArgs

+ func UnsafeIdent(ident string) QueryWithArgs

+ func (q QueryWithArgs) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

+ func (q QueryWithArgs) IsZero() bool

+ func (q QueryWithArgs) Value() Safe

+ type QueryWithSep struct

+ Sep string

+ func SafeQueryWithSep(query string, args []any, sep string) QueryWithSep

+ type Safe string

+ func (s Safe) AppendQuery(fmter Formatter, b []byte) ([]byte, error)

+ type StringArrayColumn struct

+ Column [][]string

+ func (c *StringArrayColumn) AppendValue(v reflect.Value)

+ func (c *StringArrayColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c *StringArrayColumn) Index(idx int) any

+ func (c *StringArrayColumn) Len() int

+ func (c *StringArrayColumn) Nullable(nulls Uint8Column) any

+ func (c *StringArrayColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c *StringArrayColumn) Reset(numRow int)

+ func (c *StringArrayColumn) Set(v any)

+ func (c *StringArrayColumn) Type() reflect.Type

+ func (c *StringArrayColumn) Value() any

+ func (c *StringArrayColumn) WriteData(wr *chproto.Writer) error

+ func (c *StringArrayColumn) WriteOffset(wr *chproto.Writer, offset int) int

+ func (c *StringArrayColumn) WriteTo(wr *chproto.Writer) error

+ func (c StringArrayColumn) Slice(s, e int) any

+ type StringColumn struct

+ func (c *StringColumn) AppendValue(v reflect.Value)

+ func (c *StringColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c StringColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c StringColumn) Type() reflect.Type

+ func (c StringColumn) WriteTo(wr *chproto.Writer) error

+ type Table struct

+ CHAlias Safe

+ CHEngine string

+ CHInsertName Safe

+ CHName Safe

+ CHPartition string

+ DataFields []*Field

+ FieldMap map[string]*Field

+ Fields []*Field

+ ModelName string

+ Name string

+ PKs []*Field

+ Type reflect.Type

+ func TableForType(typ reflect.Type) *Table

+ func (t *Table) AppendNamedArg(fmter Formatter, b []byte, name string, strct reflect.Value) ([]byte, bool)

+ func (t *Table) Field(name string) (*Field, error)

+ func (t *Table) HasAfterScanRowHook() bool

+ func (t *Table) IsColumnar() bool

+ func (t *Table) NewColumn(colName, colType string, numRow int) *Column

+ func (t *Table) String() string

+ type TimeColumn struct

+ func (c *TimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c TimeColumn) WriteTo(wr *chproto.Writer) error

+ type UUID [16]byte

+ type UUIDColumn struct

+ func (c *UUIDColumn) AppendValue(v reflect.Value)

+ func (c *UUIDColumn) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c UUIDColumn) ConvertAssign(idx int, v reflect.Value) error

+ func (c UUIDColumn) Type() reflect.Type

+ func (c UUIDColumn) WriteTo(wr *chproto.Writer) error

+ type Uint16Column struct

+ func (c *Uint16Column) AppendValue(v reflect.Value)

+ func (c *Uint16Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Uint16Column) Type() reflect.Type

+ func (c Uint16Column) WriteTo(wr *chproto.Writer) error

+ type Uint32Column struct

+ func (c *Uint32Column) AppendValue(v reflect.Value)

+ func (c *Uint32Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Uint32Column) Type() reflect.Type

+ func (c Uint32Column) WriteTo(wr *chproto.Writer) error

+ type Uint64Column struct

+ func (c *Uint64Column) AppendValue(v reflect.Value)

+ func (c *Uint64Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Uint64Column) Type() reflect.Type

+ func (c Uint64Column) WriteTo(wr *chproto.Writer) error

+ type Uint8Column struct

+ func (c *Uint8Column) AppendValue(v reflect.Value)

+ func (c *Uint8Column) ReadFrom(rd *chproto.Reader, numRow int) error

+ func (c Uint8Column) Type() reflect.Type

+ func (c Uint8Column) WriteTo(wr *chproto.Writer) error

+ type UnknownColumnError struct

+ Column string

+ Table *Table

+ func (err *UnknownColumnError) Error() string

Other modules containing this package

github.com/uptrace/go-clickhouse/ch

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