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.InfluxDBClient
getClient()
String
getName()
String
getOrgId()
void
start()
void
stop()
-
-
-
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:
getName
in interfaceio.vertigo.core.node.component.Connector<com.influxdb.client.InfluxDBClient>
-
getClient
public com.influxdb.client.InfluxDBClient getClient()
- Specified by:
getClient
in 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:
start
in interfaceio.vertigo.core.node.component.Activeable
-
stop
public void stop()
- Specified by:
stop
in interfaceio.vertigo.core.node.component.Activeable
-
-