db

package

Go to main page

Versions in this module

v1

v1.0.8

Aug 2, 2021

v1.0.7

Jul 21, 2021

Changes in this version

+ type FastCacheRt struct

+ RealTimePath string

+ func (r *FastCacheRt) BatchFetch(keys [][]byte) ([][]byte, error)

+ func (r *FastCacheRt) BatchWrite(keys, values [][]byte) error

+ func (r *FastCacheRt) Load(_ ...interface{}) error

+ func (r *FastCacheRt) Sync() error

type Gdb

+ func (gdb *Gdb) BatchWriteBoolData(groupNames []string, itemNames [][]string, itemValues [][]bool) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteBoolHistoricalData(groupNames []string, itemNames []string, timeStamps [][]int32, ...) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteFloatData(groupNames []string, itemNames [][]string, itemValues [][]float32) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteFloatHistoricalData(groupNames []string, itemNames []string, timeStamps [][]int32, ...) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteIntData(groupNames []string, itemNames [][]string, itemValues [][]int32) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteIntHistoricalData(groupNames []string, itemNames []string, timeStamps [][]int32, ...) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteStringData(groupNames []string, itemNames [][]string, itemValues [][]string) (TimeRows, error)

+ func (gdb *Gdb) BatchWriteStringHistoricalData(groupNames []string, itemNames []string, timeStamps [][]int32, ...) (TimeRows, error)

+ func (gdb *Gdb) CleanItemData(itemInfo DeletedItemsInfo) (TimeRows, error)

+ func (gdb *Gdb) CloseGdb() error

+ func (gdb *Gdb) DeleteBoolHistoricalData(groupNames, itemNames []string, startTimes, endTimes []int32) (TimeRows, error)

+ func (gdb *Gdb) DeleteFloatHistoricalData(groupNames, itemNames []string, startTimes, endTimes []int32) (TimeRows, error)

+ func (gdb *Gdb) DeleteIntHistoricalData(groupNames, itemNames []string, startTimes, endTimes []int32) (TimeRows, error)

+ func (gdb *Gdb) DeleteStringHistoricalData(groupNames, itemNames []string, startTimes, endTimes []int32) (TimeRows, error)

