simplexmq-6.5.0.16: SimpleXMQ message broker

Safe Haskell	None
Language	Haskell2010

Simplex.Messaging.Client.Agent

Documentation

data SMPClientAgent (p :: Party) Source #

Constructors

Fields

agentCfg :: SMPClientAgentConfig
agentParty :: SParty p
active :: TVar Bool
startedAt :: UTCTime
msgQ :: TBQueue (ServerTransmissionBatch SMPVersion ErrorType BrokerMsg)
agentQ :: TBQueue SMPClientAgentEvent
randomDrg :: TVar ChaChaDRG
smpClients :: TMap SMPServer SMPClientVar
smpSessions :: TMap SessionId (OwnServer, SMPClient)
activeServiceSubs :: TMap SMPServer (TVar (Maybe ((ServiceId, Int64), SessionId)))
activeQueueSubs :: TMap SMPServer (TMap QueueId (SessionId, APrivateAuthKey))
pendingServiceSubs :: TMap SMPServer (TVar (Maybe (ServiceId, Int64)))
pendingQueueSubs :: TMap SMPServer (TMap QueueId APrivateAuthKey)
smpSubWorkers :: TMap SMPServer (SessionVar (Async ()))
workerSeq :: TVar Int

data SMPClientAgentConfig Source #

Constructors

SMPClientAgentConfig
Fields smpCfg :: ProtocolClientConfig SMPVersion reconnectInterval :: RetryInterval persistErrorInterval :: NominalDiffTime msgQSize :: Natural agentQSize :: Natural agentSubsBatchSize :: Int ownServerDomains :: [ByteString]

data SMPClientAgentEvent Source #

Constructors

CAConnected SMPServer (Maybe ServiceId)
CADisconnected SMPServer (NonEmpty QueueId)
CASubscribed SMPServer (Maybe ServiceId) (NonEmpty QueueId)
CASubError SMPServer (NonEmpty (QueueId, SMPClientError))
CAServiceDisconnected SMPServer (ServiceId, Int64)
CAServiceSubscribed SMPServer (ServiceId, Int64) Int64
CAServiceSubError SMPServer (ServiceId, Int64) SMPClientError
CAServiceUnavailable SMPServer (ServiceId, Int64)

type OwnServer = Bool Source #

defaultSMPClientAgentConfig :: SMPClientAgentConfig Source #

newSMPClientAgent :: forall (p :: Party). SParty p -> SMPClientAgentConfig -> TVar ChaChaDRG -> IO (SMPClientAgent p) Source #

getSMPServerClient'' :: forall (p :: Party). SMPClientAgent p -> SMPServer -> ExceptT SMPClientError IO (OwnServer, SMPClient) Source #

getConnectedSMPServerClient :: forall (p :: Party). SMPClientAgent p -> SMPServer -> IO (Maybe (Either SMPClientError (OwnServer, SMPClient))) Source #

closeSMPClientAgent :: forall (p :: Party). SMPClientAgent p -> IO () Source #

lookupSMPServerClient :: forall (p :: Party). SMPClientAgent p -> SessionId -> IO (Maybe (OwnServer, SMPClient)) Source #

isOwnServer :: forall (p :: Party). SMPClientAgent p -> SMPServer -> OwnServer Source #

subscribeServiceNtfs :: SMPClientAgent 'NotifierService -> SMPServer -> (ServiceId, Int64) -> IO () Source #

subscribeQueuesNtfs :: SMPClientAgent 'NotifierService -> SMPServer -> NonEmpty (NotifierId, NtfPrivateAuthKey) -> IO () Source #

activeClientSession' :: forall (p :: Party). SMPClientAgent p -> SessionId -> SMPServer -> STM Bool Source #

removeActiveSub :: forall (p :: Party). SMPClientAgent p -> SMPServer -> QueueId -> STM () Source #

removeActiveSubs :: forall (p :: Party). SMPClientAgent p -> SMPServer -> [QueueId] -> STM () Source #

removePendingSub :: forall (p :: Party). SMPClientAgent p -> SMPServer -> QueueId -> STM () Source #

removePendingSubs :: forall (p :: Party). SMPClientAgent p -> SMPServer -> [QueueId] -> STM () Source #