schemas

Documentation

Index

• type Column
  • func NewColumn() *Column
  • func (p *Column) Parse(column string) error
  • func (p *Column) String() string
• type ColumnType
• type Measurement
  • func NewMeasurement(name string, metricType MetricType, boundary ResourceBoundary, ...) *Measurement
  • func (p *Measurement) AddColumn(name string, required bool, columnType ColumnType, dataType common.DataType)
  • func (p *Measurement) Initialize(columns string) error
  • func (p *Measurement) String() string
  • func (p *Measurement) Validate(columns []string) error
• type MetricType
• type ResourceBoundary
• type ResourceQuota
• type Schema
  • func NewSchema(scope Scope, category, schemaType string) *Schema
  • func (p *Schema) AddMeasurement(name string, metricType MetricType, boundary ResourceBoundary, ...) error
  • func (p *Schema) GetMeasurement(name string, metricType MetricType, boundary ResourceBoundary, ...) *Measurement
  • func (p *Schema) String() string
  • func (p *Schema) Validate() error
• type SchemaMeta
  • func NewSchemaMeta(scope Scope, category, schemaType string) *SchemaMeta
• type Scope

Types

type Column

type Column struct {
	Name       string
	Required   bool
	ColumnType ColumnType
	DataType   common.DataType
}

func NewColumn

func NewColumn() *Column

func (*Column) Parse

func (p *Column) Parse(column string) error

func (*Column) String

func (p *Column) String() string

type ColumnType

type ColumnType int

const (
	ColumnTypeUndefined ColumnType = iota
	Tag
	Field
)

Influxdb column type enumerator

type Measurement

type Measurement struct {
	Name       string
	MetricType MetricType
	Boundary   ResourceBoundary
	Quota      ResourceQuota
	Columns    []*Column
}

func NewMeasurement

func NewMeasurement(name string, metricType MetricType, boundary ResourceBoundary, quota ResourceQuota) *Measurement

func (*Measurement) AddColumn

func (p *Measurement) AddColumn(name string, required bool, columnType ColumnType, dataType common.DataType)

func (*Measurement) Initialize

func (p *Measurement) Initialize(columns string) error

func (*Measurement) String

func (p *Measurement) String() string

func (*Measurement) Validate

func (p *Measurement) Validate(columns []string) error

type MetricType

type MetricType int

type ResourceBoundary

type ResourceBoundary int

type ResourceQuota

type ResourceQuota int

type Schema

type Schema struct {
	SchemaMeta   *SchemaMeta
	Measurements []*Measurement
}

func NewSchema

func NewSchema(scope Scope, category, schemaType string) *Schema

func (*Schema) AddMeasurement

func (p *Schema) AddMeasurement(name string, metricType MetricType, boundary ResourceBoundary, quota ResourceQuota, columns string) error

func (*Schema) GetMeasurement

func (p *Schema) GetMeasurement(name string, metricType MetricType, boundary ResourceBoundary, quota ResourceQuota) *Measurement

func (*Schema) String

func (p *Schema) String() string

func (*Schema) Validate

func (p *Schema) Validate() error

type SchemaMeta

type SchemaMeta struct {
	Scope    Scope
	Category string
	Type     string
}

func NewSchemaMeta

func NewSchemaMeta(scope Scope, category, schemaType string) *SchemaMeta

type Scope

type Scope int