simplexmq-0.5.2: SimpleXMQ message broker
Safe HaskellNone
LanguageHaskell2010

Simplex.Messaging.Server.QueueStore.STM

Documentation

data QueueStoreData Source #

Constructors

QueueStoreData 

Fields

Instances

Instances details
MonadQueueStore QueueStore STM Source # 
Instance details

Defined in Simplex.Messaging.Server.QueueStore.STM

Methods

addQueue :: QueueStore -> RecipientPublicKey -> (RecipientId, SenderId) -> STM (Either ErrorType ()) Source #

getQueue :: forall (a :: Party). QueueStore -> SParty a -> QueueId -> STM (Either ErrorType QueueRec) Source #

secureQueue :: QueueStore -> RecipientId -> SenderPublicKey -> STM (Either ErrorType ()) Source #

suspendQueue :: QueueStore -> RecipientId -> STM (Either ErrorType ()) Source #

deleteQueue :: QueueStore -> RecipientId -> STM (Either ErrorType ()) Source #

type QueueStore = TVar QueueStoreData Source #

newQueueStore :: STM QueueStore Source #

updateQueues :: QueueStore -> RecipientId -> (QueueStoreData -> QueueRec -> (Either ErrorType (), QueueStoreData)) -> STM (Either ErrorType ()) Source #

getRcpQueue :: QueueStoreData -> RecipientId -> Either ErrorType QueueRec Source #