Change `LookupResult k v blob` to `LookupResult k v blobref`, making it independent of (table implementation specific) blobref. Similarly for `RangeLookupResult`
import qualified Data.Map.Strict as Map
import Database.LSMTree.Common (Range (..),
SomeSerialisationConstraint (..))
import Database.LSMTree.Normal (Update (..))
import Database.LSMTree.Normal (LookupResult (..),
RangeLookupResult (..), Update (..))
import GHC.Exts (IsList (..))
{-------------------------------------------------------------------------------
Table querying and updates
-------------------------------------------------------------------------------}
-- | Result of a single point lookup.
data LookupResult k v blob =
NotFound !k
| Found !k !v
| FoundWithBlob !k !v !(BlobRef blob)
deriving (Eq, Show)
-- Note: unfortunately we have to copy these types, as we need to implement BlobRef.
-- | Perform a batch of lookups.
--
-- Lookups can be performed concurrently from multiple Haskell threads.
lookups ::
(SomeSerialisationConstraint k, SomeSerialisationConstraint v)
=> [k]
-> Table k v blob
-> [LookupResult k v blob]
-> [LookupResult k v (BlobRef blob)]
lookups ks tbl =
[ case Map.lookup (serialise k) (_values tbl) of
Nothing -> NotFound k
| k <- ks
]
-- | A result for one point in a range lookup.
data RangeLookupResult k v blob =
FoundInRange !k !v
| FoundInRangeWithBlob !k !v !(BlobRef blob)
deriving (Eq, Show)
-- | Perform a range lookup.
--
-- Range lookups can be performed concurrently from multiple Haskell threads.
rangeLookup :: forall k v blob.
(SomeSerialisationConstraint k, SomeSerialisationConstraint v)
=> Range k
-> Table k v blob
-> [RangeLookupResult k v blob]
-> [RangeLookupResult k v (BlobRef blob)]
rangeLookup r tbl =
[ case v of
(v', Nothing) -> FoundInRange (deserialise k) (deserialise v')
-------------------------------------------------------------------------------}
-- | Result of a single point lookup.
data LookupResult k v blob =
data LookupResult k v blobref =
NotFound !k
| Found !k !v
| FoundWithBlob !k !v !(BlobRef blob)
| FoundWithBlob !k !v !blobref
deriving (Eq, Show)
-- | Perform a batch of lookups.
--
(IOLike m, SomeSerialisationConstraint k, SomeSerialisationConstraint v)
=> [k]
-> TableHandle m k v blob
-> m [LookupResult k v blob]
-> m [LookupResult k v (BlobRef blob)]
lookups = undefined
-- | A result for one point in a range lookup.
data RangeLookupResult k v blob =
data RangeLookupResult k v blobref =
FoundInRange !k !v
| FoundInRangeWithBlob !k !v !(BlobRef blob)
| FoundInRangeWithBlob !k !v !blobref
deriving (Eq, Show)
-- | Perform a range lookup.
--
(IOLike m, SomeSerialisationConstraint k, SomeSerialisationConstraint v)
=> Range k
-> TableHandle m k v blob
-> m [RangeLookupResult k v blob]
-> m [RangeLookupResult k v (BlobRef blob)]
rangeLookup = undefined
-- | Normal tables support insert and delete operations.
Alonzo builds
