Safe Haskell	None
Language	Haskell2010

Raft.Log

Synopsis

data EntryIssuer
- = ClientIssuer ClientId SerialNum
- | LeaderIssuer LeaderId
data EntryValue v
- = EntryValue v
- | NoValue
newtype EntryHash = EntryHash {
- unEntryHash :: ByteString
}
genesisHash :: EntryHash
hashEntry :: Serialize v => Entry v -> EntryHash
data Entry v = Entry {
- entryIndex :: Index
- entryTerm :: Term
- entryValue :: EntryValue v
- entryIssuer :: EntryIssuer
- entryPrevHash :: EntryHash
}
type Entries v = Seq (Entry v)
lastEntryIndex :: Entries v -> Maybe Index
data LastLogEntry v
- = LastLogEntry (Entry v)
- | NoLogEntries
hashLastLogEntry :: Serialize v => LastLogEntry v -> EntryHash
lastLogEntryIndex :: LastLogEntry v -> Index
lastLogEntryIssuer :: LastLogEntry v -> Maybe EntryIssuer
lastLogEntryTerm :: LastLogEntry v -> Term
lastLogEntryIndexAndTerm :: LastLogEntry v -> (Index, Term)
class RaftInitLog m v where
- type RaftInitLogError m
- initializeLog :: Proxy v -> m (Either (RaftInitLogError m) ())
data ReadEntriesSpec
- = ByIndex Index
- | ByIndices IndexInterval
data ReadEntriesRes v
- = OneEntry (Entry v)
- | ManyEntries (Entries v)
data IndexInterval = IndexInterval (Maybe Index) (Maybe Index)
class (Show (RaftReadLogError m), Monad m) => RaftReadLog m v where
- type RaftReadLogError m
- readLogEntry :: Exception (RaftReadLogError m) => Index -> m (Either (RaftReadLogError m) (Maybe (Entry v)))
- readLogEntriesFrom :: Exception (RaftReadLogError m) => Index -> m (Either (RaftReadLogError m) (Entries v))
- readLastLogEntry :: Exception (RaftReadLogError m) => m (Either (RaftReadLogError m) (Maybe (Entry v)))
class (Show (RaftWriteLogError m), Monad m) => RaftWriteLog m v where
- type RaftWriteLogError m
- writeLogEntries :: Exception (RaftWriteLogError m) => Entries v -> m (Either (RaftWriteLogError m) ())
class (Show (RaftDeleteLogError m), Monad m) => RaftDeleteLog m v where
- type RaftDeleteLogError m
- deleteLogEntriesFrom :: Exception (RaftDeleteLogError m) => Index -> m (Either (RaftDeleteLogError m) (DeleteSuccess v))
data DeleteSuccess v = DeleteSuccess
type RaftLog m v = (RaftInitLog m v, RaftReadLog m v, RaftWriteLog m v, RaftDeleteLog m v)
data RaftLogError m
type RaftLogExceptions m = (Exception (RaftInitLogError m), Exception (RaftReadLogError m), Exception (RaftWriteLogError m), Exception (RaftDeleteLogError m))
updateLog :: forall m v. (RaftDeleteLog m v, Exception (RaftDeleteLogError m), RaftWriteLog m v, Exception (RaftWriteLogError m)) => Entries v -> m (Either (RaftLogError m) (Maybe Index))
clientReqData :: Entries v -> Map ClientId (SerialNum, Index)
readEntries :: forall m v. (RaftReadLog m v, Exception (RaftReadLogError m)) => ReadEntriesSpec -> m (Either (ReadEntriesError m) (ReadEntriesRes v))

Documentation

data EntryIssuer Source #

Constructors

ClientIssuer ClientId SerialNum
LeaderIssuer LeaderId

Instances

