clickhouse: github.com/kshvakov/clickhouse/lib/column Index | Files

package column

import "github.com/kshvakov/clickhouse/lib/column"

Index

Package Files

array.go column.go common.go date.go datetime.go decimal.go enum.go fixed_string.go float32.go float64.go int16.go int32.go int64.go int8.go ip.go ipv4.go ipv6.go nullable.go string.go uint16.go uint32.go uint64.go uint8.go uuid.go

Constants

const (
    UUIDLen  = 16
    NullUUID = "00000000-0000-0000-0000-000000000000"
)

Variables

var ErrInvalidUUIDFormat = errors.New("invalid UUID format")

type Array Uses

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

func (*Array) CHType Uses

func (base *Array) CHType() string

func (*Array) Depth Uses

func (array *Array) Depth() int

func (*Array) Name Uses

func (base *Array) Name() string

func (*Array) Read Uses

func (array *Array) Read(decoder *binary.Decoder) (interface{}, error)

func (*Array) ReadArray Uses

func (array *Array) ReadArray(decoder *binary.Decoder, rows int) (_ []interface{}, err error)

func (*Array) ScanType Uses

func (base *Array) ScanType() reflect.Type

func (*Array) String Uses

func (base *Array) String() string

func (*Array) Write Uses

func (array *Array) Write(encoder *binary.Encoder, v interface{}) error

type Column Uses

type Column interface {
    Name() string
    CHType() string
    ScanType() reflect.Type
    Read(*binary.Decoder) (interface{}, error)
    Write(*binary.Encoder, interface{}) error

    Depth() int
    // contains filtered or unexported methods
}

func Factory Uses

func Factory(name, chType string, timezone *time.Location) (Column, error)

type Date Uses

type Date struct {
    Timezone *time.Location
    // contains filtered or unexported fields
}

func (*Date) CHType Uses

func (base *Date) CHType() string

func (*Date) Depth Uses

func (base *Date) Depth() int

func (*Date) Name Uses

func (base *Date) Name() string

func (*Date) Read Uses

func (dt *Date) Read(decoder *binary.Decoder) (interface{}, error)

func (*Date) ScanType Uses

func (base *Date) ScanType() reflect.Type

func (*Date) String Uses

func (base *Date) String() string

func (*Date) Write Uses

func (dt *Date) Write(encoder *binary.Encoder, v interface{}) error

type DateTime Uses

type DateTime struct {
    Timezone *time.Location
    // contains filtered or unexported fields
}

func (*DateTime) CHType Uses

func (base *DateTime) CHType() string

func (*DateTime) Depth Uses

func (base *DateTime) Depth() int

func (*DateTime) Name Uses

func (base *DateTime) Name() string

func (*DateTime) Read Uses

func (dt *DateTime) Read(decoder *binary.Decoder) (interface{}, error)

func (*DateTime) ScanType Uses

func (base *DateTime) ScanType() reflect.Type

func (*DateTime) String Uses

func (base *DateTime) String() string

func (*DateTime) Write Uses

func (dt *DateTime) Write(encoder *binary.Encoder, v interface{}) error

type Decimal Uses

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

Decimal represents Decimal(P, S) ClickHouse. Since there is support for int128 in Golang, the implementation does not support to 128-bits decimals as well. Decimal is represented as integral. Also floating-point types are supported for query parameters.

func (*Decimal) CHType Uses

func (base *Decimal) CHType() string

func (*Decimal) Depth Uses

func (base *Decimal) Depth() int

func (*Decimal) Name Uses

func (base *Decimal) Name() string

func (*Decimal) Read Uses

func (d *Decimal) Read(decoder *binary.Decoder) (interface{}, error)

func (*Decimal) ScanType Uses

func (base *Decimal) ScanType() reflect.Type

func (*Decimal) String Uses

func (base *Decimal) String() string

func (*Decimal) Write Uses

