column

package
v1.3.3 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2018 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const UUIDLen = 16

Variables

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

Functions

This section is empty.

Types

type Array

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

func (*Array) CHType

func (base *Array) CHType() string

func (*Array) Name

func (base *Array) Name() string

func (*Array) Read

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

func (*Array) ReadArray

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

func (*Array) ScanType

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

func (*Array) String

func (base *Array) String() string

func (*Array) Write

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

func (*Array) WriteArray

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

type ArrayWriter

type ArrayWriter interface {
	WriteArray(encoder *binary.Encoder, column Column) (uint64, error)
}

type Column

type Column interface {
	Name() string
	CHType() string
	ScanType() reflect.Type
	Read(*binary.Decoder) (interface{}, error)
	Write(*binary.Encoder, interface{}) error
	// contains filtered or unexported methods
}

func Factory

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

type DateTime

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

func (*DateTime) CHType

func (base *DateTime) CHType() string

func (*DateTime) Name

func (base *DateTime) Name() string

func (*DateTime) Read

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

func (*DateTime) ScanType

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

func (*DateTime) String

func (base *DateTime) String() string

func (*DateTime) Write

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

type Enum

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

func (*Enum) CHType

func (base *Enum) CHType() string

func (*Enum) Name

func (base *Enum) Name() string

func (*Enum) Read

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

func (*Enum) ScanType

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

func (*Enum) String

func (base *Enum) String() string

func (*Enum) Write

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

type ErrUnexpectedType

type ErrUnexpectedType struct {
	Column Column
	T      interface{}
}

func (*ErrUnexpectedType) Error

func (err *ErrUnexpectedType) Error() string

type FixedString

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

func (*FixedString) CHType

func (base *FixedString) CHType() string

func (*FixedString) Name

func (base *FixedString) Name() string

func (*FixedString) Read

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

func (*FixedString) ScanType

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

func (*FixedString) String

func (base *FixedString) String() string

func (*FixedString) Write

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

type Float32

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

func (*Float32) CHType

func (base *Float32) CHType() string

func (*Float32) Name

func (base *Float32) Name() string

func (Float32) Read

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

func (*Float32) ScanType

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

func (*Float32) String

func (base *Float32) String() string

func (*Float32) Write

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

type Float64

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

func (*Float64) CHType

func (base *Float64) CHType() string

func (*Float64) Name

func (base *Float64) Name() string

func (Float64) Read

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

func (*Float64) ScanType

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

func (*Float64) String

func (base *Float64) String() string

func (*Float64) Write

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

type Int16

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

func (*Int16) CHType

func (base *Int16) CHType() string

func (*Int16) Name

func (base *Int16) Name() string

func (Int16) Read

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

func (*Int16) ScanType

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

func (*Int16) String

func (base *Int16) String() string

func (*Int16) Write

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

type Int32

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

func (*Int32) CHType

func (base *Int32) CHType() string

func (*Int32) Name

func (base *Int32) Name() string

func (Int32) Read

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

func (*Int32) ScanType

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

func (*Int32) String

func (base *Int32) String() string

func (*Int32) Write

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

type Int64

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

func (*Int64) CHType

func (base *Int64) CHType() string

func (*Int64) Name

func (base *Int64) Name() string

func (Int64) Read

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

func (*Int64) ScanType

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

func (*Int64) String

func (base *Int64) String() string

func (*Int64) Write

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

type Int8

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

func (*Int8) CHType

func (base *Int8) CHType() string

func (*Int8) Name

func (base *Int8) Name() string

func (Int8) Read

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

func (*Int8) ScanType

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

func (*Int8) String

func (base *Int8) String() string

func (*Int8) Write

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

type Nullable

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

func (*Nullable) CHType

func (base *Nullable) CHType() string

func (*Nullable) Name

func (base *Nullable) Name() string

func (*Nullable) Read

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

func (*Nullable) ReadNull added in v1.2.2

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

func (*Nullable) ScanType

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

func (*Nullable) String

func (base *Nullable) String() string

func (*Nullable) Write

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

func (*Nullable) WriteNull added in v1.2.2

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

type String

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

func (*String) CHType

func (base *String) CHType() string

func (*String) Name

func (base *String) Name() string

func (String) Read

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

func (*String) ScanType

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

func (*String) String

func (base *String) String() string

func (*String) Write

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

type UInt16

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

func (*UInt16) CHType

func (base *UInt16) CHType() string

func (*UInt16) Name

func (base *UInt16) Name() string

func (UInt16) Read

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

func (*UInt16) ScanType

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

func (*UInt16) String

func (base *UInt16) String() string

func (*UInt16) Write

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

type UInt32

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

func (*UInt32) CHType

func (base *UInt32) CHType() string

func (*UInt32) Name

func (base *UInt32) Name() string

func (UInt32) Read

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

func (*UInt32) ScanType

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

func (*UInt32) String

func (base *UInt32) String() string

func (*UInt32) Write

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

type UInt64

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

func (*UInt64) CHType

func (base *UInt64) CHType() string

func (*UInt64) Name

func (base *UInt64) Name() string

func (UInt64) Read

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

func (*UInt64) ScanType

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

func (*UInt64) String

func (base *UInt64) String() string

func (*UInt64) Write

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

type UInt8

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

func (*UInt8) CHType

func (base *UInt8) CHType() string

func (*UInt8) Name

func (base *UInt8) Name() string

func (UInt8) Read

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

func (*UInt8) ScanType

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

func (*UInt8) String

func (base *UInt8) String() string

func (*UInt8) Write

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

type UUID

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

func (*UUID) CHType

func (base *UUID) CHType() string

func (*UUID) Name

func (base *UUID) Name() string

func (*UUID) Read

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

func (*UUID) ScanType

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

func (*UUID) String

func (base *UUID) String() string

func (*UUID) Write

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

Jump to

Keyboard shortcuts

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