discovery

Documentation

Index

• type FieldExplorer
  • func NewFieldExplorer(queryService influxqueries.InfluxQueryService) FieldExplorer
• type MeasureExplorer
  • func NewMeasureExplorer(queryService influxqueries.InfluxQueryService, fieldExplorer FieldExplorer) MeasureExplorer
• type TagExplorer
  • func NewTagExplorer(queryService influxqueries.InfluxQueryService) TagExplorer

Types

type FieldExplorer

type FieldExplorer interface {
	// DiscoverMeasurementFields creates the ColumnInfo for the Fields of a given measurement
	DiscoverMeasurementFields(influxClient influx.Client, db, rp, measurement string, onConflictConvertIntToFloat bool) ([]*idrf.Column, error)
}

FieldExplorer defines an API for discovering InfluxDB fields of a specified measurement

func NewFieldExplorer

func NewFieldExplorer(queryService influxqueries.InfluxQueryService) FieldExplorer

NewFieldExplorer creates a new instance of the Field discovert API

type MeasureExplorer

type MeasureExplorer interface {
	FetchAvailableMeasurements(influxClient influx.Client, db, rp string, onConflictConvertIntToFloat bool) ([]string, error)
}

MeasureExplorer defines an API for discovering the available measures in an InfluxDB database

func NewMeasureExplorer

func NewMeasureExplorer(queryService influxqueries.InfluxQueryService, fieldExplorer FieldExplorer) MeasureExplorer

NewMeasureExplorer creates a new implementation of the MeasureExplorer API

type TagExplorer

type TagExplorer interface {
	DiscoverMeasurementTags(influxClient influx.Client, database, rp, measure string) ([]*idrf.Column, error)
}

TagExplorer Defines an API for discovering the tags of an InfluxDB measurement

func NewTagExplorer

func NewTagExplorer(queryService influxqueries.InfluxQueryService) TagExplorer

NewTagExplorer creates a new implementation of that can discover the tags of an influx measurement