func (d *Decimal) Write(encoder *binary.Encoder, v interface{}) error

type Enum Uses

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

func (*Enum) CHType Uses

func (base *Enum) CHType() string

func (*Enum) Depth Uses

func (base *Enum) Depth() int

func (*Enum) Name Uses

func (base *Enum) Name() string

func (*Enum) Read Uses

func (enum *Enum) Read(decoder *binary.Decoder) (interface{}, error)

func (*Enum) ScanType Uses

func (base *Enum) ScanType() reflect.Type

func (*Enum) String Uses

func (base *Enum) String() string

func (*Enum) Write Uses

func (enum *Enum) Write(encoder *binary.Encoder, v interface{}) error

type ErrUnexpectedType Uses

type ErrUnexpectedType struct {
    Column Column
    T      interface{}
}

func (*ErrUnexpectedType) Error Uses

func (err *ErrUnexpectedType) Error() string

type FixedString Uses

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

func (*FixedString) CHType Uses

func (base *FixedString) CHType() string

func (*FixedString) Depth Uses

func (base *FixedString) Depth() int

func (*FixedString) Name Uses

func (base *FixedString) Name() string

func (*FixedString) Read Uses

func (str *FixedString) Read(decoder *binary.Decoder) (interface{}, error)

func (*FixedString) ScanType Uses

func (base *FixedString) ScanType() reflect.Type

func (*FixedString) String Uses

func (base *FixedString) String() string

func (*FixedString) Write Uses

func (str *FixedString) Write(encoder *binary.Encoder, v interface{}) error

type Float32 Uses

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

func (*Float32) CHType Uses

func (base *Float32) CHType() string

func (*Float32) Depth Uses

func (base *Float32) Depth() int

func (*Float32) Name Uses

func (base *Float32) Name() string

func (Float32) Read Uses

func (Float32) Read(decoder *binary.Decoder) (interface{}, error)

func (*Float32) ScanType Uses

func (base *Float32) ScanType() reflect.Type

func (*Float32) String Uses

func (base *Float32) String() string

func (*Float32) Write Uses

func (float *Float32) Write(encoder *binary.Encoder, v interface{}) error

type Float64 Uses

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

func (*Float64) CHType Uses

func (base *Float64) CHType() string

func (*Float64) Depth Uses

func (base *Float64) Depth() int

func (*Float64) Name Uses

func (base *Float64) Name() string

func (Float64) Read Uses

func (Float64) Read(decoder *binary.Decoder) (interface{}, error)

func (*Float64) ScanType Uses

func (base *Float64) ScanType() reflect.Type

func (*Float64) String Uses

func (base *Float64) String() string

func (*Float64) Write Uses

func (float *Float64) Write(encoder *binary.Encoder, v interface{}) error

type IP Uses

type IP net.IP

IP column type

func (IP) MarshalBinary Uses

func (ip IP) MarshalBinary() ([]byte, error)

func (*IP) Scan Uses

func (ip *IP) Scan(value interface{}) (err error)

Scan implements the driver.Valuer interface, json field interface

func (IP) String Uses

func (ip IP) String() string

String implements the fmt.Stringer interface

func (IP) Value Uses

func (ip IP) Value() (driver.Value, error)

Value implements the driver.Valuer interface, json field interface Alignment on the right side

type IPv4 Uses

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

func (*IPv4) CHType Uses

func (base *IPv4) CHType() string

func (*IPv4) Depth Uses

func (base *IPv4) Depth() int

func (*IPv4) Name Uses

func (base *IPv4) Name() string

func (*IPv4) Read Uses

func (*IPv4) Read(decoder *binary.Decoder) (interface{}, error)

func (*IPv4) ScanType Uses

func (base *IPv4) ScanType() reflect.Type

func (*IPv4) String Uses

func (base *IPv4) String() string

func (*IPv4) Write Uses

func (ip *IPv4) Write(encoder *binary.Encoder, v interface{}) error

