package clickhouse
import "github.com/ClickHouse/clickhouse-go/v2"
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
Variables ¶
Functions ¶
func Context ¶
func Context(parent context.Context, options ...QueryOption) context.Context
func Named ¶
func Named(name string, value interface{}) driver.NamedValue
func Open ¶
Types ¶
type AcquireConnTimeout ¶
type AcquireConnTimeout struct { }
func (*AcquireConnTimeout) Error ¶
func (e *AcquireConnTimeout) Error() string
type Auth ¶
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 Conn ¶
type ConnOpenStrategy ¶
type ConnOpenStrategy uint8
const ( ConnOpenInOrder ConnOpenStrategy = iota ConnOpenRoundRobin )
type Date ¶
type DateTime ¶
type Exception ¶
type InvalidColumnIndex ¶
type InvalidColumnIndex struct {
// contains filtered or unexported fields
}
func (*InvalidColumnIndex) Error ¶
func (e *InvalidColumnIndex) Error() string
type Log ¶
type Log struct { Time time.Time TimeMicro uint32 Hostname string QueryID string ThreadID uint64 Priority int8 Source string Text string }
type Options ¶
type Options struct { TLS *tls.Config Addr []string Auth Auth Debug bool Settings Settings DialTimeout time.Duration Compression *Compression MaxOpenConns int MaxIdleConns int ConnMaxLifetime time.Duration ConnOpenStrategy ConnOpenStrategy }
type ProfileEvent ¶
type ProfileEvent struct { Hostname string CurrentTime time.Time ThreadID uint64 Type string Name string Value int64 }
type Progress ¶
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 Settings ¶
type Settings map[string]interface{}
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 ¶
bind.go clickhouse.go clickhouse_options.go clickhouse_rows.go clickhouse_std.go conn.go conn_batch.go conn_exec.go conn_handshake.go conn_logs.go conn_ping.go conn_process.go conn_profile_events.go conn_query.go conn_send_query.go context.go errors.go scan.go
Directories ¶
- Version
- v2.0.0-alpha.4
- Published
- Jan 19, 2022
- Platform
- darwin/amd64
- Imports
- 26 packages
- Last checked
- now –
Tools for package owners.