simplexmq-0.4.1: SimpleXMQ message broker

Safe Haskell	None
Language	Haskell2010

Simplex.Messaging.Server.Env.STM

Documentation

data ServerConfig Source #

Constructors

ServerConfig
Fields transports :: [(ServiceName, ATransport)] tbqSize :: Natural msgQueueQuota :: Natural queueIdBytes :: Int msgIdBytes :: Int storeLog :: Maybe (StoreLog 'ReadMode) blockSize :: Int serverPrivateKey :: FullPrivateKey

data Env Source #

Constructors

Env
Fields config :: ServerConfig server :: Server queueStore :: QueueStore msgStore :: STMMsgStore idsDrg :: TVar ChaChaDRG serverKeyPair :: FullKeyPair storeLog :: Maybe (StoreLog 'WriteMode)

data Server Source #

Constructors

Server
Fields subscribedQ :: TBQueue (RecipientId, Client) subscribers :: TVar (Map RecipientId Client)

data Client Source #

Constructors

Client
Fields subscriptions :: TVar (Map RecipientId Sub) rcvQ :: TBQueue Transmission sndQ :: TBQueue Transmission

data SubscriptionThread Source #

Constructors

NoSub
SubPending
SubThread ThreadId

data Sub Source #

Constructors

Sub
Fields subThread :: SubscriptionThread delivered :: TMVar ()

newServer :: Natural -> STM Server Source #

newClient :: Natural -> STM Client Source #

newSubscription :: STM Sub Source #

newEnv :: forall m. (MonadUnliftIO m, MonadRandom m) => ServerConfig -> m Env Source #