Versions in this module Expand all Collapse all v0 v0.3.6 Dec 26, 2023 v0.3.5 Dec 26, 2023 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 AppendFloat(dst []byte, v float64) []byte + func AppendIdent(b []byte, field string) []byte + func AppendName(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 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 ArrayColumnar interface + WriteData func(wr *chproto.Writer) error + WriteOffset func(wr *chproto.Writer, offset int) int + 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 struct + func (c *ArrayLCStringColumn) ConvertAssign(idx int, dest reflect.Value) error + func (c *ArrayLCStringColumn) ReadFrom(rd *chproto.Reader, numRow int) error + func (c *ArrayLCStringColumn) WriteData(wr *chproto.Writer) error + func (c *ArrayLCStringColumn) WriteTo(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 ArrayValue struct + func Array(vi interface{}) *ArrayValue + func (a *ArrayValue) AppendQuery(fmter Formatter, b []byte) ([]byte, error) + 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 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) Type() reflect.Type + func (c *BoolColumn) WriteTo(wr *chproto.Writer) error + func (c BoolColumn) ConvertAssign(idx int, v reflect.Value) error + type BytesColumn struct + func (c *BytesColumn) AppendValue(v reflect.Value) + func (c *BytesColumn) ReadFrom(rd *chproto.Reader, numRow int) 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 (c *ColumnOf[T]) AllocForReading(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]) Init(chType string) error + func (c *ColumnOf[T]) ResetForWriting(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 + AllocForReading func(numRow int) + AppendValue func(v reflect.Value) + ConvertAssign func(idx int, dest reflect.Value) error + Index func(idx int) any + Init func(chType string) error + Len func() int + Nullable func(nulls UInt8Column) any + ReadFrom func(rd *chproto.Reader, numRow int) error + ResetForWriting func(numRow int) + Set func(v any) + Slice func(s, e int) any + Type func() reflect.Type + Value func() any + WriteTo func(wr *chproto.Writer) error + 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 + func NewBFloat16HistColumn() Columnar + func NewBoolColumn() Columnar + func NewBytesColumn() Columnar + func NewColumn(chType string, typ reflect.Type) Columnar + func NewDateColumn() Columnar + func NewDateTime64Column() Columnar + func NewDateTimeColumn() Columnar + func NewEnumColumn() Columnar + func NewFloat32Column() Columnar + func NewFloat64Column() Columnar + func NewIPColumn() Columnar + func NewInt16Column() Columnar + func NewInt32Column() Columnar + func NewInt64Column() Columnar + func NewInt8Column() Columnar + func NewJSONColumn() Columnar + func NewLCStringColumn() Columnar + func NewStringColumn() Columnar + func NewTimeColumn() Columnar + func NewUInt16Column() Columnar + func NewUInt32Column() Columnar + func NewUInt64Column() Columnar + func NewUInt8Column() Columnar + func NewUUIDColumn() 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 DateTime64Column struct + func (c *DateTime64Column) ConvertAssign(idx int, v reflect.Value) error + func (c *DateTime64Column) Init(chType string) 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 DateTimeColumn struct + func (c *DateTimeColumn) ReadFrom(rd *chproto.Reader, numRow int) error + func (c *DateTimeColumn) Type() reflect.Type + func (c *DateTimeColumn) WriteTo(wr *chproto.Writer) error + type EnumColumn struct + func (c *EnumColumn) Init(chType string) error + func (c *EnumColumn) ReadFrom(rd *chproto.Reader, numRow int) error + func (c *EnumColumn) WriteTo(wr *chproto.Writer) 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) AppendName(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 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) ResetForWriting(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 Name string + func (s Name) AppendQuery(fmter Formatter, b []byte) ([]byte, error) + type NamedArgAppender interface + AppendNamedArg func(fmter Formatter, b []byte, name string) ([]byte, bool) + type NewColumnFunc func() Columnar + func ColumnFactory(chType string, typ reflect.Type) NewColumnFunc + func NewNullableColumnFunc(fn NewColumnFunc) NewColumnFunc + type NullableColumn struct + Nulls UInt8Column + Values Columnar + func (c *NullableColumn) AllocForReading(numRow int) + 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) Init(chType string) error + 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) ResetForWriting(numRow int) + 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 (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 UnsafeName(ident string) QueryWithArgs + func (q QueryWithArgs) AppendQuery(fmter Formatter, b []byte) ([]byte, error) + func (q QueryWithArgs) IsEmpty() bool + 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 StringColumn struct + func (c *StringColumn) AppendValue(v reflect.Value) + func (c *StringColumn) ReadFrom(rd *chproto.Reader, numRow int) error + func (c *StringColumn) Type() reflect.Type + func (c *StringColumn) WriteTo(wr *chproto.Writer) error + func (c StringColumn) ConvertAssign(idx int, v reflect.Value) 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) *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 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 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 UnknownColumnError struct + Column string + Table *Table + func (err *UnknownColumnError) Error() string