Database.InfluxDB.Manage

Management query interface

data Query

An InfluxDB query.

A spec of the format is available at https://docs.influxdata.com/influxdb/v1.7/query_language/spec/.

A Query can be constructed using either

• the IsString instance with -XOverloadedStrings
• or formatQuery.

>>> :set -XOverloadedStrings
>>> "SELECT * FROM series" :: Query
"SELECT * FROM series"
>>> import qualified Database.InfluxDB.Format as F
>>> formatQuery ("SELECT * FROM "%F.key) "series"
"SELECT * FROM \"series\""

NOTE: Currently this library doesn't support type-safe query construction.

Instances

IsString Query

Defined in Database.InfluxDB.Types

Methods

fromString :: String -> Query

Show Query

Defined in Database.InfluxDB.Types

Methods

showsPrec :: Int -> Query -> ShowS

show :: Query -> String

showList :: [Query] -> ShowS

manage :: QueryParams -> Query -> IO ()

Send a database management query to InfluxDB.

>>> let db = "manage-test"
>>> let p = queryParams db
>>> manage p $ F.formatQuery ("CREATE DATABASE "%F.database) db

Query parameters

data QueryParams

The full set of parameters for the query API

Following lenses are available to access its fields:

• server
• database
• precision
• manager
• authentication
• decoder

Instances

HasCredentials QueryParams

Authentication info for the query

>>> let p = queryParams "foo"
>>> p ^. authentication
Nothing
>>> let p' = p & authentication ?~ credentials "john" "passw0rd"
>>> p' ^. authentication.traverse.user
"john"

Defined in Database.InfluxDB.Query

Methods

authentication :: Lens' QueryParams (Maybe Credentials)

HasDatabase QueryParams

>>> let p = queryParams "foo"
>>> p ^. database
"foo"

Defined in Database.InfluxDB.Query

Methods

database :: Lens' QueryParams Database

HasManager QueryParams

>>> let p = queryParams "foo" & manager .~ Left HC.defaultManagerSettings

Defined in Database.InfluxDB.Query

Methods

manager :: Lens' QueryParams (Either ManagerSettings Manager)

HasServer QueryParams

>>> let p = queryParams "foo"
>>> p ^. server.host
"localhost"

Defined in Database.InfluxDB.Query

Methods

server :: Lens' QueryParams Server

HasPrecision 'QueryRequest QueryParams

Returning JSON responses contain timestamps in the specified precision/format.

>>> let p = queryParams "foo"
>>> p ^. precision
RFC3339

Defined in Database.InfluxDB.Query

Methods

precision :: Lens' QueryParams (Precision 'QueryRequest)

queryParams :: Database -> QueryParams

Smart constructor for QueryParams

Default parameters:

server

defaultServer

precision

RFC3339

authentication

Nothing

manager

Left defaultManagerSettings

decoder

strictDecoder

server :: HasServer a => Lens' a Server

InfluxDB server address and port that to interact with.

database :: HasDatabase a => Lens' a Database

Database name to work on.

precision :: HasPrecision ty a => Lens' a (Precision ty)

Time precision parameter.

manager :: HasManager a => Lens' a (Either ManagerSettings Manager)

HTTP manager settings or a manager itself.

If it's set to ManagerSettings, the library will create a Manager from the settings for you.

Management query results

SHOW QUERIES

data ShowQuery

>>> v <- query @ShowQuery (queryParams "_internal") "SHOW QUERIES"

Instances

QueryResults ShowQuery

Defined in Database.InfluxDB.Manage

Methods

parseMeasurement :: Precision 'QueryRequest -> Maybe Text -> HashMap Text Text -> Vector Text -> Array -> Parser ShowQuery

coerceDecoder :: proxy ShowQuery -> Maybe Decoder

HasDatabase ShowQuery

>>> v <- query @ShowQuery (queryParams "_internal") "SHOW QUERIES"
>>> v ^.. each.database
...

Defined in Database.InfluxDB.Manage

Methods

database :: Lens' ShowQuery Database

qid :: Lens' ShowQuery Int

Query ID

>>> v <- query @ShowQuery (queryParams "_internal") "SHOW QUERIES"
>>> v ^.. each.qid
...

queryText :: Lens' ShowQuery Query

Query text

>>> v <- query @ShowQuery (queryParams "_internal") "SHOW QUERIES"
>>> v ^.. each.queryText
...

duration :: Lens' ShowQuery NominalDiffTime

Duration of the query

>>> v <- query @ShowQuery (queryParams "_internal") "SHOW QUERIES"
>>> v ^.. each.duration
...

SHOW SERIES

data ShowSeries

Instances

QueryResults ShowSeries

Defined in Database.InfluxDB.Manage

Methods

parseMeasurement :: Precision 'QueryRequest -> Maybe Text -> HashMap Text Text -> Vector Text -> Array -> Parser ShowSeries

coerceDecoder :: proxy ShowSeries -> Maybe Decoder

key :: Lens' ShowSeries Key

Series name

>>> v <- query @ShowSeries (queryParams "_internal") "SHOW SERIES"
>>> length $ v ^.. each.key
...