questdb

Aug 14, 2024

Changes in this version

type LineSenderPool

+ func PoolFromOptions(opts ...LineSenderOption) (*LineSenderPool, error)

+ func (p *LineSenderPool) Sender(ctx context.Context) (LineSender, error)

Aug 2, 2024

Changes in this version

+ type LineSenderPool struct

+ func PoolFromConf(conf string, opts ...LineSenderPoolOption) (*LineSenderPool, error)

+ func (p *LineSenderPool) Acquire(ctx context.Context) (LineSender, error)

+ func (p *LineSenderPool) Close(ctx context.Context) error

+ func (p *LineSenderPool) IsClosed() bool

+ func (p *LineSenderPool) Len() int

+ func (p *LineSenderPool) Release(ctx context.Context, s LineSender) error

+ type LineSenderPoolOption func(*LineSenderPool)

+ func WithMaxSenders(count int) LineSenderPoolOption

Jun 3, 2024

Changes in this version

type LineSender

+ func LineSenderFromEnv(ctx context.Context) (LineSender, error)

Mar 20, 2024

Changes in this version

+ type HttpError struct

+ Code string

+ ErrorId string

+ Line int

+ Message string

+ func (e *HttpError) Error() string

+ func (e *HttpError) HttpStatus() int

+ type InvalidConfigStrError struct

+ func NewInvalidConfigStrError(msg string, args ...interface{}) *InvalidConfigStrError

+ func (e *InvalidConfigStrError) Error() string

+ type LineSender interface

+ At func(ctx context.Context, ts time.Time) error

+ AtNow func(ctx context.Context) error

+ BoolColumn func(name string, val bool) LineSender

+ Close func(ctx context.Context) error

+ Float64Column func(name string, val float64) LineSender

+ Flush func(ctx context.Context) error

+ Int64Column func(name string, val int64) LineSender

+ Long256Column func(name string, val *big.Int) LineSender

+ StringColumn func(name, val string) LineSender

+ Symbol func(name, val string) LineSender

+ Table func(name string) LineSender

+ TimestampColumn func(name string, ts time.Time) LineSender

+ func LineSenderFromConf(ctx context.Context, conf string) (LineSender, error)

+ func NewLineSender(ctx context.Context, opts ...LineSenderOption) (LineSender, error)

+ type LineSenderOption func(*lineSenderConfig)

+ func WithAddress(addr string) LineSenderOption

+ func WithAuth(tokenId, token string) LineSenderOption

+ func WithAutoFlushDisabled() LineSenderOption

+ func WithAutoFlushInterval(interval time.Duration) LineSenderOption

+ func WithAutoFlushRows(rows int) LineSenderOption

+ func WithBasicAuth(user, pass string) LineSenderOption

+ func WithBearerToken(token string) LineSenderOption

+ func WithFileNameLimit(limit int) LineSenderOption

+ func WithHttp() LineSenderOption

+ func WithHttpTransport(t *http.Transport) LineSenderOption

+ func WithInitBufferSize(sizeInBytes int) LineSenderOption

+ func WithMaxBufferSize(sizeInBytes int) LineSenderOption

+ func WithMinThroughput(bytesPerSecond int) LineSenderOption

+ func WithRequestTimeout(timeout time.Duration) LineSenderOption

+ func WithRetryTimeout(t time.Duration) LineSenderOption

+ func WithTcp() LineSenderOption

+ func WithTls() LineSenderOption

+ func WithTlsInsecureSkipVerify() LineSenderOption

+ type RetryTimeoutError struct

+ LastErr error

+ Timeout time.Duration

+ func NewRetryTimeoutError(timeout time.Duration, lastError error) *RetryTimeoutError

+ func (e *RetryTimeoutError) Error() string