simplexmq-6.5.0.16: SimpleXMQ message broker
Safe HaskellSafe-Inferred
LanguageHaskell2010

Simplex.Messaging.Server.StoreLog

Synopsis

Documentation

data StoreLog (a :: IOMode) Source #

opaque container for file handle with a type-safe IOMode constructors are not exported, openWriteStoreLog and openReadStoreLog should be used instead

openWriteStoreLog :: Bool -> FilePath -> IO (StoreLog 'WriteMode) Source #

openReadStoreLog :: FilePath -> IO (StoreLog 'ReadMode) Source #

writeStoreLogRecord :: StrEncoding r => StoreLog 'WriteMode -> r -> IO () Source #

logCreateQueue :: StoreLog 'WriteMode -> RecipientId -> QueueRec -> IO () Source #

logDeleteLink :: StoreLog 'WriteMode -> RecipientId -> IO () Source #

logUpdateKeys :: StoreLog 'WriteMode -> QueueId -> NonEmpty RcvPublicAuthKey -> IO () Source #

logAddNotifier :: StoreLog 'WriteMode -> QueueId -> NtfCreds -> IO () Source #

logSuspendQueue :: StoreLog 'WriteMode -> QueueId -> IO () Source #

logBlockQueue :: StoreLog 'WriteMode -> QueueId -> BlockingInfo -> IO () Source #

logUnblockQueue :: StoreLog 'WriteMode -> QueueId -> IO () Source #

logDeleteQueue :: StoreLog 'WriteMode -> QueueId -> IO () Source #

logDeleteNotifier :: StoreLog 'WriteMode -> QueueId -> IO () Source #

logUpdateQueueTime :: StoreLog 'WriteMode -> QueueId -> SystemDate -> IO () Source #

logNewService :: StoreLog 'WriteMode -> ServiceRec -> IO () Source #

logQueueService :: (PartyI p, ServiceParty p) => StoreLog 'WriteMode -> RecipientId -> SParty p -> Maybe ServiceId -> IO () Source #

readWriteStoreLog :: (FilePath -> s -> IO ()) -> (StoreLog 'WriteMode -> s -> IO ()) -> FilePath -> s -> IO (StoreLog 'WriteMode) Source #

readLogLines :: Bool -> FilePath -> (Bool -> ByteString -> IO ()) -> IO () Source #

foldLogLines :: Bool -> FilePath -> (a -> Bool -> ByteString -> IO a) -> a -> IO a Source #

Orphan instances

StrEncoding QueueRec Source # 
Instance details

Methods

strEncode :: QueueRec -> ByteString Source #

strDecode :: ByteString -> Either String QueueRec Source #

strP :: Parser QueueRec Source #