Haskoin.Store.Cache

Documentation

data CacheConfig

Constructors

CacheConfig

Fields

• redis :: !Connection
• minAddrs :: !Int
• maxKeys :: !Integer
• chain :: !Chain
• metrics :: !(Maybe CacheMetrics)

Instances

StoreReadBase m => StoreReadBase (CacheT m)

Defined in Haskoin.Store.Cache

Methods

getNetwork :: CacheT m Network

getCtx :: CacheT m Ctx

getBestBlock :: CacheT m (Maybe BlockHash)

getBlocksAtHeight :: BlockHeight -> CacheT m [BlockHash]

getBlock :: BlockHash -> CacheT m (Maybe BlockData)

getTxData :: TxHash -> CacheT m (Maybe TxData)

getSpender :: OutPoint -> CacheT m (Maybe Spender)

getBalance :: Address -> CacheT m (Maybe Balance)

getUnspent :: OutPoint -> CacheT m (Maybe Unspent)

getMempool :: CacheT m [(UnixTime, TxHash)]

(MonadUnliftIO m, MonadLoggerIO m, StoreReadExtra m) => StoreReadExtra (CacheT m)

Defined in Haskoin.Store.Cache

Methods

getAddressesTxs :: [Address] -> Limits -> CacheT m [TxRef]

getAddressesUnspents :: [Address] -> Limits -> CacheT m [Unspent]

getInitialGap :: CacheT m Word32

getMaxGap :: CacheT m Word32

getNumTxData :: Word64 -> CacheT m [TxData]

getBalances :: [Address] -> CacheT m [Balance]

getAddressTxs :: Address -> Limits -> CacheT m [TxRef]

getAddressUnspents :: Address -> Limits -> CacheT m [Unspent]

xPubBals :: XPubSpec -> CacheT m [XPubBal]

xPubUnspents :: XPubSpec -> [XPubBal] -> Limits -> CacheT m [XPubUnspent]

xPubTxs :: XPubSpec -> [XPubBal] -> Limits -> CacheT m [TxRef]

xPubTxCount :: XPubSpec -> [XPubBal] -> CacheT m Word32

data CacheMetrics

type CacheT = ReaderT (Maybe CacheConfig)

data CacheError

Constructors

RedisError Reply

RedisTxError !String

LogicError !String

Instances

Exception CacheError

Defined in Haskoin.Store.Cache

Methods

toException :: CacheError -> SomeException

fromException :: SomeException -> Maybe CacheError

displayException :: CacheError -> String

Generic CacheError

Defined in Haskoin.Store.Cache

Associated Types

type Rep CacheError

Defined in Haskoin.Store.Cache

type Rep CacheError = D1 ('MetaData "CacheError" "Haskoin.Store.Cache" "haskoin-store-1.5.2-6xk1JM3ODnjA6ROuFFQjxz" 'False) (C1 ('MetaCons "RedisError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Reply)) :+: (C1 ('MetaCons "RedisTxError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 String)) :+: C1 ('MetaCons "LogicError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 String))))

Methods

from :: CacheError -> Rep CacheError x

to :: Rep CacheError x -> CacheError

Show CacheError

Defined in Haskoin.Store.Cache

Methods

showsPrec :: Int -> CacheError -> ShowS

show :: CacheError -> String

showList :: [CacheError] -> ShowS

NFData CacheError

Defined in Haskoin.Store.Cache

Methods

rnf :: CacheError -> ()

Eq CacheError

Defined in Haskoin.Store.Cache

Methods

(==) :: CacheError -> CacheError -> Bool

(/=) :: CacheError -> CacheError -> Bool

type Rep CacheError

Defined in Haskoin.Store.Cache

type Rep CacheError = D1 ('MetaData "CacheError" "Haskoin.Store.Cache" "haskoin-store-1.5.2-6xk1JM3ODnjA6ROuFFQjxz" 'False) (C1 ('MetaCons "RedisError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Reply)) :+: (C1 ('MetaCons "RedisTxError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 String)) :+: C1 ('MetaCons "LogicError" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 String))))

newCacheMetrics :: MonadLoggerIO m => Stats -> Connection -> DatabaseReader -> m CacheMetrics

withCache :: Maybe CacheConfig -> CacheT m a -> m a

connectRedis :: MonadIO m => String -> m Connection

blockRefScore :: BlockRef -> Double

scoreBlockRef :: Double -> BlockRef

type CacheWriter = Mailbox CacheWriterMessage

type CacheWriterInbox = Inbox CacheWriterMessage

cacheNewBlock :: MonadIO m => CacheWriter -> m ()

cacheNewTx :: MonadIO m => TxHash -> CacheWriter -> m ()

cacheSyncMempool :: MonadIO m => CacheWriter -> m ()

cacheWriter :: (MonadUnliftIO m, MonadLoggerIO m, StoreReadExtra m) => CacheConfig -> CacheWriterInbox -> m ()

cacheDelXPubs :: forall (m :: Type -> Type). (MonadLoggerIO m, StoreReadBase m) => [XPubSpec] -> CacheT m Integer

isInCache :: forall (m :: Type -> Type). MonadLoggerIO m => XPubSpec -> CacheT m Bool