Database.InfluxDB.Query

Query interface

data Query

Instances

Show Query

Methods

showsPrec :: Int -> Query -> ShowS

show :: Query -> String

showList :: [Query] -> ShowS

IsString Query

Methods

fromString :: String -> Query

query :: QueryResults a => QueryParams -> Query -> IO (Vector a)

Query data from InfluxDB.

It may throw InfluxException.

queryChunked

Arguments

:: QueryResults a

=> QueryParams

-> Optional Int

Chunk size

By Default, InfluxDB chunks responses by series or by every 10,000 points, whichever occurs first. If it set to a Specific value, InfluxDB chunks responses by series or by that number of points.

-> Query

-> FoldM IO (Vector a) r

-> IO r

Same as query but it instructs InfluxDB to stream chunked responses rather than returning a huge JSON object. This can be lot more efficient than query if the result is huge.

It may throw InfluxException.

Query parameters

data QueryParams

The full set of parameters for the query API

Instances

HasCredentials QueryParams

Methods

authentication :: Lens' QueryParams (Maybe Credentials)

HasManager QueryParams

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

Methods

manager :: Lens' QueryParams (Either ManagerSettings Manager)

HasDatabase QueryParams

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

Methods

database :: Lens' QueryParams Database

HasServer QueryParams

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

Methods

server :: Lens' QueryParams Server

HasPrecision QueryRequest QueryParams

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

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

Methods

precision :: Lens' QueryParams (Precision QueryRequest)

queryParams :: Database -> QueryParams

Smart constructor for QueryParams

Default parameters:

server

localServer

precision

RFC3339

authentication

Nothing

manager

Left defaultManagerSettings

server :: HasServer a => Lens' a Server

database :: HasDatabase a => Lens' a Database

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

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.

Parsing results

class QueryResults a where

Minimal complete definition

parseResults

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector a)

Instances

QueryResults Void

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector Void)

QueryResults ShowSeries

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector ShowSeries)

QueryResults ShowQuery

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector ShowQuery)

((~) * a Value, (~) * b Value) => QueryResults (a, b)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b))

((~) * a Value, (~) * b Value, (~) * c Value) => QueryResults (a, b, c)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b, c))

((~) * a Value, (~) * b Value, (~) * c Value, (~) * d Value) => QueryResults (a, b, c, d)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b, c, d))

((~) * a Value, (~) * b Value, (~) * c Value, (~) * d Value, (~) * e Value) => QueryResults (a, b, c, d, e)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b, c, d, e))

((~) * a Value, (~) * b Value, (~) * c Value, (~) * d Value, (~) * e Value, (~) * f Value) => QueryResults (a, b, c, d, e, f)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b, c, d, e, f))

((~) * a Value, (~) * b Value, (~) * c Value, (~) * d Value, (~) * e Value, (~) * f Value, (~) * g Value) => QueryResults (a, b, c, d, e, f, g)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b, c, d, e, f, g))

((~) * a Value, (~) * b Value, (~) * c Value, (~) * d Value, (~) * e Value, (~) * f Value, (~) * g Value, (~) * h Value) => QueryResults (a, b, c, d, e, f, g, h)

Methods

parseResults :: Precision QueryRequest -> Value -> Parser (Vector (a, b, c, d, e, f, g, h))

parseResultsWith

Arguments

:: (Maybe Text -> HashMap Text Text -> Vector Text -> Array -> Parser a)

A parser that takes

1. an optional name of the series
2. a map of tags
3. an array of field names
4. an array of values

to construct a value.

-> Value

-> Parser (Vector a)

Parse a JSON response

parseKey :: Key -> Vector Text -> Array -> Parser Key

Low-level functions

withQueryResponse

Arguments

:: QueryParams

-> Maybe (Optional Int)

Chunk size

By Nothing, InfluxDB returns all matching data points at once. By Just Default, InfluxDB chunks responses by series or by every 10,000 points, whichever occurs first. If it set to a Specific value, InfluxDB chunks responses by series or by that number of points.

-> Query

-> (Request -> Response BodyReader -> IO r)

-> IO r