System.Nix.Store.Remote.MonadStore

Documentation

data RemoteStoreState

Constructors

RemoteStoreState

Fields

• remoteStoreStateConfig :: ProtoStoreConfig
• remoteStoreStateLogs :: DList Logger
• remoteStoreStateMDataSource :: Maybe (Word64 -> IO (Maybe ByteString))

  Source for Logger_Read, this will be called repeatedly as the daemon requests chunks of size Word64. If the function returns Nothing and daemon tries to read more data an error is thrown. Used by AddToStoreNar and ImportPaths operations.

• remoteStoreStateMDataSink :: Maybe (ByteString -> IO ())

  Sink for Logger_Write, called repeatedly by the daemon to dump us some data. Used by ExportPath operation.

• remoteStoreStateMDataSinkSize :: Maybe Word64

  Byte length to be written to the sink, for NarForPath

• remoteStoreStateMNarSource :: Maybe (NarSource IO)

Instances

HasStoreDir RemoteStoreState

Defined in System.Nix.Store.Remote.MonadStore

Methods

hasStoreDir :: RemoteStoreState -> StoreDir

HasProtoVersion RemoteStoreState

Defined in System.Nix.Store.Remote.MonadStore

Methods

hasProtoVersion :: RemoteStoreState -> ProtoVersion

data RemoteStoreError

Constructors

RemoteStoreError_Fixme String

RemoteStoreError_BuildFailed

RemoteStoreError_ClientVersionTooOld

RemoteStoreError_DerivationParse String

RemoteStoreError_Disconnected

RemoteStoreError_GetAddrInfoFailed

RemoteStoreError_GenericIncrementalLeftovers String ByteString

RemoteStoreError_GenericIncrementalFail String ByteString

RemoteStoreError_SerializerGet SError

RemoteStoreError_SerializerHandshake HandshakeSError

RemoteStoreError_SerializerLogger LoggerSError

RemoteStoreError_SerializerPut SError

RemoteStoreError_SerializerRequest RequestSError

RemoteStoreError_SerializerReply ReplySError

RemoteStoreError_IOException SomeException

RemoteStoreError_LoggerError (Either BasicError ErrorInfo)

RemoteStoreError_LoggerLeftovers String ByteString

RemoteStoreError_LoggerParserFail String ByteString

RemoteStoreError_NoDataSourceProvided

RemoteStoreError_DataSourceExhausted

RemoteStoreError_DataSourceZeroLengthRead

RemoteStoreError_DataSourceReadTooLarge

RemoteStoreError_NoDataSinkProvided

RemoteStoreError_NoDataSinkSizeProvided

RemoteStoreError_NoNarSourceProvided

RemoteStoreError_OperationFailed

RemoteStoreError_ProtocolMismatch

RemoteStoreError_RapairNotSupportedByRemoteStore

RemoteStoreError_WorkerMagic2Mismatch

RemoteStoreError_WorkerError WorkerError

RemoteStoreError_WorkerException WorkerException

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 ()

data WorkerError

Non-fatal (to server) errors in worker interaction

Constructors

WorkerError_SendClosed

WorkerError_InvalidOperation Word64

WorkerError_NotYetImplemented

WorkerError_UnsupportedOperation

Instances

Show WorkerError

Defined in System.Nix.Store.Remote.MonadStore

Methods

showsPrec :: Int -> WorkerError -> ShowS

show :: WorkerError -> String

showList :: [WorkerError] -> ShowS

Eq WorkerError

Defined in System.Nix.Store.Remote.MonadStore

Methods

(==) :: WorkerError -> WorkerError -> Bool

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

Ord WorkerError

Defined in System.Nix.Store.Remote.MonadStore

Methods

compare :: WorkerError -> WorkerError -> Ordering

(<) :: WorkerError -> WorkerError -> Bool

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

(>) :: WorkerError -> WorkerError -> Bool

(>=) :: WorkerError -> WorkerError -> Bool

max :: WorkerError -> WorkerError -> WorkerError

min :: WorkerError -> WorkerError -> WorkerError

data WorkerException

fatal error in worker interaction which should disconnect client.

Constructors

WorkerException_ClientVersionTooOld

WorkerException_ProtocolMismatch

WorkerException_Error WorkerError

allowed error outside allowed worker state | WorkerException_DecodingError DecodingError | WorkerException_BuildFailed StorePath

Instances

Show WorkerException

Defined in System.Nix.Store.Remote.MonadStore

Methods

showsPrec :: Int -> WorkerException -> ShowS

show :: WorkerException -> String

showList :: [WorkerException] -> ShowS

Eq WorkerException

Defined in System.Nix.Store.Remote.MonadStore

Methods

(==) :: WorkerException -> WorkerException -> Bool

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

Ord WorkerException

Defined in System.Nix.Store.Remote.MonadStore

Methods

compare :: WorkerException -> WorkerException -> Ordering

(<) :: WorkerException -> WorkerException -> Bool

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

(>) :: WorkerException -> WorkerException -> Bool

(>=) :: WorkerException -> WorkerException -> Bool

max :: WorkerException -> WorkerException -> WorkerException

min :: WorkerException -> WorkerException -> WorkerException

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 ()

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

Runner for RemoteStoreT

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 ()