Haskoin.Store.Common

Documentation

data Limits

Constructors

Limits

Fields

• limit :: !Word32
• offset :: !Word32
• start :: !(Maybe Start)

Instances

Show Limits

Defined in Haskoin.Store.Common

Methods

showsPrec :: Int -> Limits -> ShowS

show :: Limits -> String

showList :: [Limits] -> ShowS

Default Limits

Defined in Haskoin.Store.Common

Methods

def :: Limits

Eq Limits

Defined in Haskoin.Store.Common

Methods

(==) :: Limits -> Limits -> Bool

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

data Start

Constructors

AtTx !TxHash

AtBlock !BlockHeight

Instances

Show Start

Defined in Haskoin.Store.Common

Methods

showsPrec :: Int -> Start -> ShowS

show :: Start -> String

showList :: [Start] -> ShowS

Eq Start

Defined in Haskoin.Store.Common

Methods

(==) :: Start -> Start -> Bool

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

class Monad m => StoreReadBase (m :: Type -> Type) where

Methods

getNetwork :: m Network

getCtx :: m Ctx

getBestBlock :: m (Maybe BlockHash)

getBlocksAtHeight :: BlockHeight -> m [BlockHash]

getBlock :: BlockHash -> m (Maybe BlockData)

getTxData :: TxHash -> m (Maybe TxData)

getSpender :: OutPoint -> m (Maybe Spender)

getBalance :: Address -> m (Maybe Balance)

getUnspent :: OutPoint -> m (Maybe Unspent)

getMempool :: m [(UnixTime, TxHash)]

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)]

MonadIO m => StoreReadBase (DatabaseReaderT m)

Defined in Haskoin.Store.Database.Reader

Methods

getNetwork :: DatabaseReaderT m Network

getCtx :: DatabaseReaderT m Ctx

getBestBlock :: DatabaseReaderT m (Maybe BlockHash)

getBlocksAtHeight :: BlockHeight -> DatabaseReaderT m [BlockHash]

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

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

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

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

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

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

MonadIO m => StoreReadBase (WriterT m)

Defined in Haskoin.Store.Database.Writer

Methods

getNetwork :: WriterT m Network

getCtx :: WriterT m Ctx

getBestBlock :: WriterT m (Maybe BlockHash)

getBlocksAtHeight :: BlockHeight -> WriterT m [BlockHash]

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

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

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

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

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

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

class StoreReadBase m => StoreReadExtra (m :: Type -> Type) where

Methods

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

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

getInitialGap :: m Word32

getMaxGap :: m Word32

getNumTxData :: Word64 -> m [TxData]

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

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

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

xPubBals :: XPubSpec -> m [XPubBal]

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

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

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

Instances

(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

MonadUnliftIO m => StoreReadExtra (DatabaseReaderT m)

Defined in Haskoin.Store.Database.Reader

Methods

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

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

getInitialGap :: DatabaseReaderT m Word32

getMaxGap :: DatabaseReaderT m Word32

getNumTxData :: Word64 -> DatabaseReaderT m [TxData]

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

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

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

xPubBals :: XPubSpec -> DatabaseReaderT m [XPubBal]

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

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

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

class StoreWrite (m :: Type -> Type) where

Methods

setBest :: BlockHash -> m ()

insertBlock :: BlockData -> m ()

setBlocksAtHeight :: [BlockHash] -> BlockHeight -> m ()

insertTx :: TxData -> m ()

insertAddrTx :: Address -> TxRef -> m ()

deleteAddrTx :: Address -> TxRef -> m ()

insertAddrUnspent :: Address -> Unspent -> m ()

deleteAddrUnspent :: Address -> Unspent -> m ()

addToMempool :: TxHash -> UnixTime -> m ()

deleteFromMempool :: TxHash -> m ()

setBalance :: Balance -> m ()

insertUnspent :: Unspent -> m ()

deleteUnspent :: OutPoint -> m ()

Instances

MonadIO m => StoreWrite (WriterT m)

Defined in Haskoin.Store.Database.Writer

Methods

setBest :: BlockHash -> WriterT m ()

insertBlock :: BlockData -> WriterT m ()

setBlocksAtHeight :: [BlockHash] -> BlockHeight -> WriterT m ()

insertTx :: TxData -> WriterT m ()

insertAddrTx :: Address -> TxRef -> WriterT m ()

deleteAddrTx :: Address -> TxRef -> WriterT m ()

insertAddrUnspent :: Address -> Unspent -> WriterT m ()

deleteAddrUnspent :: Address -> Unspent -> WriterT m ()

addToMempool :: TxHash -> UnixTime -> WriterT m ()

deleteFromMempool :: TxHash -> WriterT m ()

setBalance :: Balance -> WriterT m ()

insertUnspent :: Unspent -> WriterT m ()

deleteUnspent :: OutPoint -> WriterT m ()

data StoreEvent

Events that the store can generate.

Constructors

StoreBestBlock !BlockHash

StoreMempoolNew !TxHash

StoreMempoolDelete !TxHash

StorePeerConnected !Peer

StorePeerDisconnected !Peer

StorePeerPong !Peer !Word64

StoreTxAnnounce !Peer ![TxHash]

StoreTxReject !Peer !TxHash !RejectCode !ByteString

getActiveBlock :: StoreReadExtra m => BlockHash -> m (Maybe BlockData)

getActiveTxData :: StoreReadBase m => TxHash -> m (Maybe TxData)

getDefaultBalance :: StoreReadBase m => Address -> m Balance

getTransaction :: StoreReadBase m => TxHash -> m (Maybe Transaction)

getNumTransaction :: StoreReadExtra m => Word64 -> m [Transaction]

blockAtOrAfter :: (MonadIO m, StoreReadExtra m) => Chain -> UnixTime -> m (Maybe BlockData)

blockAtOrBefore :: (MonadIO m, StoreReadExtra m) => Chain -> UnixTime -> m (Maybe BlockData)

blockAtOrAfterMTP :: (MonadIO m, StoreReadExtra m) => Chain -> UnixTime -> m (Maybe BlockData)

xPubSummary :: XPubSpec -> [XPubBal] -> XPubSummary

deriveAddresses :: DeriveAddr -> XPubKey -> Word32 -> [(Word32, Address)]

deriveFunction :: Ctx -> DeriveType -> DeriveAddr

deOffset :: Limits -> Limits

applyLimits :: Limits -> [a] -> [a]

applyLimitsC :: forall (m :: Type -> Type) i. Monad m => Limits -> ConduitT i i m ()

applyLimit :: Limit -> [a] -> [a]

applyLimitC :: forall (m :: Type -> Type) i. Monad m => Limit -> ConduitT i i m ()

sortTxs :: [Tx] -> [(Word32, Tx)]

nub' :: Hashable a => [a] -> [a]

microseconds :: MonadIO m => m Integer

streamThings :: Monad m => (Limits -> m [a]) -> Maybe (a -> TxHash) -> Limits -> ConduitT () a m ()

joinDescStreams :: forall (m :: Type -> Type) a. (Monad m, Ord a) => [ConduitT () a m ()] -> ConduitT () a m ()