Eq EntryIssuer Source #
Instance details Defined in Raft.Log Methods (==) :: EntryIssuer -> EntryIssuer -> Bool # (/=) :: EntryIssuer -> EntryIssuer -> Bool #
Read EntryIssuer Source #
Instance details Defined in Raft.Log Methods readsPrec :: Int -> ReadS EntryIssuer # readList :: ReadS [EntryIssuer] # readPrec :: ReadPrec EntryIssuer # readListPrec :: ReadPrec [EntryIssuer] #
Show EntryIssuer Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> EntryIssuer -> ShowS # show :: EntryIssuer -> String # showList :: [EntryIssuer] -> ShowS #
Generic EntryIssuer Source #
Instance details Defined in Raft.Log Associated Types type Rep EntryIssuer :: Type -> Type # Methods from :: EntryIssuer -> Rep EntryIssuer x # to :: Rep EntryIssuer x -> EntryIssuer #
Serialize EntryIssuer Source #
Instance details Defined in Raft.Log Methods put :: Putter EntryIssuer # get :: Get EntryIssuer #
FromField EntryIssuer Source #
Instance details Defined in Raft.Log Methods fromField :: FieldParser EntryIssuer #
ToField EntryIssuer Source #
Instance details Defined in Raft.Log Methods toField :: EntryIssuer -> Action #
type Rep EntryIssuer Source #
Instance details Defined in Raft.Log type Rep EntryIssuer = D1 (MetaData "EntryIssuer" "Raft.Log" "libraft-0.5.0.0-J9sQlo4v2xjSwCkwompQR" False) (C1 (MetaCons "ClientIssuer" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ClientId) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 SerialNum)) :+: C1 (MetaCons "LeaderIssuer" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 LeaderId)))

data EntryValue v Source #

Constructors

EntryValue v
NoValue	Used as a first committed entry of a new term

Instances

Eq v => Eq (EntryValue v) Source #
Instance details Defined in Raft.Log Methods (==) :: EntryValue v -> EntryValue v -> Bool # (/=) :: EntryValue v -> EntryValue v -> Bool #
Show v => Show (EntryValue v) Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> EntryValue v -> ShowS # show :: EntryValue v -> String # showList :: [EntryValue v] -> ShowS #
Generic (EntryValue v) Source #
Instance details Defined in Raft.Log Associated Types type Rep (EntryValue v) :: Type -> Type # Methods from :: EntryValue v -> Rep (EntryValue v) x # to :: Rep (EntryValue v) x -> EntryValue v #
Serialize v => Serialize (EntryValue v) Source #
Instance details Defined in Raft.Log Methods put :: Putter (EntryValue v) # get :: Get (EntryValue v) #
(Typeable v, Serialize v) => FromField (EntryValue v) Source #
Instance details Defined in Raft.Log Methods fromField :: FieldParser (EntryValue v) #
Serialize v => ToField (EntryValue v) Source #
Instance details Defined in Raft.Log Methods toField :: EntryValue v -> Action #
type Rep (EntryValue v) Source #
Instance details Defined in Raft.Log type Rep (EntryValue v) = D1 (MetaData "EntryValue" "Raft.Log" "libraft-0.5.0.0-J9sQlo4v2xjSwCkwompQR" False) (C1 (MetaCons "EntryValue" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 v)) :+: C1 (MetaCons "NoValue" PrefixI False) (U1 :: Type -> Type))

newtype EntryHash Source #

Constructors

EntryHash
Fields unEntryHash :: ByteString

Instances

Eq EntryHash Source #
Instance details Defined in Raft.Log Methods (==) :: EntryHash -> EntryHash -> Bool # (/=) :: EntryHash -> EntryHash -> Bool #
Ord EntryHash Source #
Instance details Defined in Raft.Log Methods compare :: EntryHash -> EntryHash -> Ordering # (<) :: EntryHash -> EntryHash -> Bool # (<=) :: EntryHash -> EntryHash -> Bool # (>) :: EntryHash -> EntryHash -> Bool # (>=) :: EntryHash -> EntryHash -> Bool # max :: EntryHash -> EntryHash -> EntryHash # min :: EntryHash -> EntryHash -> EntryHash #
Read EntryHash Source #
Instance details Defined in Raft.Log Methods readsPrec :: Int -> ReadS EntryHash # readList :: ReadS [EntryHash] # readPrec :: ReadPrec EntryHash # readListPrec :: ReadPrec [EntryHash] #
Show EntryHash Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> EntryHash -> ShowS # show :: EntryHash -> String # showList :: [EntryHash] -> ShowS #
Generic EntryHash Source #
Instance details Defined in Raft.Log Associated Types type Rep EntryHash :: Type -> Type # Methods from :: EntryHash -> Rep EntryHash x # to :: Rep EntryHash x -> EntryHash #
Serialize EntryHash Source #
Instance details Defined in Raft.Log Methods put :: Putter EntryHash # get :: Get EntryHash #
FromField EntryHash Source #
Instance details Defined in Raft.Log Methods fromField :: FieldParser EntryHash #
ToField EntryHash Source #
Instance details Defined in Raft.Log Methods toField :: EntryHash -> Action #
type Rep EntryHash Source #
Instance details Defined in Raft.Log type Rep EntryHash = D1 (MetaData "EntryHash" "Raft.Log" "libraft-0.5.0.0-J9sQlo4v2xjSwCkwompQR" True) (C1 (MetaCons "EntryHash" PrefixI True) (S1 (MetaSel (Just "unEntryHash") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 ByteString)))

