influx

Documentation

Index

• type SchemaManager
  • func NewSchemaManager(client influx.Client, db, rp string, onConflictConvertIntToFloat bool, ...) *SchemaManager
  • func (sm *SchemaManager) DiscoverDataSets() ([]string, error)
  • func (sm *SchemaManager) FetchDataSet(dataSetIdentifier string) (*idrf.DataSet, error)
  • func (sm *SchemaManager) PrepareDataSet(dataSet *idrf.DataSet, strategy schemaconfig.SchemaStrategy) error

Types

type SchemaManager

type SchemaManager struct {
	// contains filtered or unexported fields
}

SchemaManager implements the schemamanagement.SchemaManager interface

func NewSchemaManager

func NewSchemaManager(
	client influx.Client,
	db, rp string,
	onConflictConvertIntToFloat bool,
	me discovery.MeasureExplorer,
	tagExplorer discovery.TagExplorer,
	fieldExplorer discovery.FieldExplorer) *SchemaManager

NewSchemaManager creates new schema manager that can discover influx data sets

func (*SchemaManager) DiscoverDataSets

func (sm *SchemaManager) DiscoverDataSets() ([]string, error)

DiscoverDataSets returns a list of the available measurements in the connected

func (*SchemaManager) FetchDataSet

func (sm *SchemaManager) FetchDataSet(dataSetIdentifier string) (*idrf.DataSet, error)

FetchDataSet for a given data set identifier (retention.measureName, or just measureName) returns the idrf.DataSet describing it

func (*SchemaManager) PrepareDataSet

func (sm *SchemaManager) PrepareDataSet(dataSet *idrf.DataSet, strategy schemaconfig.SchemaStrategy) error

PrepareDataSet NOT IMPLEMENTED