clickhouse

Oct 16, 2024

Changes in this version

+ type HTTPProxy func(*http.Request) (*url.URL, error)

type Options

+ HTTPProxyURL *url.URL

Jun 25, 2024

Changes in this version

type ConnOpenStrategy

+ const ConnOpenRandom

Mar 11, 2024

Changes in this version

type HTTPReaderWriter

+ func (rw *HTTPReaderWriter) NewReader(res *http.Response) (io.Reader, error)

Sep 12, 2023

Changes in this version

type Options

+ FreeBufOnConnRelease bool

Jul 21, 2023

Changes in this version

+ var ErrBatchNotSent = errors.New("clickhouse: invalid retry, batch not sent yet")

+ var ErrServerUnexpectedData = errors.New("code: 101, message: Unexpected packet Data received from client")

May 12, 2023

Changes in this version

+ type CustomSetting struct

+ Value string

Mar 27, 2023

Changes in this version

type Options

+ HttpUrlPath string

Mar 8, 2023

Changes in this version

type QueryOption

+ func WithUserLocation(location *time.Location) QueryOption

Jan 27, 2023

Changes in this version

+ const ClientName

+ const ClientTCPProtocolVersion

+ const ClientVersionMajor

+ const ClientVersionMinor

+ const ClientVersionPatch

+ type ClientInfo struct

+ Products []struct{ ... }

+ func (o ClientInfo) String() string

type Options

+ ClientInfo ClientInfo

Jan 10, 2023

Changes in this version

+ var ErrExpectedStringValueInNamedValueForQueryParameter = errors.New("expected string value in NamedValue for query parameter")

+ type Dial func(ctx context.Context, addr string, opt *Options) (DialResult, error)

+ type DialResult struct

+ func DefaultDialStrategy(ctx context.Context, connID int, opt *Options, dial Dial) (r DialResult, err error)

type Options

+ DialStrategy func(ctx context.Context, connID int, options *Options, dial Dial) (DialResult, error)

+ MaxCompressionBuffer int

+ type Parameters map[string]string

type QueryOption

+ func WithParameters(params Parameters) QueryOption

Nov 24, 2022

Changes in this version

+ var ErrBatchInvalid = errors.New("clickhouse: batch is invalid. check appended data is correct")

Nov 21, 2022

Changes in this version

type Options

+ BlockBufferSize uint8

+ HttpHeaders map[string]string

type QueryOption

+ func WithBlockBufferSize(size uint8) QueryOption

Aug 21, 2022

Changes in this version

+ const CompressionBrotli

+ const CompressionDeflate

+ const CompressionGZIP

+ const CompressionNone

+ const CompressionZSTD

+ func Connector(opt *Options) driver.Connector

+ type ArraySet []interface

type Compression

+ Level int

+ type CompressionMethod byte

+ func (c CompressionMethod) String() string

+ type HTTPReaderWriter struct

type Options

+ Protocol Protocol

+ type Pool struct

+ func NewPool(fn func() T) Pool[T]

+ func (p *Pool[T]) Get() T

+ func (p *Pool[T]) Put(x T)

+ type Protocol int

+ const HTTP

+ const Native

+ func (p Protocol) String() string

Jun 27, 2022

Changes in this version

+ var ErrHttpNotSupported = errors.New("HTTP: not supported")

+ func DateNamed(name string, value time.Time, scale TimeUnit) driver.NamedDateValue

+ type GroupSet struct

+ Value []interface{}

+ type InterfaceType int

+ const HttpInterface

+ const NativeInterface

type Options

+ Interface InterfaceType

+ ReadTimeout time.Duration

+ type TimeUnit uint8

+ const MicroSeconds

+ const MilliSeconds

+ const NanoSeconds

+ const Seconds

Jun 7, 2022

Changes in this version

+ var ErrAcquireConnNoAddress = errors.New("clickhouse: no valid address supplied")

+ var ErrBindMixedParamsFormats = errors.New("clickhouse [bind]: mixed named, numeric or positional parameters")

type Options

+ Debugf func(format string, v ...interface{})

Feb 5, 2022

Changes in this version

type Options

+ DialContext func(ctx context.Context, addr string) (net.Conn, error)

Feb 4, 2022

Changes in this version

type Options

+ Dial func(addr string) (net.Conn, error)

Feb 2, 2022

Changes in this version

+ var CompressionLZ4 compress.Method = compress.LZ4

+ var ErrAcquireConnTimeout = errors.New(...)

+ var ErrBatchAlreadySent = errors.New("clickhouse: batch has already been sent")

+ var ErrBindMixedNamedAndNumericParams = errors.New("clickhouse [bind]: mixed named and numeric parameters")

+ var ErrUnsupportedServerRevision = errors.New("clickhouse: unsupported server revision")

+ func Context(parent context.Context, options ...QueryOption) context.Context

+ func Named(name string, value interface{}) driver.NamedValue

+ func Open(opt *Options) (driver.Conn, error)

+ func OpenDB(opt *Options) *sql.DB

+ type Auth struct

+ Database string

+ Password string

+ Username string

+ type Compression struct

+ Method compress.Method

+ type Conn = driver.Conn

+ type ConnOpenStrategy uint8

+ const ConnOpenInOrder

+ const ConnOpenRoundRobin

+ type Exception = proto.Exception

+ type Log struct

+ Hostname string

+ Priority int8

+ QueryID string

+ Source string

+ Text string

+ ThreadID uint64

+ Time time.Time

+ TimeMicro uint32

+ type OpError struct

+ ColumnName string

+ Err error

+ Op string

+ func (e *OpError) Error() string

+ type Options struct

+ Addr []string

+ Auth Auth

+ Compression *Compression

+ ConnMaxLifetime time.Duration

+ ConnOpenStrategy ConnOpenStrategy

+ Debug bool

+ DialTimeout time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ Settings Settings

+ TLS *tls.Config

+ func ParseDSN(dsn string) (*Options, error)

+ type ProfileEvent struct

+ CurrentTime time.Time

+ Hostname string

+ Name string

+ ThreadID uint64

+ Type string

+ Value int64

+ type ProfileInfo = proto.ProfileInfo

+ type Progress = proto.Progress

+ type QueryOption func(*QueryOptions) error

+ func WithExternalTable(t ...*external.Table) QueryOption

+ func WithLogs(fn func(*Log)) QueryOption

+ func WithProfileEvents(fn func([]ProfileEvent)) QueryOption

+ func WithProfileInfo(fn func(*ProfileInfo)) 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

+ func WithStdAsync(wait bool) QueryOption

+ type QueryOptions struct

+ type ServerVersion = proto.ServerHandshake

+ type Settings map[string]interface