iotdb_go

package
v2.0.10 Latest Latest
Warning

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

Go to latest
Published: Aug 21, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrBatchInvalid              = errors.New("iotdb: batch is invalid. check appended data is correct")
	ErrBatchAlreadySent          = errors.New("iotdb: batch has already been sent")
	ErrBatchNotSent              = errors.New("iotdb: invalid retry, batch not sent yet")
	ErrAcquireConnTimeout        = errors.New("iotdb: acquire conn timeout. you can increase the number of max open conn or the dial timeout")
	ErrUnsupportedServerRevision = errors.New("iotdb: unsupported server revision")
	ErrBindMixedParamsFormats    = errors.New("iotdb [bind]: mixed named, numeric or positional parameters")
	ErrAcquireConnNoAddress      = errors.New("iotdb: no valid address supplied")
	ErrServerUnexpectedData      = errors.New("code: 101, message: Unexpected packet Data received from client")
	ErrConnectionClosed          = errors.New("iotdb: connection is closed")
	ErrTransactionsUnsupported   = errors.New("iotdb: transactions are not supported")
)
View Source
var (
	ErrInvalidValueInNamedDateValue = errors.New("invalid value in NamedDateValue for query parameter")
	ErrUnsupportedQueryParameter    = errors.New("unsupported query parameter type")
)
View Source
var (
	ErrInvalidTimezone = errors.New("invalid timezone value")
)

Functions

func DateNamed

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

func Named

func Named(name string, value any) driver.NamedValue

Types

type ArraySet

type ArraySet []any

type AsyncOptions

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

type ClientInfo

type ClientInfo struct {
	Products []struct {
		Name    string
		Version string
	}

	Comment []string
}

func (ClientInfo) Append

func (a ClientInfo) Append(b ClientInfo) ClientInfo

Append returns a new copy of the combined ClientInfo structs

type ColumnNameAndType

type ColumnNameAndType struct {
	Name string
	Type string
}

ColumnNameAndType represents a column name and type

type ConnOpenStrategy

type ConnOpenStrategy uint8
const (
	ConnOpenInOrder ConnOpenStrategy = iota
	ConnOpenRoundRobin
	ConnOpenRandom
)

type GroupSet

type GroupSet struct {
	Value []any
}

type Options

type Options struct {
	client.PoolConfig
	Debug                           bool
	ClientInfo                      ClientInfo
	Addr                            []string
	ConnOpenStrategy                ConnOpenStrategy
	DialContext                     func(ctx context.Context, addr string) (net.Conn, error)
	TLS                             *tls.Config
	DialTimeout                     time.Duration                 // default 30 second
	Debugf                          func(format string, v ...any) // only works when Debug is true
	PoolMaxSize                     *int
	PoolConnectionTimeoutInMs       *int
	PoolWaitToGetSessionTimeoutInMs *int
	PoolEnableCompression           *bool
}

func ParseDSN

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

type Parameters

type Parameters map[string]string

type QueryOption

type QueryOption func(*QueryOptions) error

type QueryOptions

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

type Settings

type Settings map[string]any

type TimeUnit

type TimeUnit uint8
const (
	Seconds TimeUnit = iota
	MilliSeconds
	MicroSeconds
	NanoSeconds
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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