Versions in this module Expand all Collapse all v1 v1.0.6 Dec 3, 2020 Changes in this version + const DefaultFetchSize + const DefaultPasswd + const DefaultUser + const DefaultZoneId + type Conn struct + type DialOption interface + type FuncOption struct + type Session struct + FetchSize int32 + Host string + Passwd string + Port string + User string + ZoneId string + func NewSession(host string, port string, opts ...DialOption) Session + func (s *Session) CheckTimeseriesExists(path string) bool + func (s *Session) Close() + func (s *Session) CreateMultiTimeseries(paths []string, dataTypes []int32, encodings []int32, compressors []int32) + func (s *Session) CreateTimeseries(path string, dataType int32, encoding int32, compressor int32) + func (s *Session) DeleteData(paths []string, startTime int64, endTime int64) + func (s *Session) DeleteStorageGroup(storageGroupId string) + func (s *Session) DeleteStorageGroups(storageGroupIds []string) + func (s *Session) DeleteTimeseries(paths []string) + func (s *Session) ExecuteBatchStatement(inserts []string) + func (s *Session) ExecuteQueryStatement(sql string) *utils.SessionDataSet + func (s *Session) ExecuteRawDataQuery(paths []string, startTime int64, endTime int64) *utils.SessionDataSet + func (s *Session) ExecuteStatement(sql string) *utils.SessionDataSet + func (s *Session) ExecuteUpdateStatement(sql string) *utils.SessionDataSet + func (s *Session) GetTimeZone() string + func (s *Session) InsertRecord(deviceId string, measurements []string, dataTypes []int32, ...) + func (s *Session) InsertRecords(deviceIds []string, measurements [][]string, dataTypes [][]int32, ...) + func (s *Session) InsertStringRecord(deviceId string, measurements []string, values []string, timestamp int64) + func (s *Session) InsertStringRecords(deviceIds []string, measurements [][]string, values [][]string, ...) + func (s *Session) InsertTablet(tablet utils.Tablet) + func (s *Session) InsertTablets(tablets []utils.Tablet) + func (s *Session) Open(enableRPCCompression bool, connectionTimeoutInMs int) + func (s *Session) SetStorageGroup(storageGroupId string) + func (s *Session) SetTimeZone(timeZone string) + func (s *Session) TestInsertRecord(deviceId string, measurements []string, dataTypes []int32, ...) + func (s *Session) TestInsertRecords(deviceIds []string, measurements [][]string, dataTypes [][]int32, ...) + func (s *Session) TestInsertStringRecord(deviceId string, measurements []string, values []string, timestamp int64) + func (s *Session) TestInsertStringRecords(deviceIds []string, measurements [][]string, values [][]string, ...) + func (s *Session) TestInsertTablet(tablet utils.Tablet) + func (s *Session) TestInsertTablets(tablets []utils.Tablet)