Cachix.Client.Push

Pushing a single path

pushSingleStorePath

Arguments

:: (MonadMask m, MonadIO m)

=> ClientEnv

cachix base url, connection manager, see defaultCachixBaseUrl, mkClientEnv

-> Store

-> PushCache

details for pushing to cache

-> PushStrategy m r

how to report results, (some) errors, and do some things

-> Text

store path

-> m r

r is determined by the PushStrategy

data PushCache

Constructors

PushCache

Fields

• pushCacheName :: Text
• pushCacheSigningKey :: SigningKey
• pushCacheToken :: Token

data PushStrategy m r

Constructors

PushStrategy

Fields

• onAlreadyPresent :: m r

  Called when a path is already in the cache.

• onAttempt :: RetryStatus -> Int64 -> m ()
• on401 :: m r
• onError :: ClientError -> m r
• onDone :: m r
• withXzipCompressor :: forall a. (ConduitM ByteString ByteString (ResourceT IO) () -> m a) -> m a
• omitDeriver :: Bool

defaultWithXzipCompressor :: forall m a. (ConduitM ByteString ByteString (ResourceT IO) () -> m a) -> m a

defaultWithXzipCompressorWithLevel :: Int -> forall m a. (ConduitM ByteString ByteString (ResourceT IO) () -> m a) -> m a

Pushing a closure of store paths

pushClosure

Arguments

:: (MonadIO m, MonadMask m)

=> (forall a b. (a -> m b) -> [a] -> m [b])

Traverse paths, responsible for bounding parallel processing of paths

For example: mapConcurrentlyBounded 4

-> ClientEnv

See pushSingleStorePath

-> Store

-> PushCache

-> (Text -> PushStrategy m r)

-> [Text]

Initial store paths

-> m [r]

Every r per store path of the entire closure of store paths

Push an entire closure

Note: onAlreadyPresent will be called less often in the future.

mapConcurrentlyBounded :: Traversable t => Int -> (a -> IO b) -> t a -> IO (t b)