influx

Documentation

Index

• type DataProducer
  • func NewDataProducer(id string, influxClient influx.Client) DataProducer
• type Extractor
  • func (e *Extractor) ID() string
  • func (e *Extractor) Prepare() (*idrf.Bundle, error)
  • func (e *Extractor) Start(errChan chan error) error

Types

type DataProducer

type DataProducer interface {
	Fetch(*producerArgs) error
}

DataProducer populates a data channel with the results from an influx query

func NewDataProducer

func NewDataProducer(id string, influxClient influx.Client) DataProducer

NewDataProducer craetes a new DataProducer

type Extractor

type Extractor struct {
	Config *config.ExtractionConfig
	SM     schemamanagement.SchemaManager

	DataProducer DataProducer
	// contains filtered or unexported fields
}

Extractor is an implementation of the extraction.Extractor interface for pulling data out of InfluxDB

func (*Extractor) ID

func (e *Extractor) ID() string

ID of the extractor, useful for logging and error reporting

func (*Extractor) Prepare

func (e *Extractor) Prepare() (*idrf.Bundle, error)

Prepare discovers the data set schema for the measure in the config

func (*Extractor) Start

func (e *Extractor) Start(errChan chan error) error

Start pulls the data from an InfluxDB measure and feeds it to a data channel Peridicly (between chunks) checks for external errors and quits if it detects them