Class 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
    • 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 database
        token - token to use for authentication
        org - org to connect to
    • Method Detail

      • 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