v1

Documentation

Index

• Constants
• func BuildQuery(isPush bool, vmId string, metric string, period string, aggregateType string, ...) (string, error)
• type Config
• type Storage
  • func GetInstance() *Storage
  • func (s Storage) DeleteMetric(database string, metric, duration string) error
  • func (s Storage) Initialize() error
  • func (s Storage) ReadMetric(isPush bool, nsId string, mcisId string, vmId string, metric string, ...) (interface{}, error)
  • func (s Storage) WriteMetric(dbName string, metrics map[string]interface{}) error
  • func (s Storage) WriteOnDemandMetric(dbName string, metricName string, tagArr map[string]string, ...) error

Constants

const (
	DefaultDatabase = "cbmon"
	PullDatabase    = "cbmonpull"
)

Functions

func BuildQuery

func BuildQuery(isPush bool, vmId string, metric string, period string, aggregateType string, duration string) (string, error)

Types

type Config

type Config struct {
	Addr     string
	Username string
	Password string
	Database string
}

type Storage

type Storage struct {
	Config Config
	Client influxdbClient.Client
}

func GetInstance

func GetInstance() *Storage

func (Storage) DeleteMetric

func (s Storage) DeleteMetric(database string, metric, duration string) error

func (Storage) Initialize

func (s Storage) Initialize() error

func (Storage) ReadMetric

func (s Storage) ReadMetric(isPush bool, nsId string, mcisId string, vmId string, metric string, period string, function string, duration string) (interface{}, error)

func (Storage) WriteMetric

func (s Storage) WriteMetric(dbName string, metrics map[string]interface{}) error

func (Storage) WriteOnDemandMetric

func (s Storage) WriteOnDemandMetric(dbName string, metricName string, tagArr map[string]string, metricVal map[string]interface{}) error