node

Documentation

Index

• Constants
• Variables
• type Entity
  • func NewEntityFromMap(data map[string]string) Entity
  • func (e Entity) NodePrediction() prediction.NodePrediction
• type Field
• type MetricType
• type Tag

Constants

const (
	Time        Tag = "time"
	Name        Tag = "name"
	Metric      Tag = "metric"
	IsScheduled Tag = "is_scheduled"
	Granularity Tag = "granularity"
	Kind        Tag = "kind"

	Value Field = "value"
)

Variables

var (
	// Tags Tags' name in influxdb
	Tags = []Tag{Name, Metric, IsScheduled, Granularity, Kind}
	// Fields Fields' name in influxdb
	Fields = []Field{Value}
	// MetricTypeCPUUsage Enum of tag "metric"
	MetricTypeCPUUsage MetricType = "cpu_usage_seconds_percentage"
	// MetricTypeMemoryUsage Enum of tag "metric"
	MetricTypeMemoryUsage MetricType = "memory_usage_bytes"

	// LocalMetricTypeToPkgMetricType Convert local package metric type to package alameda.datahub.metric.NodeMetricType
	LocalMetricTypeToPkgMetricType = map[MetricType]metric.NodeMetricType{
		MetricTypeCPUUsage:    metric.TypeNodeCPUUsageSecondsPercentage,
		MetricTypeMemoryUsage: metric.TypeNodeMemoryUsageBytes,
	}

	// PkgMetricTypeToLocalMetricType Convert package alameda.datahub.metric.NodeMetricType to local package metric type
	PkgMetricTypeToLocalMetricType = map[metric.NodeMetricType]MetricType{
		metric.TypeNodeCPUUsageSecondsPercentage: MetricTypeCPUUsage,
		metric.TypeNodeMemoryUsageBytes:          MetricTypeMemoryUsage,
	}
)

Types

type Entity

type Entity struct {
	Timestamp time.Time

	Name        *string
	Metric      *MetricType
	Value       *string
	IsScheduled *string
}

Entity Container prediction entity in influxDB

func NewEntityFromMap

func NewEntityFromMap(data map[string]string) Entity

NewEntityFromMap Build entity from map

func (Entity) NodePrediction

func (e Entity) NodePrediction() prediction.NodePrediction

NodePrediction Create container prediction base on entity

type Field

type Field = string

type MetricType

type MetricType = string

type Tag

type Tag = string