Metro.Node

Documentation

data NodeEnv u nid k rpkt

Instances

Monad m => MonadReader (NodeEnv u nid k rpkt) (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

ask :: NodeT u nid k rpkt tp m (NodeEnv u nid k rpkt)

local :: (NodeEnv u nid k rpkt -> NodeEnv u nid k rpkt) -> NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m a

reader :: (NodeEnv u nid k rpkt -> a) -> NodeT u nid k rpkt tp m a

data NodeMode

Constructors

Single

Multi

Instances

Eq NodeMode

Defined in Metro.Node

Methods

(==) :: NodeMode -> NodeMode -> Bool

(/=) :: NodeMode -> NodeMode -> Bool

Show NodeMode

Defined in Metro.Node

Methods

showsPrec :: Int -> NodeMode -> ShowS

show :: NodeMode -> String

showList :: [NodeMode] -> ShowS

data SessionMode

Constructors

SingleAction

MultiAction

Instances

Eq SessionMode

Defined in Metro.Node

Methods

(==) :: SessionMode -> SessionMode -> Bool

(/=) :: SessionMode -> SessionMode -> Bool

Show SessionMode

Defined in Metro.Node

Methods

showsPrec :: Int -> SessionMode -> ShowS

show :: SessionMode -> String

showList :: [SessionMode] -> ShowS

data NodeT u nid k rpkt tp m a

Instances

FromConn (NodeT u nid k rpkt)

Defined in Metro.Node

Methods

fromConn :: forall (n :: Type -> Type) tp a. Monad n => ConnT tp n a -> NodeT u nid k rpkt tp n a

Monad m => MonadReader (NodeEnv u nid k rpkt) (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

ask :: NodeT u nid k rpkt tp m (NodeEnv u nid k rpkt)

local :: (NodeEnv u nid k rpkt -> NodeEnv u nid k rpkt) -> NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m a

reader :: (NodeEnv u nid k rpkt -> a) -> NodeT u nid k rpkt tp m a

MonadTrans (NodeT u nid k rpkt tp)

Defined in Metro.Node

Methods

lift :: Monad m => m a -> NodeT u nid k rpkt tp m a

Monad m => Monad (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

(>>=) :: NodeT u nid k rpkt tp m a -> (a -> NodeT u nid k rpkt tp m b) -> NodeT u nid k rpkt tp m b

(>>) :: NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m b -> NodeT u nid k rpkt tp m b

return :: a -> NodeT u nid k rpkt tp m a

Functor m => Functor (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

fmap :: (a -> b) -> NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m b

(<$) :: a -> NodeT u nid k rpkt tp m b -> NodeT u nid k rpkt tp m a

Applicative m => Applicative (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

pure :: a -> NodeT u nid k rpkt tp m a

(<*>) :: NodeT u nid k rpkt tp m (a -> b) -> NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m b

liftA2 :: (a -> b -> c) -> NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m b -> NodeT u nid k rpkt tp m c

(*>) :: NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m b -> NodeT u nid k rpkt tp m b

(<*) :: NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m b -> NodeT u nid k rpkt tp m a

MonadIO m => MonadIO (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

liftIO :: IO a -> NodeT u nid k rpkt tp m a

MonadUnliftIO m => MonadUnliftIO (NodeT u nid k rpkt tp m)

Defined in Metro.Node

Methods

withRunInIO :: ((forall a. NodeT u nid k rpkt tp m a -> IO a) -> IO b) -> NodeT u nid k rpkt tp m b

initEnv :: MonadIO m => u -> nid -> IO k -> m (NodeEnv u nid k rpkt)

withEnv :: Monad m => u -> NodeT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m a

setNodeMode :: NodeMode -> NodeEnv u nid k rpkt -> NodeEnv u nid k rpkt

setSessionMode :: SessionMode -> NodeEnv u nid k rpkt -> NodeEnv u nid k rpkt

setDefaultSessionTimeout :: TVar Int64 -> NodeEnv u nid k rpkt -> NodeEnv u nid k rpkt

setDefaultSessionTimeout1 :: MonadIO m => NodeEnv1 u nid k rpkt tp -> Int64 -> m ()

runNodeT :: NodeEnv u nid k rpkt -> NodeT u nid k rpkt tp m a -> ConnT tp m a

startNodeT :: (MonadUnliftIO m, Transport tp, RecvPacket rpkt, GetPacketId k rpkt, Eq k, Hashable k) => SessionT u nid k rpkt tp m () -> NodeT u nid k rpkt tp m ()

startNodeT_ :: (MonadUnliftIO m, Transport tp, RecvPacket rpkt, GetPacketId k rpkt, Eq k, Hashable k) => (rpkt -> m Bool) -> SessionT u nid k rpkt tp m () -> NodeT u nid k rpkt tp m ()

withSessionT :: (MonadUnliftIO m, Eq k, Hashable k) => Maybe Int64 -> SessionT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m a

nodeState :: MonadIO m => NodeT u nid k rpkt tp m Bool

stopNodeT :: (MonadIO m, Transport tp) => NodeT u nid k rpkt tp m ()

env :: Monad m => NodeT u nid k rpkt tp m u

request :: (MonadUnliftIO m, Transport tp, SendPacket spkt, SetPacketId k spkt, Eq k, Hashable k) => Maybe Int64 -> spkt -> NodeT u nid k rpkt tp m (Maybe rpkt)

requestAndRetry :: (MonadUnliftIO m, Transport tp, SendPacket spkt, SetPacketId k spkt, Eq k, Hashable k) => Maybe Int64 -> Maybe Int -> spkt -> NodeT u nid k rpkt tp m (Maybe rpkt)

newSessionEnv :: (MonadIO m, Eq k, Hashable k) => Maybe Int64 -> k -> NodeT u nid k rpkt tp m (SessionEnv u nid k rpkt)

nextSessionId :: MonadIO m => NodeT u nid k rpkt tp m k

runSessionT_ :: Monad m => SessionEnv u nid k rpkt -> SessionT u nid k rpkt tp m a -> NodeT u nid k rpkt tp m a

busy :: MonadIO m => NodeT u nid k rpkt tp m Bool

data NodeEnv1 u nid k rpkt tp

Constructors

NodeEnv1

Fields

• nodeEnv :: NodeEnv u nid k rpkt
• connEnv :: ConnEnv tp

initEnv1 :: MonadIO m => (NodeEnv u nid k rpkt -> NodeEnv u nid k rpkt) -> ConnEnv tp -> u -> nid -> IO k -> m (NodeEnv1 u nid k rpkt tp)

runNodeT1 :: NodeEnv1 u nid k rpkt tp -> NodeT u nid k rpkt tp m a -> m a

getEnv1 :: (Monad m, Transport tp) => NodeT u nid k rpkt tp m (NodeEnv1 u nid k rpkt tp)

getTimer :: MonadIO m => NodeT u nid k rpkt tp m Int64

getNodeId :: Monad m => NodeT n nid k rpkt tp m nid

getSessionSize :: MonadIO m => NodeEnv u nid k rpkt -> m Int

getSessionSize1 :: MonadIO m => NodeEnv1 u nid k rpkt tp -> m Int