schemamgt

Documentation

Index

• Variables
• func DefaultSchemasInit()
• func NewMeasurement(entity interface{}) *schemas.Measurement
• func NewSchema(entity interface{}) *schemas.Schema
• func NewSchemaMeta(entity interface{}) *schemas.SchemaMeta
• func SchemaInit(config *influxdb.Config) error
• type SchemaManagement
  • func NewSchemaManagement() *SchemaManagement
  • func (p *SchemaManagement) AddSchemas(schemas []*InfluxSchemas.Schema)
  • func (p *SchemaManagement) DeleteSchemas(table InfluxSchemas.Scope, category, schemaType string) error
  • func (p *SchemaManagement) Flush() error
  • func (p *SchemaManagement) GetSchema(schemaScope InfluxSchemas.Scope, schemaCategory, schemaType string) *InfluxSchemas.Schema
  • func (p *SchemaManagement) GetSchemas(scope InfluxSchemas.Scope, category, schemaType string) []*InfluxSchemas.Schema
  • func (p *SchemaManagement) Refresh() error
• type SchemaMap
  • func NewSchemaMap() *SchemaMap
  • func (p *SchemaMap) AddSchema(schema *schemas.Schema)
  • func (p *SchemaMap) Empty()

Variables

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

var DefaultSchemas = map[string][]interface{}{
	"application":    defaults.DefaultSchemaApplication(),
	"config":         defaults.DefaultSchemaConfig(),
	"fedemeter":      defaults.DefaultSchemaFedemeter(),
	"metering":       defaults.DefaultSchemaMetering(),
	"metric":         defaults.DefaultSchemaMetric(),
	"planning":       defaults.DefaultSchemaPlanning(),
	"prediction":     defaults.DefaultSchemaPrediction(),
	"recommendation": defaults.DefaultSchemaRecommendation(),
	"resource":       defaults.DefaultSchemaResource(),
	"target":         defaults.DefaultSchemaTarget(),
}

Functions

func DefaultSchemasInit

func DefaultSchemasInit()

func NewMeasurement

func NewMeasurement(entity interface{}) *schemas.Measurement

func NewSchema

func NewSchema(entity interface{}) *schemas.Schema

func NewSchemaMeta

func NewSchemaMeta(entity interface{}) *schemas.SchemaMeta

func SchemaInit

func SchemaInit(config *influxdb.Config) error

Types

type SchemaManagement

type SchemaManagement struct {
}

func NewSchemaManagement

func NewSchemaManagement() *SchemaManagement

func (*SchemaManagement) AddSchemas

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

func (*SchemaManagement) DeleteSchemas

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

func (*SchemaManagement) Flush

func (p *SchemaManagement) Flush() error

func (*SchemaManagement) GetSchema

func (p *SchemaManagement) GetSchema(schemaScope InfluxSchemas.Scope, schemaCategory, schemaType string) *InfluxSchemas.Schema

func (*SchemaManagement) GetSchemas

func (p *SchemaManagement) GetSchemas(scope InfluxSchemas.Scope, category, schemaType string) []*InfluxSchemas.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()