genesisHash :: EntryHash Source #

hashEntry :: Serialize v => Entry v -> EntryHash Source #

data Entry v Source #

Representation of an entry in the replicated log

Constructors

Entry
Fields entryIndex :: Index Index of entry in the log entryTerm :: Term Term when entry was received by leader entryValue :: EntryValue v Command to update state machine entryIssuer :: EntryIssuer Id of the client that issued the command entryPrevHash :: EntryHash

Instances

Eq v => Eq (Entry v) Source #
Instance details Defined in Raft.Log Methods (==) :: Entry v -> Entry v -> Bool # (/=) :: Entry v -> Entry v -> Bool #
Show v => Show (Entry v) Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> Entry v -> ShowS # show :: Entry v -> String # showList :: [Entry v] -> ShowS #
Generic (Entry v) Source #
Instance details Defined in Raft.Log Associated Types type Rep (Entry v) :: Type -> Type # Methods from :: Entry v -> Rep (Entry v) x # to :: Rep (Entry v) x -> Entry v #
Serialize v => Serialize (Entry v) Source #
Instance details Defined in Raft.Log Methods put :: Putter (Entry v) # get :: Get (Entry v) #
type Rep (Entry v) Source #
Instance details Defined in Raft.Log type Rep (Entry v) = D1 (MetaData "Entry" "Raft.Log" "libraft-0.5.0.0-J9sQlo4v2xjSwCkwompQR" False) (C1 (MetaCons "Entry" PrefixI True) ((S1 (MetaSel (Just "entryIndex") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Index) :: S1 (MetaSel (Just "entryTerm") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Term)) :: (S1 (MetaSel (Just "entryValue") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (EntryValue v)) :: (S1 (MetaSel (Just "entryIssuer") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EntryIssuer) :: S1 (MetaSel (Just "entryPrevHash") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 EntryHash)))))

type Entries v = Seq (Entry v) Source #

lastEntryIndex :: Entries v -> Maybe Index Source #

data LastLogEntry v Source #

The datatype representing a node's last log entry

Constructors

LastLogEntry (Entry v)
NoLogEntries

Instances

Show v => Show (LastLogEntry v) Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> LastLogEntry v -> ShowS # show :: LastLogEntry v -> String # showList :: [LastLogEntry v] -> ShowS #

hashLastLogEntry :: Serialize v => LastLogEntry v -> EntryHash Source #

lastLogEntryIndex :: LastLogEntry v -> Index Source #

lastLogEntryIssuer :: LastLogEntry v -> Maybe EntryIssuer Source #

lastLogEntryTerm :: LastLogEntry v -> Term Source #

lastLogEntryIndexAndTerm :: LastLogEntry v -> (Index, Term) Source #

class RaftInitLog m v where Source #

Provides an interface to initialize a fresh log entry storage

Associated Types

type RaftInitLogError m Source #

Methods

initializeLog :: Proxy v -> m (Either (RaftInitLogError m) ()) Source #

Instances

