Package io.vertigo.connectors.influxdb

Class InfluxDbConnector

java.lang.Object

io.vertigo.connectors.influxdb.InfluxDbConnector

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>, io.vertigo.core.node.component.CoreComponent

public class InfluxDbConnector
extends Object
implements io.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>, io.vertigo.core.node.component.Activeable

An InfluxDb connector to the time series database.

Author:

mlaroche

Field Summary

Fields inherited from interface io.vertigo.core.node.component.Connector

DEFAULT_CONNECTOR_NAME

Constructor Summary

Constructors

Constructor	Description
InfluxDbConnector(Optional<String> connectorNameOpt, String host, String token, String org)	Constructor of an InfluxDb connector to the time series database

Method Summary

Modifier and Type	Method	Description
com.influxdb.client.InfluxDBClient	getClient()
String	getName()
String	getOrgId()
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InfluxDbConnector

@Inject
public InfluxDbConnector(Optional<String> connectorNameOpt,
 String host,
 String token,
 String org)

Constructor of an InfluxDb connector to the time series database

Parameters:

connectorNameOpt -

host - Host of the influxdb database

token - token to use for authentication

org - org to connect to

Method Details

getName

public String getName()

Specified by:

getName in interface io.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>

getClient

public com.influxdb.client.InfluxDBClient getClient()

Specified by:

getClient in interface io.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>

Returns:

the influxdb java client

getOrgId

public String getOrgId()

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable