storageDBs

Documentation

Index

• type IStorageConsumer
  • func LoadIStorageConsumer() []IStorageConsumer
• type Storage2Es
  • func NewStorage2Es6ByDefaultConfig() *Storage2Es
  • func (the *Storage2Es) SaveGroupTheme(dataList []common_models.EsGroupTheme)
  • func (the *Storage2Es) SaveRaw(dataList []common_models.EsRaw)
  • func (the *Storage2Es) SaveTheme(dataList []common_models.EsTheme)
  • func (the *Storage2Es) SaveVib(dataList []common_models.EsVbRaw)
• type Storage2InfluxDB
  • func NewStorage2InfluxDB2(influx *dbHelper.InfluxDBHelper) *Storage2InfluxDB
  • func NewStorage2InfluxDB2ByDefaultConfig() *Storage2InfluxDB
  • func (the *Storage2InfluxDB) SaveDeviceData(dataList []common_models.DeviceData)
  • func (the *Storage2InfluxDB) SaveGroupTheme(dataList []common_models.EsGroupTheme)
  • func (the *Storage2InfluxDB) SaveRaw(dataList []common_models.EsRaw)
  • func (the *Storage2InfluxDB) SaveTheme(dataList []common_models.EsTheme)
  • func (the *Storage2InfluxDB) SaveThemeData(dataList []common_models.StationData)
  • func (the *Storage2InfluxDB) SaveVib(dataList []common_models.EsVbRaw)

Types

type IStorageConsumer

type IStorageConsumer interface {
	SaveRaw(d []common_models.EsRaw)
	SaveTheme(d []common_models.EsTheme)
	SaveVib(d []common_models.EsVbRaw)
	SaveGroupTheme(d []common_models.EsGroupTheme)
}

func LoadIStorageConsumer

func LoadIStorageConsumer() []IStorageConsumer

type Storage2Es

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

func NewStorage2Es6ByDefaultConfig

func NewStorage2Es6ByDefaultConfig() *Storage2Es

NewStorage2Es6ByDefaultConfig 读取默认配置-初始化

func (*Storage2Es) SaveGroupTheme

func (the *Storage2Es) SaveGroupTheme(dataList []common_models.EsGroupTheme)

SaveGroupTheme 分组主题数据写入ES

func (*Storage2Es) SaveRaw

func (the *Storage2Es) SaveRaw(dataList []common_models.EsRaw)

func (*Storage2Es) SaveTheme

func (the *Storage2Es) SaveTheme(dataList []common_models.EsTheme)

func (*Storage2Es) SaveVib

func (the *Storage2Es) SaveVib(dataList []common_models.EsVbRaw)

type Storage2InfluxDB

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

func NewStorage2InfluxDB2

func NewStorage2InfluxDB2(influx *dbHelper.InfluxDBHelper) *Storage2InfluxDB

func NewStorage2InfluxDB2ByDefaultConfig

func NewStorage2InfluxDB2ByDefaultConfig() *Storage2InfluxDB

NewStorage2InfluxDB2ByDefaultConfig 读取默认配置-初始化

func (*Storage2InfluxDB) SaveDeviceData

func (the *Storage2InfluxDB) SaveDeviceData(dataList []common_models.DeviceData)

func (*Storage2InfluxDB) SaveGroupTheme

func (the *Storage2InfluxDB) SaveGroupTheme(dataList []common_models.EsGroupTheme)

func (*Storage2InfluxDB) SaveRaw

func (the *Storage2InfluxDB) SaveRaw(dataList []common_models.EsRaw)

func (*Storage2InfluxDB) SaveTheme

func (the *Storage2InfluxDB) SaveTheme(dataList []common_models.EsTheme)

func (*Storage2InfluxDB) SaveThemeData

func (the *Storage2InfluxDB) SaveThemeData(dataList []common_models.StationData)

func (*Storage2InfluxDB) SaveVib

func (the *Storage2InfluxDB) SaveVib(dataList []common_models.EsVbRaw)