Package com.barden.library.database.influx

Class InfluxProvider

java.lang.Object
com.barden.library.database.influx.InfluxProvider
public final class InfluxProvider extends Object
Influx provider class.

  • Constructor Details

    • InfluxProvider

      public InfluxProvider(@Nonnull String host, int port, @Nonnull String token, @Nonnull String organization, @Nonnull String bucket)
      Create influx connection and provider class with sync-driver.
      Parameters:
      host - Host or IP address of InfluxDB server.
      port - Port address of InfluxDB server.
      token - Token.
      organization - Organization.
      bucket - Bucket.

  • Method Details

    • isInitialized

      public boolean isInitialized()
      Gets if InfluxDB initialized or not.
      Returns:
      If InfluxDB initialized or not.

    • getHost

      @Nonnull public String getHost()
      Gets host.
      Returns:
      Host.

    • getPort

      public int getPort()
      Gets port.
      Returns:
      Port.

    • getToken

      @Nonnull public String getToken()
      Gets token.
      Returns:
      Token.

    • getOrganization

      @Nonnull public String getOrganization()
      Gets organization.
      Returns:
      Organization.

    • getOrganizationId

      @Nonnull public String getOrganizationId()
      Gets organization id.
      Returns:
      Organization id.

    • getBucket

      @Nonnull public String getBucket()
      Gets bucket.
      Returns:
      Bucket.

    • getClient

      @Nonnull public com.influxdb.client.InfluxDBClient getClient()
      Gets connected client.
      Returns:
      InfluxDB Client.

    • getWriteAPI

      @Nonnull public com.influxdb.client.WriteApi getWriteAPI()
      Gets write api.
      Returns:
      Write API.

    • getWriteAPIBlocking

      @Nonnull public com.influxdb.client.WriteApiBlocking getWriteAPIBlocking()
      Gets write api blocking. Create a new synchronous blocking Write client.
      Returns:
      Write API Blocking.

    • findBucketByName

      @Nonnull public Optional<com.influxdb.client.domain.Bucket> findBucketByName(@Nonnull String name)
      Finds bucket by its name.
      Parameters:
      name - Bucket name.
      Returns:
      Optional bucket.

    • getBucketByName

      @Nonnull public com.influxdb.client.domain.Bucket getBucketByName(@Nonnull String name)
      Gets bucket by its name.
      Parameters:
      name - Bucket name.
      Returns:
      Bucket.

    • findOrganizationByName

      @Nonnull public Optional<com.influxdb.client.domain.Organization> findOrganizationByName(@Nonnull String name)
      Finds organization by its name.
      Parameters:
      name - Organization name.
      Returns:
      Optional organization.

    • getOrganizationByName

      @Nonnull public com.influxdb.client.domain.Organization getOrganizationByName(@Nonnull String name)
      Gets organization by its name.
      Parameters:
      name - Organization name.
      Returns:
      Organization.

    • findTaskByName

      @Nonnull public Optional<com.influxdb.client.domain.Task> findTaskByName(@Nonnull String name)
      Finds task by its name.
      Parameters:
      name - Task name.
      Returns:
      Optional task.

    • getTaskByName

      @Nonnull public com.influxdb.client.domain.Task getTaskByName(@Nonnull String name)
      Gets task by its name.
      Parameters:
      name - Task name.
      Returns:
      Task.