db

Documentation

Index

• func InitDB(config *config.Config) error
• type DBInterface
  • func GetInstance() DBInterface
• type InfluxDB
  • func NewInfluxDB(config *config.Config) (*InfluxDB, error)
  • func (db *InfluxDB) Close() error
  • func (db *InfluxDB) SaveNodeEnergy(data *types.NodeData) error
  • func (db *InfluxDB) SaveTaskEnergy(taskData *types.TaskData) error

Functions

func InitDB

func InitDB(config *config.Config) error

Types

type DBInterface

type DBInterface interface {
	SaveNodeEnergy(*types.NodeData) error
	SaveTaskEnergy(*types.TaskData) error
	Close() error
}

func GetInstance

func GetInstance() DBInterface

type InfluxDB

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

func NewInfluxDB

func NewInfluxDB(config *config.Config) (*InfluxDB, error)

func (*InfluxDB) Close

func (db *InfluxDB) Close() error

func (*InfluxDB) SaveNodeEnergy

func (db *InfluxDB) SaveNodeEnergy(data *types.NodeData) error

func (*InfluxDB) SaveTaskEnergy

func (db *InfluxDB) SaveTaskEnergy(taskData *types.TaskData) error