Snap.Snaplet.Riak

A Snaplet for using the Riak database (via the riak package) Modelled on snaplet-postgresql-simple

Documentation

data RiakDB

Riak Snaplet state. Stores a connection pool shared between handlers.

withRiak :: HasRiak m => (Connection -> IO a) -> m a

Perform an action using a Riak Connection in the Riak snaplet

result <- withRiak $ \c -> get c "myBucket" "myKey" Default

riakInit :: Pool -> SnapletInit b RiakDB

Initialize the Riak snaplet

riakCreate :: Client -> Int -> NominalDiffTime -> Int -> SnapletInit b RiakDB

Thin wrapper around create to run within SnapletInit

class MonadIO m => HasRiak m where

A class which, when implemented, allows the wrapper functions below to be used without explicitly managing the connection and having to use liftIO.

Methods

getRiakState :: m RiakDB

get :: (HasRiak m, FromJSON a, ToJSON a, Resolvable a) => Bucket -> Key -> R -> m (Maybe (a, VClock))

getMany :: (HasRiak m, FromJSON a, ToJSON a, Resolvable a) => Bucket -> [Key] -> R -> m [Maybe (a, VClock)]

modify :: (HasRiak m, FromJSON a, ToJSON a, Resolvable a) => Bucket -> Key -> R -> W -> DW -> (Maybe a -> IO (a, b)) -> m (a, b)

modify_ :: (HasRiak m, FromJSON a, ToJSON a, Resolvable a) => Bucket -> Key -> R -> W -> DW -> (Maybe a -> IO a) -> m a

delete :: HasRiak m => Bucket -> Key -> RW -> m ()

put :: (HasRiak m, Eq a, FromJSON a, ToJSON a, Resolvable a) => Bucket -> Key -> Maybe VClock -> a -> W -> DW -> m (a, VClock)

putMany :: (HasRiak m, Eq a, FromJSON a, ToJSON a, Resolvable a) => Bucket -> [(Key, Maybe VClock, a)] -> W -> DW -> m [(a, VClock)]

listBuckets :: HasRiak m => m (Seq Bucket)

foldKeys :: HasRiak m => Bucket -> (a -> Key -> IO a) -> a -> m a

getBucket :: HasRiak m => Bucket -> m BucketProps

setBucket :: HasRiak m => Bucket -> BucketProps -> m ()

mapReduce :: HasRiak m => Job -> (a -> MapReduce -> a) -> a -> m a