dbHelper

Sep 26, 2024

Changes in this version

type ESHelper

+ func (the *ESHelper) BulkWriteGroup2Es(index string, themes []common_models.EsGroupTheme)

+ func (the *ESHelper) Close()

Sep 19, 2024

Changes in this version

+ type ESHelper struct

+ func NewESHelper(addresses []string, user, pwd string) *ESHelper

+ func (the *ESHelper) BulkWrite(index, reqBody string)

+ func (the *ESHelper) BulkWriteRaws2Es(index string, raws []common_models.EsRaw)

+ func (the *ESHelper) Search(index, reqBody string)

+ func (the *ESHelper) SearchLatestStationData(index string, sensorId int) (common_models.EsTheme, error)

+ func (the *ESHelper) SearchRaw(index, reqBody string) []common_models.HitRaw

+ type InfluxDBHelper struct

+ func NewInfluxDBHelper(url, token, org string) *InfluxDBHelper

+ func (the *InfluxDBHelper) Close()

+ func (the *InfluxDBHelper) Query() map[string]time.Time

+ func (the *InfluxDBHelper) QueryByOfflineGap(measurement string, offlineGap string) map[string]time.Time

+ func (the *InfluxDBHelper) Write(lines []string, bucket string)