Neptune.Channel

Documentation

data DataChannelWithData

Constructors

forall a.NeptDataType a => DataChannelWithData (DataChannel a, [DataPoint a])

transmitter :: HasCallStack => NeptuneSession -> Experiment -> IO ()

Background thread for transmission

createChannel :: forall t. (NeptDataType t, HasCallStack) => NeptuneSession -> ExperimentId -> Text -> IO (DataChannel t)

Create a neptune data channel.

getOrCreateChannel

Arguments

:: forall t. NeptDataType t

=> Proxy t

dummy data type

-> ChannelHashMap

current user channels

-> Text

channel name

-> IO (DataChannel t)

creator

-> IO DataChannelAny

Get a neptune data channel. If the data channel doesn't exist yet, a data channel will be created and added to the hashmap of current user channels.

sendChannel :: HasCallStack => NeptuneSession -> ExperimentId -> [DataChannelWithData] -> IO ()

Send a batch of data in their respective channel.

readTChanAtMost :: Int -> TChan a -> STM [a]

Read at most n items from the queue, with blocking read at the first item.

readTChanFull :: TChan a -> STM [a]

Read all items from the queue

gatherDataPoints :: forall a. NeptDataType a => Proxy a -> [DataPointAny] -> ([Text], [DataPoint a])

logE :: MonadIO m => NeptuneBackendConfig -> Text -> m ()