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

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

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 (ReaderT WebConfig m)

Defined in Haskoin.Store.Web

Methods

getNetwork :: ReaderT WebConfig m Network

getBestBlock :: ReaderT WebConfig m (Maybe BlockHash)

getBlocksAtHeight :: BlockHeight -> ReaderT WebConfig m [BlockHash]

getBlock :: BlockHash -> ReaderT WebConfig m (Maybe BlockData)

getTxData :: TxHash -> ReaderT WebConfig m (Maybe TxData)

getSpender :: OutPoint -> ReaderT WebConfig m (Maybe Spender)

getBalance :: Address -> ReaderT WebConfig m (Maybe Balance)

getUnspent :: OutPoint -> ReaderT WebConfig m (Maybe Unspent)

getMempool :: ReaderT WebConfig m [(UnixTime, TxHash)]

class StoreReadBase m => StoreReadExtra m where

Minimal complete definition

getAddressesTxs, getAddressesUnspents, getMaxGap, getInitialGap

Methods

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

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

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

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

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

xPubBals :: XPubSpec -> m [XPubBal]

xPubSummary :: XPubSpec -> m XPubSummary

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

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

getMaxGap :: m Word32

getInitialGap :: m Word32

Instances

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

Defined in Haskoin.Store.Cache

Methods

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

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

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

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

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

xPubBals :: XPubSpec -> CacheT m [XPubBal]

xPubSummary :: XPubSpec -> CacheT m XPubSummary

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

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

getMaxGap :: CacheT m Word32

getInitialGap :: CacheT m Word32

MonadIO m => StoreReadExtra (DatabaseReaderT m)

Defined in Haskoin.Store.Database.Reader

Methods

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

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

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

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

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

xPubBals :: XPubSpec -> DatabaseReaderT m [XPubBal]

xPubSummary :: XPubSpec -> DatabaseReaderT m XPubSummary

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

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

getMaxGap :: DatabaseReaderT m Word32

getInitialGap :: DatabaseReaderT m Word32

(MonadUnliftIO m, MonadLoggerIO m) => StoreReadExtra (ReaderT WebConfig m)

Defined in Haskoin.Store.Web

Methods

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

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

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

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

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

xPubBals :: XPubSpec -> ReaderT WebConfig m [XPubBal]

xPubSummary :: XPubSpec -> ReaderT WebConfig m XPubSummary

xPubUnspents :: XPubSpec -> Limits -> ReaderT WebConfig m [XPubUnspent]

xPubTxs :: XPubSpec -> Limits -> ReaderT WebConfig m [TxRef]

getMaxGap :: ReaderT WebConfig m Word32

getInitialGap :: ReaderT WebConfig m Word32

class StoreWrite m where

Methods

setBest :: BlockHash -> m ()

insertBlock :: BlockData -> m ()

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

insertTx :: TxData -> m ()

insertSpender :: OutPoint -> Spender -> m ()

deleteSpender :: OutPoint -> 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 ()

insertSpender :: OutPoint -> Spender -> WriterT m ()

deleteSpender :: OutPoint -> 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

StorePeerConnected !Peer

StorePeerDisconnected !Peer

StorePeerPong !Peer !Word64

StoreTxAvailable !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

Serialize PubExcept

Defined in Haskoin.Store.Common

Methods

put :: Putter PubExcept

get :: Get PubExcept

NFData PubExcept

Defined in Haskoin.Store.Common

Methods

rnf :: PubExcept -> ()

type Rep PubExcept

Defined in Haskoin.Store.Common

type Rep PubExcept = D1 ('MetaData "PubExcept" "Haskoin.Store.Common" "haskoin-store-0.40.7-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)))

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

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

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

getSpenders :: StoreReadBase m => TxHash -> m (IntMap Spender)

xPubBalsTxs :: StoreReadExtra m => [XPubBal] -> Limits -> m [TxRef]

xPubBalsUnspents :: StoreReadExtra m => [XPubBal] -> Limits -> m [XPubUnspent]

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

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

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

deOffset :: Limits -> Limits

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

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

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

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

microseconds :: MonadIO m => m Integer