Ctl.Internal.QueryM.Ogmios.Mempool

data ReleasedMempool

Constructors

• ReleasedMempool

Instances

• Generic ReleasedMempool _
• Show ReleasedMempool
• DecodeAeson ReleasedMempool
• DecodeOgmios ReleasedMempool

newtype MempoolSizeAndCapacity

The acquired snapshot’s size (in bytes), number of transactions, and capacity (in bytes).

Constructors

• MempoolSizeAndCapacity { capacity :: Int, currentSize :: Int, numberOfTxs :: Int }

Instances

• Generic MempoolSizeAndCapacity _
• Newtype MempoolSizeAndCapacity _
• Show MempoolSizeAndCapacity
• DecodeAeson MempoolSizeAndCapacity
• DecodeOgmios MempoolSizeAndCapacity

newtype MempoolSnapshotAcquired

Instances

• Show MempoolSnapshotAcquired
• DecodeAeson MempoolSnapshotAcquired
• DecodeOgmios MempoolSnapshotAcquired

newtype MempoolTransaction

Constructors

• MempoolTransaction { id :: OgmiosTxId, raw :: String }

Instances

• Generic MempoolTransaction _
• Newtype MempoolTransaction _

newtype HasTxR

Constructors

• HasTxR Boolean

Instances

• Newtype HasTxR _
• DecodeOgmios HasTxR

newtype MaybeMempoolTransaction

Constructors

• MaybeMempoolTransaction (Maybe MempoolTransaction)

Instances

• DecodeAeson MaybeMempoolTransaction
• Newtype MaybeMempoolTransaction _
• DecodeOgmios MaybeMempoolTransaction

acquireMempoolSnapshotCall :: JsonRpc2Call Unit MempoolSnapshotAcquired

mempoolSnapshotHasTxCall :: MempoolSnapshotAcquired -> JsonRpc2Call TransactionHash HasTxR

mempoolSnapshotNextTxCall :: MempoolSnapshotAcquired -> JsonRpc2Call Unit MaybeMempoolTransaction

mempoolSnapshotSizeAndCapacityCall :: MempoolSnapshotAcquired -> JsonRpc2Call Unit MempoolSizeAndCapacity

releaseMempoolCall :: MempoolSnapshotAcquired -> JsonRpc2Call Unit ReleasedMempool

type ListenerSet (request :: Type) (response :: Type) = { addMessageListener :: ListenerId -> (Either OgmiosDecodeError response -> Effect Unit) -> Effect Unit, removeMessageListener :: ListenerId -> Effect Unit }

type OgmiosListeners = { acquireMempool :: ListenerSet Unit MempoolSnapshotAcquired, mempoolHasTx :: ListenerSet TransactionHash HasTxR, mempoolNextTx :: ListenerSet Unit MaybeMempoolTransaction, mempoolSizeAndCapacity :: ListenerSet Unit MempoolSizeAndCapacity, releaseMempool :: ListenerSet Unit ReleasedMempool }

type ListenerId = String

mkOgmiosCallType :: forall (a :: Type) (i :: Type) (o :: Type). EncodeAeson (JsonRpc2Request a) => DecodeOgmios o => { method :: String, params :: i -> a } -> JsonRpc2Call i o

type OgmiosWebSocket = WebSocket OgmiosListeners

data WebSocket listeners

Constructors

• WebSocket JsWebSocket listeners

listeners :: forall (listeners :: Type). WebSocket listeners -> listeners

mkListenerSet :: forall (request :: Type) (response :: Type). DecodeOgmios response => Dispatcher -> ListenerSet request response

defaultMessageListener :: Logger -> Array WebsocketDispatch -> String -> Effect Unit

mkOgmiosWebSocketAff :: Logger -> String -> Aff OgmiosWebSocket

mkRequestAff :: forall (request :: Type) (response :: Type) (listeners :: Type). listeners -> JsWebSocket -> Logger -> JsonRpc2Call request response -> (listeners -> ListenerSet request response) -> request -> Aff response

underlyingWebSocket :: forall (a :: Type). WebSocket a -> JsWebSocket