| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Database.InfluxDB.Line
- data Line time = Line !Measurement !(Map Key Key) !(Map Key LineField) !(Maybe time)
- measurement :: Lens' (Line time) Measurement
- tagSet :: Lens' (Line time) (Map Key Key)
- fieldSet :: Lens' (Line time) (Map Key LineField)
- timestamp :: Lens' (Line time) (Maybe time)
- buildLine :: (time -> Int64) -> Line time -> Builder
- buildLines :: Foldable f => (time -> Int64) -> f (Line time) -> Builder
- encodeLine :: (time -> Int64) -> Line time -> ByteString
- encodeLines :: Foldable f => (time -> Int64) -> f (Line time) -> ByteString
- type LineField = Field NonNullable
- data Field (n :: Nullability) where
- data Precision (ty :: RequestType) where
- Nanosecond :: Precision ty
- Microsecond :: Precision ty
- Millisecond :: Precision ty
- Second :: Precision ty
- Minute :: Precision ty
- Hour :: Precision ty
- RFC3339 :: Precision QueryRequest
Documentation
The Line protocol implementation.
>>>:set -XOverloadedStrings>>>import Database.InfluxDB>>>import Data.Time>>>import qualified Data.ByteString.Lazy.Char8 as BL8>>>import System.IO (stdout)>>>:{let l1 = Line "cpu_usage" (Map.singleton "cpu" "cpu-total") (Map.fromList [ ("idle", FieldFloat 10.1) , ("system", FieldFloat 53.3) , ("user", FieldFloat 46.6) ]) (Just $ parseTimeOrError False defaultTimeLocale "%F %T%Q %Z" "2017-06-17 15:41:40.42659044 UTC") :: Line UTCTime :}
Types and accessors
Placeholder for the Line Protocol
See https://docs.influxdata.com/influxdb/v1.5/write_protocols/line_protocol_tutorial/ for the concrete syntax.
measurement :: Lens' (Line time) Measurement Source #
Name of the measurement that you want to write your data to.
tagSet :: Lens' (Line time) (Map Key Key) Source #
Tag(s) that you want to include with your data point. Tags are optional in
the Line Protocol, so you can set it empty.
fieldSet :: Lens' (Line time) (Map Key LineField) Source #
Field(s) for your data point. Every data point requires at least one field
in the Line Protocol, so it shouldn't be empty.
timestamp :: Lens' (Line time) (Maybe time) Source #
Timestamp for your data point. You can put whatever type of timestamp that
is an instance of the Timestamp class.
Serializers
Arguments
| :: (time -> Int64) | Function to convert time to an InfluxDB timestamp |
| -> Line time | |
| -> ByteString |
Serialize a Line to a lazy bytestring
>>>BL8.putStrLn $ encodeLine (scaleTo Second) l1cpu_usage,cpu=cpu-total idle=10.1,system=53.3,user=46.6 1497714100
Arguments
| :: Foldable f | |
| => (time -> Int64) | Function to convert time to an InfluxDB timestamp |
| -> f (Line time) | |
| -> ByteString |
Serialize Lines to a lazy bytestring
>>>BL8.putStr $ encodeLines (scaleTo Second) [l1, l1]cpu_usage,cpu=cpu-total idle=10.1,system=53.3,user=46.6 1497714100 cpu_usage,cpu=cpu-total idle=10.1,system=53.3,user=46.6 1497714100
Other types
type LineField = Field NonNullable Source #
Field type for the line protocol. The line protocol doesn't accept null values.
data Field (n :: Nullability) where Source #
data Precision (ty :: RequestType) where Source #
Predefined set of time precision.
RFC3339 is only available for QueryRequests.
Constructors
| Nanosecond :: Precision ty | POSIX time in ns |
| Microsecond :: Precision ty | POSIX time in μs |
| Millisecond :: Precision ty | POSIX time in ms |
| Second :: Precision ty | POSIX time in s |
| Minute :: Precision ty | POSIX time in minutes |
| Hour :: Precision ty | POSIX time in hours |
| RFC3339 :: Precision QueryRequest | Nanosecond precision time in a human readable format, like
|