Simplex.Messaging.Server.Env.STM

Documentation

data ServerConfig

Constructors

ServerConfig

Fields

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

data Env

Constructors

Env

Fields

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

data Server

Constructors

Server

Fields

• subscribedQ :: TBQueue (RecipientId, Client)
• subscribers :: TVar (Map RecipientId Client)

data Client

Constructors

Client

Fields

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

data SubscriptionThread

Constructors

NoSub

SubPending

SubThread ThreadId

data Sub

Constructors

Sub

Fields

• subThread :: SubscriptionThread
• delivered :: TMVar ()

newServer :: Natural -> STM Server

newClient :: Natural -> STM Client

newSubscription :: STM Sub

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