Documentation ¶
Index ¶
- Variables
- func Context(parent context.Context, options ...QueryOption) context.Context
- func Named(name string, value interface{}) driver.NamedValue
- func Open(opt *Options) (driver.Conn, error)
- type AcquireConnTimeout
- type Auth
- type BatchAlreadySent
- type BindMixedNamedAndNumericParams
- type Compression
- type Conn
- type ConnOpenStrategy
- type Date
- type DateTime
- type Exception
- type InvalidColumnIndex
- type Log
- type Options
- type ProfileEvent
- type Progress
- type QueryOption
- func WithExternalTable(t ...*external.Table) QueryOption
- func WithLogs(fn func(*Log)) QueryOption
- func WithProfileEvents(fn func([]ProfileEvent)) QueryOption
- func WithProgress(fn func(*Progress)) QueryOption
- func WithQueryID(queryID string) QueryOption
- func WithQuotaKey(quotaKey string) QueryOption
- func WithSettings(settings Settings) QueryOption
- func WithSpan(span trace.SpanContext) QueryOption
- type QueryOptions
- type ScanStructErr
- type ServerVersion
- type Settings
- type UnexpectedArguments
- type UnexpectedPacket
- type UnexpectedScanDestination
Constants ¶
This section is empty.
Variables ¶
View Source
var (
CompressionLZ4 compress.Method = compress.LZ4
)
View Source
var ErrUnsupportedServerRevision = errors.New("unsupported server revision")
Functions ¶
func Named ¶
func Named(name string, value interface{}) driver.NamedValue
Types ¶
type AcquireConnTimeout ¶
type AcquireConnTimeout struct { }
func (*AcquireConnTimeout) Error ¶
func (e *AcquireConnTimeout) Error() string
type BatchAlreadySent ¶
type BatchAlreadySent struct{}
func (*BatchAlreadySent) Error ¶
func (e *BatchAlreadySent) Error() string
type BindMixedNamedAndNumericParams ¶
type BindMixedNamedAndNumericParams struct{}
func (*BindMixedNamedAndNumericParams) Error ¶
func (e *BindMixedNamedAndNumericParams) Error() string
type Compression ¶
type ConnOpenStrategy ¶
type ConnOpenStrategy uint8
const ( ConnOpenInOrder ConnOpenStrategy = iota ConnOpenRoundRobin )
type InvalidColumnIndex ¶
type InvalidColumnIndex struct {
// contains filtered or unexported fields
}
func (*InvalidColumnIndex) Error ¶
func (e *InvalidColumnIndex) Error() string
type ProfileEvent ¶
type QueryOption ¶
type QueryOption func(*QueryOptions) error
func WithExternalTable ¶
func WithExternalTable(t ...*external.Table) QueryOption
func WithLogs ¶
func WithLogs(fn func(*Log)) QueryOption
func WithProfileEvents ¶
func WithProfileEvents(fn func([]ProfileEvent)) QueryOption
func WithProgress ¶
func WithProgress(fn func(*Progress)) QueryOption
func WithQueryID ¶
func WithQueryID(queryID string) QueryOption
func WithQuotaKey ¶
func WithQuotaKey(quotaKey string) QueryOption
func WithSettings ¶
func WithSettings(settings Settings) QueryOption
func WithSpan ¶
func WithSpan(span trace.SpanContext) QueryOption
type QueryOptions ¶
type QueryOptions struct {
// contains filtered or unexported fields
}
type ScanStructErr ¶
type ScanStructErr struct {
// contains filtered or unexported fields
}
func (*ScanStructErr) Error ¶
func (e *ScanStructErr) Error() string
type ServerVersion ¶
type ServerVersion = proto.ServerHandshake
type UnexpectedArguments ¶
type UnexpectedArguments = proto.UnexpectedArguments
type UnexpectedPacket ¶
type UnexpectedPacket struct {
// contains filtered or unexported fields
}
func (*UnexpectedPacket) Error ¶
func (e *UnexpectedPacket) Error() string
type UnexpectedScanDestination ¶
type UnexpectedScanDestination struct {
// contains filtered or unexported fields
}
func (*UnexpectedScanDestination) Error ¶
func (e *UnexpectedScanDestination) Error() string
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
benchmark
|
|
examples
|
|
lib
|
|
cityhash102
* COPY from https://github.com/zentures/cityhash/ NOTE: The code is modified to be compatible with CityHash128 used in ClickHouse
|
* COPY from https://github.com/zentures/cityhash/ NOTE: The code is modified to be compatible with CityHash128 used in ClickHouse |
Click to show internal directories.
Click to hide internal directories.