influx

package

v0.4.1 Latest Latest Go to latest Published: Jun 7, 2017 License: GPL-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Griesbacher/nagflux

Links

Open Source Insights

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
type ResultsStruct
type SeriesStruct
type SeriesValue
type ShowSeriesResult
type Worker
- func (worker *Worker) Stop()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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) *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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL