Contract.Backend.Ogmios.Mempool

acquireMempoolSnapshot :: MempoolM MempoolSnapshotAcquired

mempoolSnapshotHasTx :: MempoolSnapshotAcquired -> TransactionHash -> MempoolM Boolean

mempoolSnapshotNextTx :: MempoolSnapshotAcquired -> MempoolM (Maybe Transaction)

fetchMempoolTxs :: MempoolSnapshotAcquired -> MempoolM (Array Transaction)

Recursively request the next TX in the mempool until Ogmios does not respond with a new TX.

mempoolSnapshotSizeAndCapacity :: MempoolSnapshotAcquired -> MempoolM MempoolSizeAndCapacity

releaseMempool :: MempoolSnapshotAcquired -> MempoolM Unit

withMempoolSnapshot :: forall a. (MempoolSnapshotAcquired -> MempoolM a) -> MempoolM a

A bracket-style function for working with mempool snapshots - ensures release in the presence of exceptions

type MempoolEnv = { customLogger :: Maybe (LogLevel -> Message -> Aff Unit), logLevel :: LogLevel, ogmiosWs :: OgmiosWebSocket, suppressLogs :: Boolean }

Instances

• MonadAsk MempoolEnv (MempoolMT Aff)

newtype MempoolMT :: (Type -> Type) -> Type -> Typenewtype MempoolMT (m :: Type -> Type) (a :: Type)

Constructors

• MempoolMT (ReaderT MempoolEnv m a)

Instances

• Newtype (MempoolMT m a) _
• (Functor m) => Functor (MempoolMT m)
• (Apply m) => Apply (MempoolMT m)
• (Applicative m) => Applicative (MempoolMT m)
• (Bind m) => Bind (MempoolMT m)
• Monad (MempoolMT Aff)
• MonadEffect (MempoolMT Aff)
• MonadAff (MempoolMT Aff)
• MonadThrow Error (MempoolMT Aff)
• MonadError Error (MempoolMT Aff)
• MonadAsk MempoolEnv (MempoolMT Aff)

type MempoolM = MempoolMT Aff