Documentation
¶
Index ¶
- Variables
- func DateNamed(name string, value time.Time, scale TimeUnit) driver.NamedDateValue
- func Named(name string, value any) driver.NamedValue
- type ArraySet
- type AsyncOptions
- type ClientInfo
- type ColumnNameAndType
- type ConnOpenStrategy
- type GroupSet
- type Options
- type Parameters
- type QueryOption
- type QueryOptions
- type Settings
- type TimeUnit
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 ¶
Types ¶
type AsyncOptions ¶
type AsyncOptions struct {
// contains filtered or unexported fields
}
type ClientInfo ¶
func (ClientInfo) Append ¶
func (a ClientInfo) Append(b ClientInfo) ClientInfo
Append returns a new copy of the combined ClientInfo structs
type ColumnNameAndType ¶
ColumnNameAndType represents a column name and type
type ConnOpenStrategy ¶
type ConnOpenStrategy uint8
const ( ConnOpenInOrder ConnOpenStrategy = iota ConnOpenRoundRobin ConnOpenRandom )
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
}
type Parameters ¶
type QueryOption ¶
type QueryOption func(*QueryOptions) error
type QueryOptions ¶
type QueryOptions struct {
// contains filtered or unexported fields
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.