type IPv6 Uses

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

func (*IPv6) CHType Uses

func (base *IPv6) CHType() string

func (*IPv6) Depth Uses

func (base *IPv6) Depth() int

func (*IPv6) Name Uses

func (base *IPv6) Name() string

func (*IPv6) Read Uses

func (*IPv6) Read(decoder *binary.Decoder) (interface{}, error)

func (*IPv6) ScanType Uses

func (base *IPv6) ScanType() reflect.Type

func (*IPv6) String Uses

func (base *IPv6) String() string

func (*IPv6) Write Uses

func (ip *IPv6) Write(encoder *binary.Encoder, v interface{}) error

type Int16 Uses

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

func (*Int16) CHType Uses

func (base *Int16) CHType() string

func (*Int16) Depth Uses

func (base *Int16) Depth() int

func (*Int16) Name Uses

func (base *Int16) Name() string

func (Int16) Read Uses

func (Int16) Read(decoder *binary.Decoder) (interface{}, error)

func (*Int16) ScanType Uses

func (base *Int16) ScanType() reflect.Type

func (*Int16) String Uses

func (base *Int16) String() string

func (*Int16) Write Uses

func (i *Int16) Write(encoder *binary.Encoder, v interface{}) error

type Int32 Uses

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

func (*Int32) CHType Uses

func (base *Int32) CHType() string

func (*Int32) Depth Uses

func (base *Int32) Depth() int

func (*Int32) Name Uses

func (base *Int32) Name() string

func (Int32) Read Uses

func (Int32) Read(decoder *binary.Decoder) (interface{}, error)

func (*Int32) ScanType Uses

func (base *Int32) ScanType() reflect.Type

func (*Int32) String Uses

func (base *Int32) String() string

func (*Int32) Write Uses

func (i *Int32) Write(encoder *binary.Encoder, v interface{}) error

type Int64 Uses

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

func (*Int64) CHType Uses

func (base *Int64) CHType() string

func (*Int64) Depth Uses

func (base *Int64) Depth() int

func (*Int64) Name Uses

func (base *Int64) Name() string

func (Int64) Read Uses

func (Int64) Read(decoder *binary.Decoder) (interface{}, error)

func (*Int64) ScanType Uses

func (base *Int64) ScanType() reflect.Type

func (*Int64) String Uses

func (base *Int64) String() string

func (*Int64) Write Uses

func (i *Int64) Write(encoder *binary.Encoder, v interface{}) error

type Int8 Uses

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

func (*Int8) CHType Uses

func (base *Int8) CHType() string

func (*Int8) Depth Uses

func (base *Int8) Depth() int

func (*Int8) Name Uses

func (base *Int8) Name() string

func (Int8) Read Uses

func (Int8) Read(decoder *binary.Decoder) (interface{}, error)

func (*Int8) ScanType Uses

func (base *Int8) ScanType() reflect.Type

func (*Int8) String Uses

func (base *Int8) String() string

func (*Int8) Write Uses

func (i *Int8) Write(encoder *binary.Encoder, v interface{}) error

type Nullable Uses

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

func (*Nullable) CHType Uses

func (base *Nullable) CHType() string

func (*Nullable) Depth Uses

func (base *Nullable) Depth() int

func (*Nullable) Name Uses

func (base *Nullable) Name() string

func (*Nullable) Read Uses

func (null *Nullable) Read(decoder *binary.Decoder) (interface{}, error)

func (*Nullable) ReadNull Uses

func (null *Nullable) ReadNull(decoder *binary.Decoder, rows int) (_ []interface{}, err error)

func (*Nullable) ScanType Uses

func (null *Nullable) ScanType() reflect.Type

func (*Nullable) String Uses

func (base *Nullable) String() string

func (*Nullable) Write Uses

func (null *Nullable) Write(encoder *binary.Encoder, v interface{}) error

func (*Nullable) WriteNull Uses

