influx

Documentation

Index

• func WorkerGenerator(jobs chan collector.Printable, connection, dumpFile, version string, ...) func(workerId int) *Worker
• type Connector
  • func ConnectorFactory(jobs chan collector.Printable, ...) *Connector
  • func (connector *Connector) AddWorker()
  • func (connector Connector) AmountWorkers() int
  • func (connector *Connector) CreateDatabase(loginData string) bool
  • func (connector Connector) DatabaseExists() bool
  • func (connector Connector) IsAlive() bool
  • func (connector *Connector) RemoveWorker()
  • func (connector *Connector) Stop()
  • func (connector *Connector) TestDatabaseExists() bool
  • func (connector *Connector) TestIfIsAlive(stopReadingDataIfDown bool) bool
• type ResultsStruct
• type SeriesStruct
• type SeriesValue
• type ShowSeriesResult
• type Worker
  • func (worker *Worker) Stop()

Functions

func WorkerGenerator

func WorkerGenerator(jobs chan collector.Printable, connection, dumpFile, version string,
	connector *Connector, target data.Target, stopReadingDataIfDown bool) func(workerId int) *Worker

WorkerGenerator generates a new Worker and starts it.

Types

type Connector

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

Connector makes the basic connection to an Influxdb.

func ConnectorFactory

func ConnectorFactory(jobs chan collector.Printable, connectionHost, connectionArgs, dumpFile, version string,
	workerAmount, maxWorkers int, createDatabaseIfNotExists, stopReadingDataIfDown bool, target data.Target, clientTimeout int) *Connector

ConnectorFactory Constructor which will create some workers if the connection is established.

func (*Connector) AddWorker

func (connector *Connector) AddWorker()

AddWorker creates a new worker

func (Connector) AmountWorkers

func (connector Connector) AmountWorkers() int

AmountWorkers current amount of workers.

func (*Connector) CreateDatabase

func (connector *Connector) CreateDatabase(loginData string) bool

CreateDatabase creates the database.

func (Connector) DatabaseExists

func (connector Connector) DatabaseExists() bool

DatabaseExists does the database exist.

func (Connector) IsAlive

func (connector Connector) IsAlive() bool

IsAlive is the database system alive.

func (*Connector) RemoveWorker

func (connector *Connector) RemoveWorker()

RemoveWorker stops a worker

func (*Connector) Stop

func (connector *Connector) Stop()

Stop the connector and its workers.

func (*Connector) TestDatabaseExists

func (connector *Connector) TestDatabaseExists() bool

TestDatabaseExists test active if the database exists.

func (*Connector) TestIfIsAlive

func (connector *Connector) TestIfIsAlive(stopReadingDataIfDown bool) bool

TestIfIsAlive test active if the database system is alive.

type ResultsStruct

type ResultsStruct []struct {
	Series SeriesStruct
}

ResultsStruct is a list of series

type SeriesStruct

type SeriesStruct []struct {
	Columns []string
	Name    string
	Values  []SeriesValue
}

SeriesStruct is a list of field values

type SeriesValue

type SeriesValue []interface{}

SeriesValue is list of values for a certain timestamp

type ShowSeriesResult

type ShowSeriesResult struct {
	Results ResultsStruct
}

ShowSeriesResult represents the JSON query result

type Worker

type Worker struct {
	IsRunning bool
	// contains filtered or unexported fields
}

Worker reads data from the queue and sends them to the influxdb.

func (*Worker) Stop

func (worker *Worker) Stop()

Stop stops the worker