simplexmq-0.5.2: 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 serverTbqSize :: 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) nextClientId :: TVar Natural

data Client Source #

Constructors

Client
Fields subscriptions :: TVar (Map RecipientId Sub) rcvQ :: TBQueue Transmission sndQ :: TBQueue Transmission clientId :: Natural connected :: TVar Bool

data SubscriptionThread Source #

Constructors

NoSub
SubPending
SubThread ThreadId

data Sub Source #

Constructors

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

newServer :: Natural -> STM Server Source #

newClient :: Server -> Natural -> STM Client Source #

newSubscription :: STM Sub Source #

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