MonadIO m => RaftInitLog (RaftPostgresT m) v Source #
Instance details Defined in Raft.Log.PostgreSQL Associated Types type RaftInitLogError (RaftPostgresT m) :: Type Source # Methods initializeLog :: Proxy v -> RaftPostgresT m (Either (RaftInitLogError (RaftPostgresT m)) ()) Source #
(MonadIO m, RaftInitLog m v) => RaftInitLog (RaftPersistFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Persistent Associated Types type RaftInitLogError (RaftPersistFileStoreT m) :: Type Source # Methods initializeLog :: Proxy v -> RaftPersistFileStoreT m (Either (RaftInitLogError (RaftPersistFileStoreT m)) ()) Source #
(Serialize v, MonadIO m) => RaftInitLog (RaftLogFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Log Associated Types type RaftInitLogError (RaftLogFileStoreT m) :: Type Source # Methods initializeLog :: Proxy v -> RaftLogFileStoreT m (Either (RaftInitLogError (RaftLogFileStoreT m)) ()) Source #
(MonadIO m, RaftInitLog m v) => RaftInitLog (RaftSocketT sm v m) v Source #
Instance details Defined in Examples.Raft.Socket.Node Associated Types type RaftInitLogError (RaftSocketT sm v m) :: Type Source # Methods initializeLog :: Proxy v -> RaftSocketT sm v m (Either (RaftInitLogError (RaftSocketT sm v m)) ()) Source #

data ReadEntriesSpec Source #

Constructors

ByIndex Index
ByIndices IndexInterval

Instances

Show ReadEntriesSpec Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> ReadEntriesSpec -> ShowS # show :: ReadEntriesSpec -> String # showList :: [ReadEntriesSpec] -> ShowS #
Generic ReadEntriesSpec Source #
Instance details Defined in Raft.Log Associated Types type Rep ReadEntriesSpec :: Type -> Type # Methods from :: ReadEntriesSpec -> Rep ReadEntriesSpec x # to :: Rep ReadEntriesSpec x -> ReadEntriesSpec #
Serialize ReadEntriesSpec Source #
Instance details Defined in Raft.Log Methods put :: Putter ReadEntriesSpec # get :: Get ReadEntriesSpec #
type Rep ReadEntriesSpec Source #
Instance details Defined in Raft.Log type Rep ReadEntriesSpec = D1 (MetaData "ReadEntriesSpec" "Raft.Log" "libraft-0.5.0.0-J9sQlo4v2xjSwCkwompQR" False) (C1 (MetaCons "ByIndex" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Index)) :+: C1 (MetaCons "ByIndices" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 IndexInterval)))

data ReadEntriesRes v Source #

The result of reading one or more

Constructors

OneEntry (Entry v)
ManyEntries (Entries v)

data IndexInterval Source #

Constructors

IndexInterval (Maybe Index) (Maybe Index)

Instances

Show IndexInterval Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> IndexInterval -> ShowS # show :: IndexInterval -> String # showList :: [IndexInterval] -> ShowS #
Generic IndexInterval Source #
Instance details Defined in Raft.Log Associated Types type Rep IndexInterval :: Type -> Type # Methods from :: IndexInterval -> Rep IndexInterval x # to :: Rep IndexInterval x -> IndexInterval #
Serialize IndexInterval Source #
Instance details Defined in Raft.Log Methods put :: Putter IndexInterval # get :: Get IndexInterval #
type Rep IndexInterval Source #
Instance details Defined in Raft.Log type Rep IndexInterval = D1 (MetaData "IndexInterval" "Raft.Log" "libraft-0.5.0.0-J9sQlo4v2xjSwCkwompQR" False) (C1 (MetaCons "IndexInterval" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Index)) :*: S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 (Maybe Index))))

class (Show (RaftReadLogError m), Monad m) => RaftReadLog m v where Source #

Provides an interface for nodes to read log entries from storage.

Minimal complete definition

readLogEntry, readLastLogEntry

Associated Types

type RaftReadLogError m Source #

Methods

readLogEntry :: Exception (RaftReadLogError m) => Index -> m (Either (RaftReadLogError m) (Maybe (Entry v))) Source #

Read the log at a given index

readLogEntriesFrom :: Exception (RaftReadLogError m) => Index -> m (Either (RaftReadLogError m) (Entries v)) Source #

Read log entries from a specific index onwards, including the specific index

readLastLogEntry :: Exception (RaftReadLogError m) => m (Either (RaftReadLogError m) (Maybe (Entry v))) Source #