+ func (gdb *Gdb) GetBoolHistoricalData(groupNames, itemNames []string, startTimes, endTimes, intervals []int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetBoolHistoricalDataWithCondition(groupName string, itemNames []string, startTime, endTime, interval int32, ...) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetBoolHistoricalDataWithStamp(groupNames, itemNames []string, timeStamps [][]int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetBoolRawHistoricalData(groupNames, itemNames []string) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetFloatHistoricalData(groupNames, itemNames []string, startTimes, endTimes, intervals []int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetFloatHistoricalDataWithCondition(groupName string, itemNames []string, startTime, endTime, interval int32, ...) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetFloatHistoricalDataWithStamp(groupNames, itemNames []string, timeStamps [][]int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetFloatRawHistoricalData(groupNames, itemNames []string) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetIntHistoricalData(groupNames, itemNames []string, startTimes, endTimes, intervals []int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetIntHistoricalDataWithCondition(groupName string, itemNames []string, startTime, endTime, interval int32, ...) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetIntHistoricalDataWithStamp(groupNames, itemNames []string, timeStamps [][]int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetIntRawHistoricalData(groupNames, itemNames []string) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetStringHistoricalData(groupNames, itemNames []string, startTimes, endTimes, intervals []int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetStringHistoricalDataWithCondition(groupName string, itemNames []string, startTime, endTime, interval int32, ...) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetStringHistoricalDataWithStamp(groupNames, itemNames []string, timeStamps [][]int32) (GdbHistoricalData, error)

+ func (gdb *Gdb) GetStringRawHistoricalData(groupNames, itemNames []string) (GdbHistoricalData, error)

+ func (gdb *Gdb) ReLoadDb() (TimeRows, error)

+ func (gdb *Gdb) StopService(_ ...interface{}) error

+ type GdbHistoricalData struct

+ HistoricalData cmap.ConcurrentMap

+ Times int64

+ type GdbRealTimeData struct

+ RealTimeData cmap.ConcurrentMap

+ Times int64

+ type Options struct

+ DriverName string

+ Dsn string

+ UseInnerStop bool

+ func DefaultOptions() *Options

+ type RedisRt struct

+ DbNum int

+ Ip string

+ KeyName string

+ PassWord string

+ Port int

+ func (r *RedisRt) BatchFetch(keys [][]byte) ([][]byte, error)

+ func (r *RedisRt) BatchWrite(keys, values [][]byte) error

+ func (r *RedisRt) Load(_ ...interface{}) error

+ func (r *RedisRt) Sync() error

+ type RtGdb interface

+ BatchFetch func(keys [][]byte) ([][]byte, error)

+ BatchWrite func(keys, values [][]byte) error

+ Load func(params ...interface{}) error

+ Sync func() error

+ type StopGdb interface

+ StopService func(params ...interface{}) error

+ type TimeCols struct

+ EffectedCols int

+ Times int64

+ type TimeMap struct

+ Result cmap.ConcurrentMap

+ Times int64

+ type TimeRows struct

+ EffectedRows int

+ Times int64

v1.0.6

Jun 1, 2021

Changes in this version

type HistoricalItemValue

+ GroupName string

type ItemValue

+ GroupName string

v1.0.5

May 6, 2021

v1.0.4

May 6, 2021

v1.0.3

May 6, 2021

Changes in this version

+ type AddedGroupColumnsInfo struct

+ ColumnNames []string

+ DefaultValues []string

+ GroupName string

+ type AddedGroupInfo struct

+ ColumnNames []string

+ GroupName string

+ type AddedGroupInfos struct

+ GroupInfos []AddedGroupInfo

+ type AddedItemsInfo struct

+ GroupName string

+ ItemValues []map[string]string

+ type CheckItemsInfo struct

+ GroupName string

+ ItemNames []string

+ type Config struct

+ type DeletedGroupColumnNamesInfo struct

+ ColumnNames []string

+ GroupName string

+ type DeletedItemsInfo struct

+ Condition string

+ GroupName string

type Gdb

+ func (gdb *Gdb) BatchWriteHistoricalData(infos ...HistoricalItemValue) error

+ func (gdb *Gdb) CheckItems(groupName string, itemNames ...string) error

+ func (gdb *Gdb) CleanGroupItems(groupNames ...string) (Rows, error)

+ type GdbConfigs struct

+ ApplicationName string

+ Authorization bool

+ DbPath string

+ IP string

+ ItemDbPath string

+ Mode string

+ Port int64

+ type GdbItems struct

+ ItemValues []map[string]string

+ type GroupNamesInfo struct

+ GroupNames []string

+ type GroupPropertyInfo struct

+ ItemColumnNames []string

+ ItemCount string

+ type HistoricalItemValue struct

+ ItemName string

+ TimeStamps []string

+ Values []string

+ type HttpsConfigs struct

+ Ca bool

+ CaCertificateName string

+ SelfSignedCa bool

+ ServerCertificateName string

+ ServerKeyName string

+ type ItemsInfo struct

+ ColumnNames string

+ Condition string

+ GroupName string

+ RowCount int

+ StartRow int

+ type LogConfigs struct

+ ExpiredTime int

+ Level string

+ LogWriting bool

+ type UpdatedGroupColumnNamesInfo struct

+ GroupName string

+ NewColumnNames []string

+ OldColumnNames []string

+ type UpdatedGroupNameInfo struct

+ NewGroupName string

+ OldGroupName string

+ type UpdatedGroupNamesInfo struct

+ Infos []UpdatedGroupNameInfo

+ type UpdatedItemsInfo struct

+ Clause string

+ Condition string

+ GroupName string

v1.0.2

Feb 7, 2021

Changes in this version

+ func InitialDbServer(ip string, port int64, dbPath, itemDbPath string, ...) error

type BatchWriteString

+ WithTimeStamp bool

type Gdb

+ func (gdb *Gdb) AddItemsByExcel(groupName, filePath string) (Rows, error)

+ func (gdb *Gdb) GetRawHistoricalData(itemNames ...string) (cmap.ConcurrentMap, error)

+ type ItemValue struct

+ ItemName string

+ TimeStamp string

+ Value string

v1.0.1

Feb 3, 2021

Changes in this version

type Gdb

+ ItemDbPath string

+ func (gdb *Gdb) AddGroupColumns(info AddGroupColumnInfo) (Cols, error)

+ func (gdb *Gdb) AddGroups(groupInfos ...AddGroupInfo) (Rows, error)

+ func (gdb *Gdb) DeleteGroupColumns(info DeletedGroupColumnInfo) (Cols, error)

+ func (gdb *Gdb) DeleteGroups(groupInfos DeletedGroupInfo) (Rows, error)

+ func (gdb *Gdb) GetGroupProperty(groupNames ...string) (map[string]GroupProperty, error)

+ func (gdb *Gdb) GetGroups() (GroupInfo, error)

+ func (gdb *Gdb) GetItems(itemInfo ItemInfo) ([]map[string]string, error)

+ func (gdb *Gdb) GetItemsWithCount(itemInfo ItemInfo) (Items, error)

+ func (gdb *Gdb) UpdateGroupColumnNames(info UpdatedGroupColumnInfo) (Cols, error)

+ func (gdb *Gdb) UpdateGroupNames(groupInfos ...UpdatedGroupInfo) (Rows, error)

v1.0.0

Feb 1, 2021

Changes in this version

+ const Ram

+ const Speed

+ const TimeKey

+ const WrittenItems

+ var Json = jsonIter.ConfigCompatibleWithStandardLibrary

+ func GetGroupProperty(groupNames ...string) (map[string]GroupProperty, error)

+ func GetItems(itemInfo ItemInfo) ([]map[string]string, error)

+ type AddGroupColumnInfo struct

+ ColumnNames []string

+ GroupName string

+ type AddGroupInfo struct

+ ColumnNames []string

+ GroupName string

+ type AddItemInfo struct

+ GroupName string

+ Values []map[string]string

+ type BatchWriteString struct

+ GroupName string

+ ItemValues [][]string

+ type Cols struct

+ EffectedCols int

+ func AddGroupColumns(info AddGroupColumnInfo) (Cols, error)

+ func DeleteGroupColumns(info DeletedGroupColumnInfo) (Cols, error)

+ func UpdateGroupColumnNames(info UpdatedGroupColumnInfo) (Cols, error)

+ type ColumnNameError struct

+ ErrorInfo string

+ func (cn ColumnNameError) Error() string

+ type DeadZone struct

+ DeadZoneCount int

+ ItemName string

+ type DeletedGroupColumnInfo struct

+ ColumnNames []string

+ GroupName string

+ type DeletedGroupInfo struct

+ GroupNames []string

+ type DeletedHistoricalDataInfo struct

+ ItemNames []string

+ TimeStamps []TimeStamp

+ type ExcelError struct

+ ErrorInfo string

+ func (oe ExcelError) Error() string

+ type Gdb struct

+ DbPath string

+ HisDb *leveldb.DB

+ InfoDb *leveldb.DB

+ RtDb *leveldb.DB

+ RtDbFilter cmap.ConcurrentMap

+ func NewGdb(dbPath string) *Gdb

+ func (gdb *Gdb) AddCalcItemHandler(c *gin.Context)

+ func (gdb *Gdb) AddGroupColumnsHandler(c *gin.Context)

+ func (gdb *Gdb) AddGroupsHandler(c *gin.Context)

+ func (gdb *Gdb) AddItems(itemInfo AddItemInfo) (Rows, error)

+ func (gdb *Gdb) AddItemsHandler(c *gin.Context)

+ func (gdb *Gdb) BatchWrite(kv [][]string, withTimeStamp bool) (Rows, error)

+ func (gdb *Gdb) BatchWriteHandler(c *gin.Context)

+ func (gdb *Gdb) Calc() error

+ func (gdb *Gdb) DeleteCalculationItemHandler(c *gin.Context)

+ func (gdb *Gdb) DeleteGroupColumnsHandler(c *gin.Context)

+ func (gdb *Gdb) DeleteGroupsHandler(c *gin.Context)

+ func (gdb *Gdb) DeleteHistoricalData(itemNames []string, timeStamps []TimeStamp) (Rows, error)

+ func (gdb *Gdb) DeleteHistoricalDataHandler(c *gin.Context)

+ func (gdb *Gdb) DeleteItems(itemInfo ItemInfo) (Rows, error)

+ func (gdb *Gdb) DeleteItemsHandler(c *gin.Context)

+ func (gdb *Gdb) GetCalcItemHandler(c *gin.Context)

+ func (gdb *Gdb) GetDbInfoHandler(c *gin.Context)

+ func (gdb *Gdb) GetDbSpeedHistoryHandler(c *gin.Context)

+ func (gdb *Gdb) GetGroupPropertyHandler(c *gin.Context)

+ func (gdb *Gdb) GetGroupsHandler(c *gin.Context)

+ func (gdb *Gdb) GetHistoricalData(itemNames []string, startTimeStamps []int, endTimeStamps []int, ...) (cmap.ConcurrentMap, error)

+ func (gdb *Gdb) GetHistoricalDataHandler(c *gin.Context)

+ func (gdb *Gdb) GetHistoricalDataWithCondition(itemNames []string, startTime []int, endTime []int, intervals []int, ...) (cmap.ConcurrentMap, error)

+ func (gdb *Gdb) GetHistoricalDataWithConditionHandler(c *gin.Context)

+ func (gdb *Gdb) GetHistoricalDataWithStamp(itemNames []string, timeStamps ...string) (cmap.ConcurrentMap, error)

+ func (gdb *Gdb) GetHistoricalDataWithStampHandler(c *gin.Context)

+ func (gdb *Gdb) GetItemsHandler(c *gin.Context)

+ func (gdb *Gdb) GetJsCodeHandler(c *gin.Context)

+ func (gdb *Gdb) GetLogsHandler(c *gin.Context)

+ func (gdb *Gdb) GetProcessInfo() error

+ func (gdb *Gdb) GetRealTimeData(itemNames ...string) (cmap.ConcurrentMap, error)

+ func (gdb *Gdb) GetRealTimeDataHandler(c *gin.Context)

+ func (gdb *Gdb) HandleAddItemsByExcel(c *gin.Context)

+ func (gdb *Gdb) HandleGetItemsWithCount(c *gin.Context)

+ func (gdb *Gdb) HandleGetUerInfo(c *gin.Context)

+ func (gdb *Gdb) HandleUploadFile(c *gin.Context)

+ func (gdb *Gdb) HandleUserLogin(c *gin.Context)

+ func (gdb *Gdb) InitialDb(flag int) error

+ func (gdb *Gdb) StartCalculationItemHandler(c *gin.Context)

+ func (gdb *Gdb) StopCalculationItemHandler(c *gin.Context)

+ func (gdb *Gdb) UpdateCalcItemHandler(c *gin.Context)

+ func (gdb *Gdb) UpdateGroupColumnNamesHandler(c *gin.Context)

+ func (gdb *Gdb) UpdateGroupNamesHandler(c *gin.Context)

+ func (gdb *Gdb) UpdateItems(itemInfo ItemInfo) (Rows, error)

+ func (gdb *Gdb) UpdateItemsHandler(c *gin.Context)

+ type GroupInfo struct

+ GroupNames []string

+ func GetGroups() (GroupInfo, error)

+ type GroupProperty struct

+ ItemColumnNames []string

+ ItemCount string

+ type HistoricalDataInfo struct

+ DeadZones []DeadZone

+ EndTimes []int

+ FilterCondition string

+ Intervals []int

+ ItemNames []string

+ StartTimes []int

+ TimeStamps []string

+ type ItemInfo struct

+ Clause string

+ Column string

+ Condition string

+ GroupName string

+ RowCount int

+ StartRow int

+ type Items struct

+ ItemCount int64

+ ItemValues []map[string]string

+ func GetItemsWithCount(itemInfo ItemInfo) (Items, error)

+ type OperationResponseData struct

+ Code int

+ Message string

+ type RealTimeDataString struct

+ ItemNames []string

+ type ResponseData struct

+ Code int

+ Data interface{}

+ Message string

+ type Rows struct

+ EffectedRows int

+ func AddGroups(groupInfos ...AddGroupInfo) (Rows, error)

+ func DeleteGroups(groupInfos DeletedGroupInfo) (Rows, error)

+ func UpdateGroupNames(groupInfos ...UpdatedGroupInfo) (Rows, error)

+ type TimeStamp struct

+ EndTime string

+ StartTime string

+ type UpdatedGroupColumnInfo struct

+ GroupName string

+ NewColumnNames []string

+ OldColumnNames []string

+ type UpdatedGroupInfo struct

+ NewGroupName string

+ OldGroupName string

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