func (null *Nullable) WriteNull(nulls, encoder *binary.Encoder, v interface{}) error

type String Uses

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

func (*String) CHType Uses

func (base *String) CHType() string

func (*String) Depth Uses

func (base *String) Depth() int

func (*String) Name Uses

func (base *String) Name() string

func (String) Read Uses

func (String) Read(decoder *binary.Decoder) (interface{}, error)

func (*String) ScanType Uses

func (base *String) ScanType() reflect.Type

func (*String) String Uses

func (base *String) String() string

func (*String) Write Uses

func (str *String) Write(encoder *binary.Encoder, v interface{}) error

type UInt16 Uses

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

func (*UInt16) CHType Uses

func (base *UInt16) CHType() string

func (*UInt16) Depth Uses

func (base *UInt16) Depth() int

func (*UInt16) Name Uses

func (base *UInt16) Name() string

func (UInt16) Read Uses

func (UInt16) Read(decoder *binary.Decoder) (interface{}, error)

func (*UInt16) ScanType Uses

func (base *UInt16) ScanType() reflect.Type

func (*UInt16) String Uses

func (base *UInt16) String() string

func (*UInt16) Write Uses

func (u *UInt16) Write(encoder *binary.Encoder, v interface{}) error

type UInt32 Uses

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

func (*UInt32) CHType Uses

func (base *UInt32) CHType() string

func (*UInt32) Depth Uses

func (base *UInt32) Depth() int

func (*UInt32) Name Uses

func (base *UInt32) Name() string

func (UInt32) Read Uses

func (UInt32) Read(decoder *binary.Decoder) (interface{}, error)

func (*UInt32) ScanType Uses

func (base *UInt32) ScanType() reflect.Type

func (*UInt32) String Uses

func (base *UInt32) String() string

func (*UInt32) Write Uses

func (u *UInt32) Write(encoder *binary.Encoder, v interface{}) error

type UInt64 Uses

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

func (*UInt64) CHType Uses

func (base *UInt64) CHType() string

func (*UInt64) Depth Uses

func (base *UInt64) Depth() int

func (*UInt64) Name Uses

func (base *UInt64) Name() string

func (UInt64) Read Uses

func (UInt64) Read(decoder *binary.Decoder) (interface{}, error)

func (*UInt64) ScanType Uses

func (base *UInt64) ScanType() reflect.Type

func (*UInt64) String Uses

func (base *UInt64) String() string

func (*UInt64) Write Uses

func (u *UInt64) Write(encoder *binary.Encoder, v interface{}) error

type UInt8 Uses

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

func (*UInt8) CHType Uses

func (base *UInt8) CHType() string

func (*UInt8) Depth Uses

func (base *UInt8) Depth() int

func (*UInt8) Name Uses

func (base *UInt8) Name() string

func (UInt8) Read Uses

func (UInt8) Read(decoder *binary.Decoder) (interface{}, error)

func (*UInt8) ScanType Uses

func (base *UInt8) ScanType() reflect.Type

func (*UInt8) String Uses

func (base *UInt8) String() string

func (*UInt8) Write Uses

func (u *UInt8) Write(encoder *binary.Encoder, v interface{}) error

type UUID Uses

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

func (*UUID) CHType Uses

func (base *UUID) CHType() string

func (*UUID) Depth Uses

func (base *UUID) Depth() int

func (*UUID) Name Uses

func (base *UUID) Name() string

func (*UUID) Read Uses

func (*UUID) Read(decoder *binary.Decoder) (interface{}, error)

func (*UUID) ScanType Uses

func (base *UUID) ScanType() reflect.Type

func (*UUID) String Uses

func (base *UUID) String() string

func (*UUID) Write Uses

func (u *UUID) Write(encoder *binary.Encoder, v interface{}) (err error)

Package column imports 11 packages (graph) and is imported by 2 packages. Updated 2019-09-20. Refresh now. Tools for package owners.