dbHelper

Documentation

Index

• type ESHelper
  • func NewESHelper(addresses []string, user, pwd string) *ESHelper
  • func (the *ESHelper) BulkWrite(index, reqBody string)
  • func (the *ESHelper) BulkWriteGroup2Es(index string, themes []common_models.EsGroupTheme)
  • func (the *ESHelper) BulkWriteRaws2Es(index string, raws []common_models.EsRaw)
  • func (the *ESHelper) Close()
  • 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
  • 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)

Types

type ESHelper

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

func NewESHelper

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

func (*ESHelper) BulkWrite

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

func (*ESHelper) BulkWriteGroup2Es

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

BulkWriteGroup2Es 分组主题数据写入ES

func (*ESHelper) BulkWriteRaws2Es

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

func (*ESHelper) Close

func (the *ESHelper) Close()

func (*ESHelper) Search

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

func (*ESHelper) SearchLatestStationData

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

func (*ESHelper) SearchRaw

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

type InfluxDBHelper

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

func NewInfluxDBHelper

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

func (*InfluxDBHelper) Close

func (the *InfluxDBHelper) Close()

func (*InfluxDBHelper) Query

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

func (*InfluxDBHelper) QueryByOfflineGap

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

func (*InfluxDBHelper) Write

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