influx_fedemeter

Documentation

Index

• Variables
• type CostMeasurementType
• type EnumMeasurementID
• type InfluxField
• type InfluxMeasurement
  • func NewInfluxMeasurement(databaseName string, measurementID EnumMeasurementID, tags []string, ...) *InfluxMeasurement
  • func (n *InfluxMeasurement) GetWriteRequest(starttime *timestamp.Timestamp) (*dpRawData.WriteRawdataRequest, error)

Variables

var EnumMeasurementName = map[EnumMeasurementID]string{
	0: "calculate_instance",
	1: "calculate_storage",
	2: "recommendation_jeri",
	3: "prediction_cost_namespace",
	4: "prediction_cost_app",
	5: "history_cost_namespace",
	6: "history_cost_app",
	7: "cost_namespace",
	8: "cost_app"}

var MeasurementColumns map[EnumMeasurementID][]string

Types

type CostMeasurementType

type CostMeasurementType int

const (
	CostMeasurementHistory   CostMeasurementType = 0
	CostMeasureemntPredicted CostMeasurementType = 1
)

type EnumMeasurementID

type EnumMeasurementID int32

type InfluxField

type InfluxField struct {
	Name    string
	Type    common.DataType
	Default interface{}
}

type InfluxMeasurement

type InfluxMeasurement struct {
	DatabaseName      string
	MeasurementID     EnumMeasurementID
	TagKeys           []string
	FieldKeys         []*InfluxField
	SourceData        interface{}
	Granularity       int64
	ReservedInstances bool
	Arithmetic        string
	Country           string
	Type              CostMeasurementType
}

func NewInfluxMeasurement

func NewInfluxMeasurement(databaseName string, measurementID EnumMeasurementID, tags []string, fields []*InfluxField, sourceData interface{}, granularity int64, revservedinstances bool) *InfluxMeasurement

func (*InfluxMeasurement) GetWriteRequest

func (n *InfluxMeasurement) GetWriteRequest(starttime *timestamp.Timestamp) (*dpRawData.WriteRawdataRequest, error)