simplexmq-0.5.1: SimpleXMQ message broker
Safe HaskellNone
LanguageHaskell2010

Simplex.Messaging.Server.QueueStore

Documentation

data QueueRec Source #

Constructors

QueueRec 

Fields

data QueueStatus Source #

Constructors

QueueActive 
QueueOff 

Instances

Instances details
Eq QueueStatus Source # 
Instance details

Defined in Simplex.Messaging.Server.QueueStore

Methods

(==) :: QueueStatus -> QueueStatus -> Bool #

(/=) :: QueueStatus -> QueueStatus -> Bool #

class MonadQueueStore s m where Source #

Methods

addQueue :: s -> RecipientPublicKey -> (RecipientId, SenderId) -> m (Either ErrorType ()) Source #

getQueue :: s -> SParty (a :: Party) -> QueueId -> m (Either ErrorType QueueRec) Source #

secureQueue :: s -> RecipientId -> SenderPublicKey -> m (Either ErrorType ()) Source #

suspendQueue :: s -> RecipientId -> m (Either ErrorType ()) Source #

deleteQueue :: s -> RecipientId -> m (Either ErrorType ()) Source #

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 #

mkQueueRec :: RecipientPublicKey -> (RecipientId, SenderId) -> QueueRec Source #