System.Nix.Store.Remote

Documentation

data RepairMode

Repair mode

Constructors

RepairMode_DoRepair

RepairMode_DontRepair

Instances

Bounded RepairMode

Defined in System.Nix.Store.Types

Methods

minBound :: RepairMode

maxBound :: RepairMode

Enum RepairMode

Defined in System.Nix.Store.Types

Methods

succ :: RepairMode -> RepairMode

pred :: RepairMode -> RepairMode

toEnum :: Int -> RepairMode

fromEnum :: RepairMode -> Int

enumFrom :: RepairMode -> [RepairMode]

enumFromThen :: RepairMode -> RepairMode -> [RepairMode]

enumFromTo :: RepairMode -> RepairMode -> [RepairMode]

enumFromThenTo :: RepairMode -> RepairMode -> RepairMode -> [RepairMode]

Generic RepairMode

Defined in System.Nix.Store.Types

Associated Types

type Rep RepairMode :: Type -> Type

Methods

from :: RepairMode -> Rep RepairMode x

to :: Rep RepairMode x -> RepairMode

Show RepairMode

Defined in System.Nix.Store.Types

Methods

showsPrec :: Int -> RepairMode -> ShowS

show :: RepairMode -> String

showList :: [RepairMode] -> ShowS

Eq RepairMode

Defined in System.Nix.Store.Types

Methods

(==) :: RepairMode -> RepairMode -> Bool

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

Ord RepairMode

Defined in System.Nix.Store.Types

Methods

compare :: RepairMode -> RepairMode -> Ordering

(<) :: RepairMode -> RepairMode -> Bool

(<=) :: RepairMode -> RepairMode -> Bool

(>) :: RepairMode -> RepairMode -> Bool

(>=) :: RepairMode -> RepairMode -> Bool

max :: RepairMode -> RepairMode -> RepairMode

min :: RepairMode -> RepairMode -> RepairMode

type Rep RepairMode

Defined in System.Nix.Store.Types

