Haskoin.Store.Common

Documentation

data Limits

Constructors

Limits

Fields

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

Instances

Eq Limits

Defined in Haskoin.Store.Common

Methods

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

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

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

data Start

Constructors

AtTx

Fields

• atTxHash :: !TxHash

AtBlock

Fields

• atBlockHeight :: !BlockHeight

Instances

Eq Start

Defined in Haskoin.Store.Common

Methods

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

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

Show Start

Defined in Haskoin.Store.Common

Methods

showsPrec :: Int -> Start -> ShowS

show :: Start -> String

showList :: [Start] -> ShowS

class Monad m => StoreReadBase m where

Methods

getNetwork :: m Network

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

MonadIO m => StoreReadBase (DatabaseReaderT m)

Defined in Haskoin.Store.Database.Reader

Methods

getNetwork :: DatabaseReaderT m Network

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

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

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

Defined in Haskoin.Store.Cache

Methods

getNetwork :: CacheT m Network

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

class StoreReadBase m => StoreReadExtra m 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 => 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

(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

class StoreWrite m 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

data PubExcept

Constructors

PubNoPeers

PubReject RejectCode

PubTimeout

PubPeerDisconnected

Instances

Eq PubExcept

Defined in Haskoin.Store.Common

Methods

(==) :: PubExcept -> PubExcept -> Bool

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

Show PubExcept

Defined in Haskoin.Store.Common

Methods

showsPrec :: Int -> PubExcept -> ShowS

show :: PubExcept -> String

showList :: [PubExcept] -> ShowS

Generic PubExcept

Defined in Haskoin.Store.Common

Associated Types

type Rep PubExcept :: Type -> Type

Methods

from :: PubExcept -> Rep PubExcept x

to :: Rep PubExcept x -> PubExcept

Exception PubExcept

Defined in Haskoin.Store.Common

Methods

toException :: PubExcept -> SomeException

fromException :: SomeException -> Maybe PubExcept

displayException :: PubExcept -> String

NFData PubExcept

Defined in Haskoin.Store.Common

Methods

rnf :: PubExcept -> ()

Serialize PubExcept

Defined in Haskoin.Store.Common

Methods

put :: Putter PubExcept

get :: Get PubExcept

type Rep PubExcept

Defined in Haskoin.Store.Common

type Rep PubExcept = D1 ('MetaData "PubExcept" "Haskoin.Store.Common" "haskoin-store-0.65.5-inplace" 'False) ((C1 ('MetaCons "PubNoPeers" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "PubReject" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 RejectCode))) :+: (C1 ('MetaCons "PubTimeout" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "PubPeerDisconnected" 'PrefixI 'False) (U1 :: Type -> Type)))

data DataMetrics

Constructors

DataMetrics

Fields

• dataBestCount :: !Counter
• dataBlockCount :: !Counter
• dataTxCount :: !Counter
• dataMempoolCount :: !Counter
• dataBalanceCount :: !Counter
• dataUnspentCount :: !Counter
• dataAddrTxCount :: !Counter
• dataXPubBals :: !Counter
• dataXPubUnspents :: !Counter
• dataXPubTxs :: !Counter
• dataXPubTxCount :: !Counter

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

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

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

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

getNumTransaction :: (Monad m, 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 :: DeriveType -> DeriveAddr

deOffset :: Limits -> Limits

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

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

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

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

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

nub' :: (Eq a, Hashable a) => [a] -> [a]

microseconds :: MonadIO m => m Integer

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

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

createDataMetrics :: MonadIO m => Store -> m DataMetrics