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
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.influxdb.client.InfluxDBClientgetClient()StringgetName()StringgetOrgId()voidstart()voidstop()
-
-
-
Constructor Detail
-
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 databasetoken- token to use for authenticationorg- org to connect to
-
-
Method Detail
-
getName
public String getName()
- Specified by:
getNamein interfaceio.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>
-
getClient
public com.influxdb.client.InfluxDBClient getClient()
- Specified by:
getClientin interfaceio.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>- Returns:
- the influxdb java client
-
getOrgId
public String getOrgId()
-
start
public void start()
- Specified by:
startin interfaceio.vertigo.core.node.component.Activeable
-
stop
public void stop()
- Specified by:
stopin interfaceio.vertigo.core.node.component.Activeable
-
-