type Rep RepairMode = D1 ('MetaData "RepairMode" "System.Nix.Store.Types" "hnix-store-core-0.8.0.0-KoQ0hVKi7ckChERuSTExWl" 'False) (C1 ('MetaCons "RepairMode_DoRepair" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "RepairMode_DontRepair" 'PrefixI 'False) (U1 :: Type -> Type))

data FileIngestionMethod

Add path recursively or not

Constructors

FileIngestionMethod_Flat

FileIngestionMethod_FileRecursive

Instances

Bounded FileIngestionMethod

Defined in System.Nix.Store.Types

Methods

minBound :: FileIngestionMethod

maxBound :: FileIngestionMethod

Enum FileIngestionMethod

Defined in System.Nix.Store.Types

Methods

succ :: FileIngestionMethod -> FileIngestionMethod

pred :: FileIngestionMethod -> FileIngestionMethod

toEnum :: Int -> FileIngestionMethod

fromEnum :: FileIngestionMethod -> Int

enumFrom :: FileIngestionMethod -> [FileIngestionMethod]

enumFromThen :: FileIngestionMethod -> FileIngestionMethod -> [FileIngestionMethod]

enumFromTo :: FileIngestionMethod -> FileIngestionMethod -> [FileIngestionMethod]

enumFromThenTo :: FileIngestionMethod -> FileIngestionMethod -> FileIngestionMethod -> [FileIngestionMethod]

Generic FileIngestionMethod

Defined in System.Nix.Store.Types

Associated Types

type Rep FileIngestionMethod :: Type -> Type

Methods

from :: FileIngestionMethod -> Rep FileIngestionMethod x

to :: Rep FileIngestionMethod x -> FileIngestionMethod

Show FileIngestionMethod

Defined in System.Nix.Store.Types

Methods

showsPrec :: Int -> FileIngestionMethod -> ShowS

show :: FileIngestionMethod -> String

showList :: [FileIngestionMethod] -> ShowS

Eq FileIngestionMethod

Defined in System.Nix.Store.Types

Methods

(==) :: FileIngestionMethod -> FileIngestionMethod -> Bool

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

Ord FileIngestionMethod

Defined in System.Nix.Store.Types

Methods

compare :: FileIngestionMethod -> FileIngestionMethod -> Ordering

(<) :: FileIngestionMethod -> FileIngestionMethod -> Bool

(<=) :: FileIngestionMethod -> FileIngestionMethod -> Bool

(>) :: FileIngestionMethod -> FileIngestionMethod -> Bool

(>=) :: FileIngestionMethod -> FileIngestionMethod -> Bool

max :: FileIngestionMethod -> FileIngestionMethod -> FileIngestionMethod

min :: FileIngestionMethod -> FileIngestionMethod -> FileIngestionMethod

type Rep FileIngestionMethod

Defined in System.Nix.Store.Types

type Rep FileIngestionMethod = D1 ('MetaData "FileIngestionMethod" "System.Nix.Store.Types" "hnix-store-core-0.8.0.0-KoQ0hVKi7ckChERuSTExWl" 'False) (C1 ('MetaCons "FileIngestionMethod_Flat" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "FileIngestionMethod_FileRecursive" 'PrefixI 'False) (U1 :: Type -> Type))

module System.Nix.Store.Remote.Client

class (MonadIO m, MonadError RemoteStoreError m) => MonadRemoteStore m where

Minimal complete definition

Nothing

Methods

appendLog :: Logger -> m ()

default appendLog :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => Logger -> m ()

getConfig :: m ProtoStoreConfig

default getConfig :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m ProtoStoreConfig

getStoreDir :: m StoreDir

default getStoreDir :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m StoreDir

setStoreDir :: StoreDir -> m ()

default setStoreDir :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => StoreDir -> m ()

getProtoVersion :: m ProtoVersion

Get ProtoVersion from state

default getProtoVersion :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m ProtoVersion

setProtoVersion :: ProtoVersion -> m ()

default setProtoVersion :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => ProtoVersion -> m ()

getStoreSocket :: m Socket

default getStoreSocket :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m Socket

setNarSource :: NarSource IO -> m ()

default setNarSource :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => NarSource IO -> m ()

takeNarSource :: m (Maybe (NarSource IO))

default takeNarSource :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> m ()

default setDataSource :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => (Word64 -> IO (Maybe ByteString)) -> m ()

takeDataSource :: m (Maybe (Word64 -> IO (Maybe ByteString)))

default takeDataSource :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: m (Maybe (Word64 -> IO (Maybe ByteString)))

default getDataSource :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: m ()

default clearDataSource :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m ()

setDataSink :: (ByteString -> IO ()) -> m ()

default setDataSink :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => (ByteString -> IO ()) -> m ()

getDataSink :: m (Maybe (ByteString -> IO ()))

default getDataSink :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m (Maybe (ByteString -> IO ()))

clearDataSink :: m ()

default clearDataSink :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m ()

setDataSinkSize :: Word64 -> m ()

default setDataSinkSize :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => Word64 -> m ()

getDataSinkSize :: m (Maybe Word64)

default getDataSinkSize :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m (Maybe Word64)

clearDataSinkSize :: m ()

default clearDataSinkSize :: (MonadTrans t, MonadRemoteStore m', m ~ t m') => m ()

Instances

MonadIO m => MonadRemoteStore (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

appendLog :: Logger -> RemoteStoreT m ()

getConfig :: RemoteStoreT m ProtoStoreConfig

getStoreDir :: RemoteStoreT m StoreDir

setStoreDir :: StoreDir -> RemoteStoreT m ()

getProtoVersion :: RemoteStoreT m ProtoVersion

setProtoVersion :: ProtoVersion -> RemoteStoreT m ()

getStoreSocket :: RemoteStoreT m Socket

setNarSource :: NarSource IO -> RemoteStoreT m ()

takeNarSource :: RemoteStoreT m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> RemoteStoreT m ()

takeDataSource :: RemoteStoreT m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: RemoteStoreT m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: RemoteStoreT m ()

setDataSink :: (ByteString -> IO ()) -> RemoteStoreT m ()

getDataSink :: RemoteStoreT m (Maybe (ByteString -> IO ()))

clearDataSink :: RemoteStoreT m ()

setDataSinkSize :: Word64 -> RemoteStoreT m ()

getDataSinkSize :: RemoteStoreT m (Maybe Word64)

clearDataSinkSize :: RemoteStoreT m ()

MonadRemoteStore m => MonadRemoteStore (ExceptT RemoteStoreError m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

appendLog :: Logger -> ExceptT RemoteStoreError m ()

getConfig :: ExceptT RemoteStoreError m ProtoStoreConfig

getStoreDir :: ExceptT RemoteStoreError m StoreDir

setStoreDir :: StoreDir -> ExceptT RemoteStoreError m ()

getProtoVersion :: ExceptT RemoteStoreError m ProtoVersion

setProtoVersion :: ProtoVersion -> ExceptT RemoteStoreError m ()

getStoreSocket :: ExceptT RemoteStoreError m Socket

setNarSource :: NarSource IO -> ExceptT RemoteStoreError m ()

takeNarSource :: ExceptT RemoteStoreError m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> ExceptT RemoteStoreError m ()

takeDataSource :: ExceptT RemoteStoreError m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: ExceptT RemoteStoreError m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: ExceptT RemoteStoreError m ()

setDataSink :: (ByteString -> IO ()) -> ExceptT RemoteStoreError m ()

getDataSink :: ExceptT RemoteStoreError m (Maybe (ByteString -> IO ()))

clearDataSink :: ExceptT RemoteStoreError m ()

setDataSinkSize :: Word64 -> ExceptT RemoteStoreError m ()

getDataSinkSize :: ExceptT RemoteStoreError m (Maybe Word64)

clearDataSinkSize :: ExceptT RemoteStoreError m ()

MonadRemoteStore m => MonadRemoteStore (ReaderT r m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

appendLog :: Logger -> ReaderT r m ()

getConfig :: ReaderT r m ProtoStoreConfig

getStoreDir :: ReaderT r m StoreDir

setStoreDir :: StoreDir -> ReaderT r m ()

getProtoVersion :: ReaderT r m ProtoVersion

setProtoVersion :: ProtoVersion -> ReaderT r m ()

getStoreSocket :: ReaderT r m Socket

setNarSource :: NarSource IO -> ReaderT r m ()

takeNarSource :: ReaderT r m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> ReaderT r m ()

takeDataSource :: ReaderT r m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: ReaderT r m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: ReaderT r m ()

setDataSink :: (ByteString -> IO ()) -> ReaderT r m ()

getDataSink :: ReaderT r m (Maybe (ByteString -> IO ()))

clearDataSink :: ReaderT r m ()

setDataSinkSize :: Word64 -> ReaderT r m ()

getDataSinkSize :: ReaderT r m (Maybe Word64)

clearDataSinkSize :: ReaderT r m ()

MonadRemoteStore m => MonadRemoteStore (StateT s m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

appendLog :: Logger -> StateT s m ()

getConfig :: StateT s m ProtoStoreConfig

getStoreDir :: StateT s m StoreDir

setStoreDir :: StoreDir -> StateT s m ()

getProtoVersion :: StateT s m ProtoVersion

setProtoVersion :: ProtoVersion -> StateT s m ()

getStoreSocket :: StateT s m Socket

setNarSource :: NarSource IO -> StateT s m ()

takeNarSource :: StateT s m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> StateT s m ()

takeDataSource :: StateT s m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: StateT s m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: StateT s m ()

setDataSink :: (ByteString -> IO ()) -> StateT s m ()

getDataSink :: StateT s m (Maybe (ByteString -> IO ()))

clearDataSink :: StateT s m ()

setDataSinkSize :: Word64 -> StateT s m ()

getDataSinkSize :: StateT s m (Maybe Word64)

clearDataSinkSize :: StateT s m ()

data RemoteStoreT m a

Instances

MonadTrans RemoteStoreT

Defined in System.Nix.Store.Remote.MonadStore

Methods

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

Monad m => MonadError RemoteStoreError (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

throwError :: RemoteStoreError -> RemoteStoreT m a

catchError :: RemoteStoreT m a -> (RemoteStoreError -> RemoteStoreT m a) -> RemoteStoreT m a

Monad m => MonadReader Socket (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

ask :: RemoteStoreT m Socket

local :: (Socket -> Socket) -> RemoteStoreT m a -> RemoteStoreT m a

reader :: (Socket -> a) -> RemoteStoreT m a

MonadIO m => MonadIO (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

liftIO :: IO a -> RemoteStoreT m a

Monad m => Applicative (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

pure :: a -> RemoteStoreT m a

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

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

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

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

Functor m => Functor (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

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

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

Monad m => Monad (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

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

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

return :: a -> RemoteStoreT m a

MonadCatch m => MonadCatch (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

catch :: (HasCallStack, Exception e) => RemoteStoreT m a -> (e -> RemoteStoreT m a) -> RemoteStoreT m a

MonadMask m => MonadMask (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

mask :: HasCallStack => ((forall a. RemoteStoreT m a -> RemoteStoreT m a) -> RemoteStoreT m b) -> RemoteStoreT m b

uninterruptibleMask :: HasCallStack => ((forall a. RemoteStoreT m a -> RemoteStoreT m a) -> RemoteStoreT m b) -> RemoteStoreT m b

generalBracket :: HasCallStack => RemoteStoreT m a -> (a -> ExitCase b -> RemoteStoreT m c) -> (a -> RemoteStoreT m b) -> RemoteStoreT m (b, c)

MonadThrow m => MonadThrow (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

throwM :: (HasCallStack, Exception e) => e -> RemoteStoreT m a

MonadIO m => MonadRemoteStore (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

appendLog :: Logger -> RemoteStoreT m ()

getConfig :: RemoteStoreT m ProtoStoreConfig

getStoreDir :: RemoteStoreT m StoreDir

setStoreDir :: StoreDir -> RemoteStoreT m ()

getProtoVersion :: RemoteStoreT m ProtoVersion

setProtoVersion :: ProtoVersion -> RemoteStoreT m ()

getStoreSocket :: RemoteStoreT m Socket

setNarSource :: NarSource IO -> RemoteStoreT m ()

takeNarSource :: RemoteStoreT m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> RemoteStoreT m ()

takeDataSource :: RemoteStoreT m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: RemoteStoreT m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: RemoteStoreT m ()

setDataSink :: (ByteString -> IO ()) -> RemoteStoreT m ()

getDataSink :: RemoteStoreT m (Maybe (ByteString -> IO ()))

clearDataSink :: RemoteStoreT m ()

setDataSinkSize :: Word64 -> RemoteStoreT m ()

getDataSinkSize :: RemoteStoreT m (Maybe Word64)

clearDataSinkSize :: RemoteStoreT m ()

data RemoteStoreError

Constructors

RemoteStoreError_GetAddrInfoFailed

Instances

Show RemoteStoreError

Defined in System.Nix.Store.Remote.MonadStore

Methods

showsPrec :: Int -> RemoteStoreError -> ShowS

show :: RemoteStoreError -> String

showList :: [RemoteStoreError] -> ShowS

Monad m => MonadError RemoteStoreError (RemoteStoreT m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

throwError :: RemoteStoreError -> RemoteStoreT m a

catchError :: RemoteStoreT m a -> (RemoteStoreError -> RemoteStoreT m a) -> RemoteStoreT m a

MonadRemoteStore m => MonadRemoteStore (ExceptT RemoteStoreError m)

Defined in System.Nix.Store.Remote.MonadStore

Methods

appendLog :: Logger -> ExceptT RemoteStoreError m ()

getConfig :: ExceptT RemoteStoreError m ProtoStoreConfig

getStoreDir :: ExceptT RemoteStoreError m StoreDir

setStoreDir :: StoreDir -> ExceptT RemoteStoreError m ()

getProtoVersion :: ExceptT RemoteStoreError m ProtoVersion

setProtoVersion :: ProtoVersion -> ExceptT RemoteStoreError m ()

getStoreSocket :: ExceptT RemoteStoreError m Socket

setNarSource :: NarSource IO -> ExceptT RemoteStoreError m ()

takeNarSource :: ExceptT RemoteStoreError m (Maybe (NarSource IO))

setDataSource :: (Word64 -> IO (Maybe ByteString)) -> ExceptT RemoteStoreError m ()

takeDataSource :: ExceptT RemoteStoreError m (Maybe (Word64 -> IO (Maybe ByteString)))

getDataSource :: ExceptT RemoteStoreError m (Maybe (Word64 -> IO (Maybe ByteString)))

clearDataSource :: ExceptT RemoteStoreError m ()

setDataSink :: (ByteString -> IO ()) -> ExceptT RemoteStoreError m ()

getDataSink :: ExceptT RemoteStoreError m (Maybe (ByteString -> IO ()))

clearDataSink :: ExceptT RemoteStoreError m ()

setDataSinkSize :: Word64 -> ExceptT RemoteStoreError m ()

getDataSinkSize :: ExceptT RemoteStoreError m (Maybe Word64)

clearDataSinkSize :: ExceptT RemoteStoreError m ()

runRemoteStoreT :: Monad m => Socket -> RemoteStoreT m a -> m (Either RemoteStoreError a, DList Logger)

Runner for RemoteStoreT

module System.Nix.Store.Remote.Types

Compat

type MonadStore = RemoteStoreT IO

Runners

runStore :: (MonadIO m, MonadMask m) => RemoteStoreT m a -> Run m a

runStoreConnection :: (MonadIO m, MonadMask m) => StoreConnection -> RemoteStoreT m a -> Run m a

runStoreSocket :: (MonadIO m, MonadMask m) => Family -> SockAddr -> RemoteStoreT m a -> Run m a

Daemon

runDaemon :: forall m a. (MonadIO m, MonadConc m) => WorkerHelper m -> m a -> m a

runDaemonConnection :: forall m a. (MonadIO m, MonadConc m) => WorkerHelper m -> RemoteStoreT m () -> StoreConnection -> m a -> m a

Run an emulated nix daemon using given StoreConnection the deamon will close when the continuation returns.

justdoit :: Run IO (Bool, Bool)