schema_mgt

Documentation

Index

• Constants
• Variables
• func DeepCopy(dst interface{}, src interface{}) error
• func DefaultSchemasInit()
• func SchemaInit(config *config.Config) error
• type SchemaManagement
  • func NewSchemaManagement() *SchemaManagement
  • func (p *SchemaManagement) AddSchemas(schemas []*Schema.Schema)
  • func (p *SchemaManagement) DeleteSchemas(table Schema.Scope, category, schemaType string) error
  • func (p *SchemaManagement) Flush() error
  • func (p *SchemaManagement) GetSchemas(scope Schema.Scope, category, schemaType string) []*Schema.Schema
  • func (p *SchemaManagement) Refresh() error
• type SchemaMap
  • func NewSchemaMap() *SchemaMap
  • func (p *SchemaMap) AddSchema(schema *schemas.Schema)
  • func (p *SchemaMap) Empty()

Constants

const (
	ScopeUndefined Schema.Scope = iota
	Application
	Metric
	Planning
	Prediction
	Recommendation
	Resource
)

Table enumerator

const (
	MetricTypeUndefined Schema.MetricType = iota
	CPUUsageSecondsPercentage
	MemoryUsageBytes
	PowerUsageWatts
	TemperatureCelsius
	DutyCycle
	CurrentOffset
	Lag
)

Metric type enumerator

const (
	ResourceBoundaryUndefined Schema.ResourceBoundary = iota
	ResourceRaw
	ResourceUpperBound
	ResourceLowerBound
)

Resource boundary enumerator

const (
	ResourceQuotaUndefined Schema.ResourceQuota = iota
	ResourceLimit
	ResourceRequest
	ResourceInitialLimit
	ResourceInitialRequest
)

Resource quota enumerator

Variables

var (
	InfluxConfig  *InternalInflux.Config
	RWLock        *sync.RWMutex
	Schemas       *SchemaMap
	Schemas2Write *SchemaMap
)

var DatabaseNameMap = map[Schema.Scope]string{
	Application:    "alameda_application",
	Metric:         "alameda_metric",
	Planning:       "alameda_planning",
	Prediction:     "alameda_prediction",
	Recommendation: "alameda_recommendation",
	Resource:       "alameda_resource",
}

var MeasurementNameMap = map[Schema.Scope]string{
	Application:    "application",
	Metric:         "metric",
	Planning:       "planning",
	Prediction:     "prediction",
	Recommendation: "recommendation",
	Resource:       "resource",
}

var MeasurementSchemaNameMap = map[Schema.Scope]string{
	Application:    "application_schema",
	Metric:         "metric_schema",
	Planning:       "planning_schema",
	Prediction:     "prediction_schema",
	Recommendation: "recommendation_schema",
	Resource:       "resource_schema",
}

Functions

func DeepCopy

func DeepCopy(dst interface{}, src interface{}) error

func DefaultSchemasInit

func DefaultSchemasInit()

func SchemaInit

func SchemaInit(config *config.Config) error

Types

type SchemaManagement

type SchemaManagement struct {
}

func NewSchemaManagement

func NewSchemaManagement() *SchemaManagement

func (*SchemaManagement) AddSchemas

func (p *SchemaManagement) AddSchemas(schemas []*Schema.Schema)

func (*SchemaManagement) DeleteSchemas

func (p *SchemaManagement) DeleteSchemas(table Schema.Scope, category, schemaType string) error

func (*SchemaManagement) Flush

func (p *SchemaManagement) Flush() error

func (*SchemaManagement) GetSchemas

func (p *SchemaManagement) GetSchemas(scope Schema.Scope, category, schemaType string) []*Schema.Schema

func (*SchemaManagement) Refresh

func (p *SchemaManagement) Refresh() error

type SchemaMap

type SchemaMap struct {
	Schemas map[schemas.Scope][]*schemas.Schema
}

func NewSchemaMap

func NewSchemaMap() *SchemaMap

func (*SchemaMap) AddSchema

func (p *SchemaMap) AddSchema(schema *schemas.Schema)

func (*SchemaMap) Empty

func (p *SchemaMap) Empty()