Network.Riak.CRDT

CRDT operations

• Haskell-side
  • Haskell values: Counter, Set etc
  • ADT for operations: CounterOp, SetOp etc
  • modify to locally modify a value (matching riak behaviour)

• Riak-side
  • get to get a current value
  • sendModify to ask Riak to apply modifications

TL;DR example

>>> let c = Counter 41
>>> let op = CounterInc 1
>>> modify op c
Counter 42
>>> get conn "counters" "bucket" "key"
Just (DTCounter (Counter 41))
>>> sendModify conn "counters" "bucket" "key" [op] >> get conn "counters" "bucket" "key"
Just (DTCounter (Counter 42))

Documentation

module Network.Riak.CRDT.Types

get :: Connection -> BucketType -> Bucket -> Key -> IO (Maybe DataType)

class MapCRDT a => CRDT a op | a -> op, op -> a where

CRDT types

Methods

modify :: op -> a -> a

Modify a value by applying an operation

sendModify :: Connection -> BucketType -> Bucket -> Key -> [op] -> IO ()

Request riak a modification

Instances

CRDT Counter CounterOp

CRDT Set SetOp

CRDT Map MapOp