Examples.Raft.FileStore

Documentation

newtype NodeEnvError

Constructors

NodeEnvError Text

Instances

Show NodeEnvError

Defined in Examples.Raft.FileStore

Methods

showsPrec :: Int -> NodeEnvError -> ShowS

show :: NodeEnvError -> String

showList :: [NodeEnvError] -> ShowS

Exception NodeEnvError

Defined in Examples.Raft.FileStore

Methods

toException :: NodeEnvError -> SomeException

fromException :: SomeException -> Maybe NodeEnvError

displayException :: NodeEnvError -> String

data NodeFileStoreEnv

Constructors

NodeFileStoreEnv

Fields

• nfsPersistentState :: FilePath
• nfsLogEntries :: FilePath

Instances

Monad m => MonadReader NodeFileStoreEnv (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

ask :: RaftFileStoreT m NodeFileStoreEnv

local :: (NodeFileStoreEnv -> NodeFileStoreEnv) -> RaftFileStoreT m a -> RaftFileStoreT m a

reader :: (NodeFileStoreEnv -> a) -> RaftFileStoreT m a

newtype RaftFileStoreT m a

Constructors

RaftFileStoreT

Fields

• unRaftFileStoreT :: ReaderT NodeFileStoreEnv m a

Instances

MonadTrans RaftFileStoreT

Defined in Examples.Raft.FileStore

Methods

lift :: Monad m => m a -> RaftFileStoreT m a

Monad m => MonadReader NodeFileStoreEnv (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

ask :: RaftFileStoreT m NodeFileStoreEnv

local :: (NodeFileStoreEnv -> NodeFileStoreEnv) -> RaftFileStoreT m a -> RaftFileStoreT m a

reader :: (NodeFileStoreEnv -> a) -> RaftFileStoreT m a

Monad m => Monad (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

(>>=) :: RaftFileStoreT m a -> (a -> RaftFileStoreT m b) -> RaftFileStoreT m b

(>>) :: RaftFileStoreT m a -> RaftFileStoreT m b -> RaftFileStoreT m b

return :: a -> RaftFileStoreT m a

fail :: String -> RaftFileStoreT m a

Functor m => Functor (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

fmap :: (a -> b) -> RaftFileStoreT m a -> RaftFileStoreT m b

(<$) :: a -> RaftFileStoreT m b -> RaftFileStoreT m a

MonadFail m => MonadFail (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

fail :: String -> RaftFileStoreT m a

Applicative m => Applicative (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

pure :: a -> RaftFileStoreT m a

(<*>) :: RaftFileStoreT m (a -> b) -> RaftFileStoreT m a -> RaftFileStoreT m b

liftA2 :: (a -> b -> c) -> RaftFileStoreT m a -> RaftFileStoreT m b -> RaftFileStoreT m c

(*>) :: RaftFileStoreT m a -> RaftFileStoreT m b -> RaftFileStoreT m b

(<*) :: RaftFileStoreT m a -> RaftFileStoreT m b -> RaftFileStoreT m a

Alternative m => Alternative (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

empty :: RaftFileStoreT m a

(<|>) :: RaftFileStoreT m a -> RaftFileStoreT m a -> RaftFileStoreT m a

some :: RaftFileStoreT m a -> RaftFileStoreT m [a]

many :: RaftFileStoreT m a -> RaftFileStoreT m [a]

MonadPlus m => MonadPlus (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

mzero :: RaftFileStoreT m a

mplus :: RaftFileStoreT m a -> RaftFileStoreT m a -> RaftFileStoreT m a

MonadIO m => MonadIO (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

liftIO :: IO a -> RaftFileStoreT m a

MonadConc m => MonadConc (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Associated Types

type STM (RaftFileStoreT m) :: Type -> Type

type MVar (RaftFileStoreT m) :: Type -> Type

type IORef (RaftFileStoreT m) :: Type -> Type

type Ticket (RaftFileStoreT m) :: Type -> Type

type ThreadId (RaftFileStoreT m) :: Type

Methods

forkWithUnmask :: ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m ()) -> RaftFileStoreT m (ThreadId (RaftFileStoreT m))

forkWithUnmaskN :: String -> ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m ()) -> RaftFileStoreT m (ThreadId (RaftFileStoreT m))

forkOnWithUnmask :: Int -> ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m ()) -> RaftFileStoreT m (ThreadId (RaftFileStoreT m))

forkOnWithUnmaskN :: String -> Int -> ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m ()) -> RaftFileStoreT m (ThreadId (RaftFileStoreT m))

forkOSWithUnmask :: ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m ()) -> RaftFileStoreT m (ThreadId (RaftFileStoreT m))

forkOSWithUnmaskN :: String -> ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m ()) -> RaftFileStoreT m (ThreadId (RaftFileStoreT m))

isCurrentThreadBound :: RaftFileStoreT m Bool

getNumCapabilities :: RaftFileStoreT m Int

setNumCapabilities :: Int -> RaftFileStoreT m ()

myThreadId :: RaftFileStoreT m (ThreadId (RaftFileStoreT m))

yield :: RaftFileStoreT m ()

threadDelay :: Int -> RaftFileStoreT m ()

newEmptyMVar :: RaftFileStoreT m (MVar (RaftFileStoreT m) a)

newEmptyMVarN :: String -> RaftFileStoreT m (MVar (RaftFileStoreT m) a)

putMVar :: MVar (RaftFileStoreT m) a -> a -> RaftFileStoreT m ()

tryPutMVar :: MVar (RaftFileStoreT m) a -> a -> RaftFileStoreT m Bool

readMVar :: MVar (RaftFileStoreT m) a -> RaftFileStoreT m a

tryReadMVar :: MVar (RaftFileStoreT m) a -> RaftFileStoreT m (Maybe a)

takeMVar :: MVar (RaftFileStoreT m) a -> RaftFileStoreT m a

tryTakeMVar :: MVar (RaftFileStoreT m) a -> RaftFileStoreT m (Maybe a)

newIORef :: a -> RaftFileStoreT m (IORef (RaftFileStoreT m) a)

newIORefN :: String -> a -> RaftFileStoreT m (IORef (RaftFileStoreT m) a)

readIORef :: IORef (RaftFileStoreT m) a -> RaftFileStoreT m a

atomicModifyIORef :: IORef (RaftFileStoreT m) a -> (a -> (a, b)) -> RaftFileStoreT m b

writeIORef :: IORef (RaftFileStoreT m) a -> a -> RaftFileStoreT m ()

atomicWriteIORef :: IORef (RaftFileStoreT m) a -> a -> RaftFileStoreT m ()

readForCAS :: IORef (RaftFileStoreT m) a -> RaftFileStoreT m (Ticket (RaftFileStoreT m) a)

peekTicket' :: Proxy (RaftFileStoreT m) -> Ticket (RaftFileStoreT m) a -> a

casIORef :: IORef (RaftFileStoreT m) a -> Ticket (RaftFileStoreT m) a -> a -> RaftFileStoreT m (Bool, Ticket (RaftFileStoreT m) a)

modifyIORefCAS :: IORef (RaftFileStoreT m) a -> (a -> (a, b)) -> RaftFileStoreT m b

modifyIORefCAS_ :: IORef (RaftFileStoreT m) a -> (a -> a) -> RaftFileStoreT m ()

atomically :: STM (RaftFileStoreT m) a -> RaftFileStoreT m a

readTVarConc :: TVar (STM (RaftFileStoreT m)) a -> RaftFileStoreT m a

throwTo :: Exception e => ThreadId (RaftFileStoreT m) -> e -> RaftFileStoreT m ()

MonadConc m => MonadThrow (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

throwM :: Exception e => e -> RaftFileStoreT m a

MonadConc m => MonadCatch (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

catch :: Exception e => RaftFileStoreT m a -> (e -> RaftFileStoreT m a) -> RaftFileStoreT m a

MonadConc m => MonadMask (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Methods

mask :: ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m b) -> RaftFileStoreT m b

uninterruptibleMask :: ((forall a. RaftFileStoreT m a -> RaftFileStoreT m a) -> RaftFileStoreT m b) -> RaftFileStoreT m b

generalBracket :: RaftFileStoreT m a -> (a -> ExitCase b -> RaftFileStoreT m c) -> (a -> RaftFileStoreT m b) -> RaftFileStoreT m (b, c)

(MonadIO m, MonadConc m) => RaftPersist (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

Associated Types

type RaftPersistError (RaftFileStoreT m) :: Type

Methods

readPersistentState :: RaftFileStoreT m (Either (RaftPersistError (RaftFileStoreT m)) PersistentState)

writePersistentState :: PersistentState -> RaftFileStoreT m (Either (RaftPersistError (RaftFileStoreT m)) ())

(MonadIO m, MonadConc m, Serialize v) => RaftReadLog (RaftFileStoreT m) v

Defined in Examples.Raft.FileStore

Associated Types

type RaftReadLogError (RaftFileStoreT m) :: Type

Methods

readLogEntry :: Index -> RaftFileStoreT m (Either (RaftReadLogError (RaftFileStoreT m)) (Maybe (Entry v)))

readLogEntriesFrom :: Index -> RaftFileStoreT m (Either (RaftReadLogError (RaftFileStoreT m)) (Entries v))

readLastLogEntry :: RaftFileStoreT m (Either (RaftReadLogError (RaftFileStoreT m)) (Maybe (Entry v)))

(MonadIO m, MonadConc m, Serialize v) => RaftDeleteLog (RaftFileStoreT m) v

Defined in Examples.Raft.FileStore

Associated Types

type RaftDeleteLogError (RaftFileStoreT m) :: Type

Methods

deleteLogEntriesFrom :: Index -> RaftFileStoreT m (Either (RaftDeleteLogError (RaftFileStoreT m)) (DeleteSuccess v))

(MonadIO m, MonadConc m, Serialize v) => RaftWriteLog (RaftFileStoreT m) v

Defined in Examples.Raft.FileStore

Associated Types

type RaftWriteLogError (RaftFileStoreT m) :: Type

Methods

writeLogEntries :: Entries v -> RaftFileStoreT m (Either (RaftWriteLogError (RaftFileStoreT m)) ())

type ThreadId (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type ThreadId (RaftFileStoreT m) = ThreadId (ReaderT NodeFileStoreEnv m)

type Ticket (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type Ticket (RaftFileStoreT m) = Ticket (ReaderT NodeFileStoreEnv m)

type IORef (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type IORef (RaftFileStoreT m) = IORef (ReaderT NodeFileStoreEnv m)

type MVar (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type MVar (RaftFileStoreT m) = MVar (ReaderT NodeFileStoreEnv m)

type STM (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type STM (RaftFileStoreT m) = STM (ReaderT NodeFileStoreEnv m)

type RaftPersistError (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type RaftPersistError (RaftFileStoreT m) = NodeEnvError

type RaftReadLogError (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type RaftReadLogError (RaftFileStoreT m) = NodeEnvError

type RaftDeleteLogError (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type RaftDeleteLogError (RaftFileStoreT m) = NodeEnvError

type RaftWriteLogError (RaftFileStoreT m)

Defined in Examples.Raft.FileStore

type RaftWriteLogError (RaftFileStoreT m) = NodeEnvError

readLogEntries :: (MonadIO m, Serialize v) => RaftFileStoreT m (Either Text (Entries v))