Database.InfluxDB.Write.UDP

Documentation

This module is desined to be used with the network package and be imported qualified.

>>> :set -XOverloadedStrings -XNoOverloadedLists
>>> import qualified Data.Map as Map
>>> import Data.Time
>>> import Network.Socket
>>> import Database.InfluxDB
>>> import qualified Database.InfluxDB.Write.UDP as UDP
>>> sock <- Network.Socket.socket AF_INET Datagram defaultProtocol
>>> let localhost = tupleToHostAddress (127, 0, 0, 1)
>>> let params = UDP.writeParams sock $ SockAddrInet 8089 localhost
>>> UDP.write params $ Line "measurement1" Map.empty (Map.fromList [("value", FieldInt 42)]) (Nothing :: Maybe UTCTime)
>>> close sock

Make sure that the UDP service is enabled in the InfluxDB config. This API doesn't tell you if any error occurs. See the official doc for details.

Writers

write :: Timestamp time => WriteParams -> Line time -> IO ()

Write a Line

writeBatch :: (Timestamp time, Foldable f) => WriteParams -> f (Line time) -> IO ()

Write Lines in a batch

This is more efficient than write.

writeByteString :: WriteParams -> ByteString -> IO ()

Write a lazy ByteString

Writer parameters

data WriteParams

The full set of parameters for the UDP writer.

Instances

HasPrecision 'WriteRequest WriteParams

Timestamp precision.

In the UDP API, all timestamps are sent in nanosecond but you can specify lower precision. The writer just rounds timestamps to the specified precision.

Defined in Database.InfluxDB.Write.UDP

Methods

precision :: Lens' WriteParams (Precision 'WriteRequest)

writeParams :: Socket -> SockAddr -> WriteParams

Smart constructor for WriteParams

Default parameters:

precision

Nanosecond

socket :: Lens' WriteParams Socket

Open UDP socket

sockAddr :: Lens' WriteParams SockAddr

UDP endopoint of the database

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

Time precision parameter.