Safe Haskell	None
Language	GHC2024

Napkin.Run.Metadata.KVStore

Documentation

class (FromJSON payload, ToJSON payload, Ord key) => MetadataPayload key payload | key -> payload where #

Methods

Instances details

MetadataPayload SuccessfulTaskDuration SuccessfulTaskDurationInfo #
Instance details Defined in Napkin.Run.Metadata Methods keyText :: SuccessfulTaskDuration -> Text #
MetadataPayload TableLastRun LastRunInfo #
Instance details Defined in Napkin.Run.Metadata Methods keyText :: TableLastRun -> Text #
MetadataPayload TableLastSuccessfulRun LastSuccessfulRunInfo #
Instance details Defined in Napkin.Run.Metadata Methods keyText :: TableLastSuccessfulRun -> Text #

kvReadMany :: (MetadataPayload key payload, MonadIO m, Katip m) => KVS -> [key] -> m (Map key payload) #

kvRead :: (MetadataPayload key payload, MonadIO m, Katip m) => KVS -> key -> m (Maybe payload) #

kvWrite :: (MetadataPayload key payload, MonadIO m, Katip m) => KVS -> key -> payload -> m () #

kvUpdate :: (MetadataPayload key payload, MonadIO m, Katip m) => KVS -> key -> (Maybe payload -> payload) -> m () #

data KVS #

Constructors

KVS
Fields read :: forall key payload. MetadataPayload key payload => [key] -> IO (Map key payload) write :: forall key payload. MetadataPayload key payload => key -> payload -> IO ()

type InitKVS (m :: Type -> k) = m (KVS, IO ()) #

Constructors

KVSFile
Fields directory :: FilePath
KVSS3
Fields bucket :: BucketName prefix :: Text
KVSDummy

Instances details

FromJSON KVSConnectionString #
Instance details Defined in Napkin.Run.Metadata.KVStore Methods parseJSON :: Value -> Parser KVSConnectionString # parseJSONList :: Value -> Parser [KVSConnectionString] # omittedField :: Maybe KVSConnectionString #
Show KVSConnectionString #
Instance details Defined in Napkin.Run.Metadata.KVStore Methods showsPrec :: Int -> KVSConnectionString -> ShowS # show :: KVSConnectionString -> String # showList :: [KVSConnectionString] -> ShowS #
Eq KVSConnectionString #
Instance details Defined in Napkin.Run.Metadata.KVStore Methods (==) :: KVSConnectionString -> KVSConnectionString -> Bool # (/=) :: KVSConnectionString -> KVSConnectionString -> Bool #

withKVS :: (MonadIO m, MonadResource m) => InitKVS m -> (KVS -> m a) -> m a #