Read the last log entry in the log

readLogEntriesFrom :: Exception (RaftReadLogError m) => Index -> m (Either (RaftReadLogError m) (Entries v)) Source #

Read log entries from a specific index onwards, including the specific index

Instances

(Typeable v, Serialize v, MonadIO m) => RaftReadLog (RaftPostgresT m) v Source #
Instance details Defined in Raft.Log.PostgreSQL Associated Types type RaftReadLogError (RaftPostgresT m) :: Type Source # Methods readLogEntry :: Index -> RaftPostgresT m (Either (RaftReadLogError (RaftPostgresT m)) (Maybe (Entry v))) Source # readLogEntriesFrom :: Index -> RaftPostgresT m (Either (RaftReadLogError (RaftPostgresT m)) (Entries v)) Source # readLastLogEntry :: RaftPostgresT m (Either (RaftReadLogError (RaftPostgresT m)) (Maybe (Entry v))) Source #
RaftReadLog m v => RaftReadLog (RaftPersistFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Persistent Associated Types type RaftReadLogError (RaftPersistFileStoreT m) :: Type Source # Methods readLogEntry :: Index -> RaftPersistFileStoreT m (Either (RaftReadLogError (RaftPersistFileStoreT m)) (Maybe (Entry v))) Source # readLogEntriesFrom :: Index -> RaftPersistFileStoreT m (Either (RaftReadLogError (RaftPersistFileStoreT m)) (Entries v)) Source # readLastLogEntry :: RaftPersistFileStoreT m (Either (RaftReadLogError (RaftPersistFileStoreT m)) (Maybe (Entry v))) Source #
(MonadIO m, Serialize v) => RaftReadLog (RaftLogFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Log Associated Types type RaftReadLogError (RaftLogFileStoreT m) :: Type Source # Methods readLogEntry :: Index -> RaftLogFileStoreT m (Either (RaftReadLogError (RaftLogFileStoreT m)) (Maybe (Entry v))) Source # readLogEntriesFrom :: Index -> RaftLogFileStoreT m (Either (RaftReadLogError (RaftLogFileStoreT m)) (Entries v)) Source # readLastLogEntry :: RaftLogFileStoreT m (Either (RaftReadLogError (RaftLogFileStoreT m)) (Maybe (Entry v))) Source #
RaftReadLog m v => RaftReadLog (RaftSocketT sm v m) v Source #
Instance details Defined in Examples.Raft.Socket.Node Associated Types type RaftReadLogError (RaftSocketT sm v m) :: Type Source # Methods readLogEntry :: Index -> RaftSocketT sm v m (Either (RaftReadLogError (RaftSocketT sm v m)) (Maybe (Entry v))) Source # readLogEntriesFrom :: Index -> RaftSocketT sm v m (Either (RaftReadLogError (RaftSocketT sm v m)) (Entries v)) Source # readLastLogEntry :: RaftSocketT sm v m (Either (RaftReadLogError (RaftSocketT sm v m)) (Maybe (Entry v))) Source #

class (Show (RaftWriteLogError m), Monad m) => RaftWriteLog m v where Source #

Provides an interface for nodes to write log entries to storage.

Associated Types

type RaftWriteLogError m Source #

Methods

writeLogEntries :: Exception (RaftWriteLogError m) => Entries v -> m (Either (RaftWriteLogError m) ()) Source #

Write the given log entries to storage

Instances

(Serialize v, MonadIO m) => RaftWriteLog (RaftPostgresT m) v Source #
Instance details Defined in Raft.Log.PostgreSQL Associated Types type RaftWriteLogError (RaftPostgresT m) :: Type Source # Methods writeLogEntries :: Entries v -> RaftPostgresT m (Either (RaftWriteLogError (RaftPostgresT m)) ()) Source #
RaftWriteLog m v => RaftWriteLog (RaftPersistFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Persistent Associated Types type RaftWriteLogError (RaftPersistFileStoreT m) :: Type Source # Methods writeLogEntries :: Entries v -> RaftPersistFileStoreT m (Either (RaftWriteLogError (RaftPersistFileStoreT m)) ()) Source #
(MonadIO m, Serialize v) => RaftWriteLog (RaftLogFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Log Associated Types type RaftWriteLogError (RaftLogFileStoreT m) :: Type Source # Methods writeLogEntries :: Entries v -> RaftLogFileStoreT m (Either (RaftWriteLogError (RaftLogFileStoreT m)) ()) Source #
RaftWriteLog m v => RaftWriteLog (RaftSocketT sm v m) v Source #
Instance details Defined in Examples.Raft.Socket.Node Associated Types type RaftWriteLogError (RaftSocketT sm v m) :: Type Source # Methods writeLogEntries :: Entries v -> RaftSocketT sm v m (Either (RaftWriteLogError (RaftSocketT sm v m)) ()) Source #

class (Show (RaftDeleteLogError m), Monad m) => RaftDeleteLog m v where Source #

Provides an interface for nodes to delete log entries from storage.

Associated Types

type RaftDeleteLogError m Source #

Methods

deleteLogEntriesFrom :: Exception (RaftDeleteLogError m) => Index -> m (Either (RaftDeleteLogError m) (DeleteSuccess v)) Source #

Delete log entries from a given index; e.g. 'deleteLogEntriesFrom 7' should delete every log entry with an index >= 7.

Instances

(Serialize v, MonadIO m) => RaftDeleteLog (RaftPostgresT m) v Source #
Instance details Defined in Raft.Log.PostgreSQL Associated Types type RaftDeleteLogError (RaftPostgresT m) :: Type Source # Methods deleteLogEntriesFrom :: Index -> RaftPostgresT m (Either (RaftDeleteLogError (RaftPostgresT m)) (DeleteSuccess v)) Source #
RaftDeleteLog m v => RaftDeleteLog (RaftPersistFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Persistent Associated Types type RaftDeleteLogError (RaftPersistFileStoreT m) :: Type Source # Methods deleteLogEntriesFrom :: Index -> RaftPersistFileStoreT m (Either (RaftDeleteLogError (RaftPersistFileStoreT m)) (DeleteSuccess v)) Source #
(MonadIO m, Serialize v) => RaftDeleteLog (RaftLogFileStoreT m) v Source #
Instance details Defined in Examples.Raft.FileStore.Log Associated Types type RaftDeleteLogError (RaftLogFileStoreT m) :: Type Source # Methods deleteLogEntriesFrom :: Index -> RaftLogFileStoreT m (Either (RaftDeleteLogError (RaftLogFileStoreT m)) (DeleteSuccess v)) Source #
RaftDeleteLog m v => RaftDeleteLog (RaftSocketT sm v m) v Source #
Instance details Defined in Examples.Raft.Socket.Node Associated Types type RaftDeleteLogError (RaftSocketT sm v m) :: Type Source # Methods deleteLogEntriesFrom :: Index -> RaftSocketT sm v m (Either (RaftDeleteLogError (RaftSocketT sm v m)) (DeleteSuccess v)) Source #

data DeleteSuccess v Source #

Constructors

DeleteSuccess

type RaftLog m v = (RaftInitLog m v, RaftReadLog m v, RaftWriteLog m v, RaftDeleteLog m v) Source #

data RaftLogError m Source #

Representation of possible errors that come from reading, writing or deleting logs from the persistent storage

Instances

Show (RaftLogError m) Source #
Instance details Defined in Raft.Log Methods showsPrec :: Int -> RaftLogError m -> ShowS # show :: RaftLogError m -> String # showList :: [RaftLogError m] -> ShowS #

type RaftLogExceptions m = (Exception (RaftInitLogError m), Exception (RaftReadLogError m), Exception (RaftWriteLogError m), Exception (RaftDeleteLogError m)) Source #

updateLog :: forall m v. (RaftDeleteLog m v, Exception (RaftDeleteLogError m), RaftWriteLog m v, Exception (RaftWriteLogError m)) => Entries v -> m (Either (RaftLogError m) (Maybe Index)) Source #

clientReqData :: Entries v -> Map ClientId (SerialNum, Index) Source #

readEntries :: forall m v. (RaftReadLog m v, Exception (RaftReadLogError m)) => ReadEntriesSpec -> m (Either (ReadEntriesError m) (ReadEntriesRes v)) Source #