elasticsearch

Documentation

Index

• func WorkerGenerator(jobs chan collector.Printable, connection, index, dumpFile string, ...) func(workerId int) *Worker
• type Connector
  • func ConnectorFactory(jobs chan collector.Printable, connectionHost, index, dumpFile string, ...) *Connector
  • func (connector *Connector) AddWorker()
  • func (connector Connector) AmountWorkers() int
  • func (connector *Connector) CreateDatabase() 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() bool
• type Worker
  • func (worker *Worker) Stop()

Functions

func WorkerGenerator

func WorkerGenerator(jobs chan collector.Printable, connection, index, dumpFile string, version float32, connector *Connector) 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, index, dumpFile string, workerAmount, maxWorkers int, version float32, createDatabaseIfNotExists bool) *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() 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() bool

TestIfIsAlive test active if the database system is alive.

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