Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- txSubmissionInbound :: forall txid tx idx m. ( Ord txid, NoThunks txid, NoThunks tx, MonadSTM m, MonadThrow m) => Tracer m ( TraceTxSubmissionInbound txid tx) -> Word16 -> TxSubmissionMempoolReader txid tx idx m -> TxSubmissionMempoolWriter txid tx idx m -> NodeToNodeVersion -> TxSubmissionServerPipelined txid tx m ()
-
data
TxSubmissionMempoolWriter
txid tx idx m =
TxSubmissionMempoolWriter
{
- txId :: tx -> txid
- mempoolAddTxs :: [tx] -> m [txid]
- data TraceTxSubmissionInbound txid tx
- data TxSubmissionProtocolError
-
data
ProcessedTxCount
=
ProcessedTxCount
{
- ptxcAccepted :: Int
- ptxcRejected :: Int
Documentation
:: forall txid tx idx m. ( Ord txid, NoThunks txid, NoThunks tx, MonadSTM m, MonadThrow m) | |
=> Tracer m ( TraceTxSubmissionInbound txid tx) | |
-> Word16 |
Maximum number of unacknowledged txids allowed |
-> TxSubmissionMempoolReader txid tx idx m | |
-> TxSubmissionMempoolWriter txid tx idx m | |
-> NodeToNodeVersion | |
-> TxSubmissionServerPipelined txid tx m () |
data TxSubmissionMempoolWriter txid tx idx m Source #
The consensus layer functionality that the inbound side of the tx submission logic requires.
This is provided to the tx submission logic by the consensus layer.
TxSubmissionMempoolWriter | |
|
data TraceTxSubmissionInbound txid tx Source #
TraceTxSubmissionCollected Int |
Number of transactions just about to be inserted. |
TraceTxSubmissionProcessed ProcessedTxCount |
Just processed transaction pass/fail breakdown. |
TraceTxInboundTerminated |
Server received
|
TraceTxInboundCanRequestMoreTxs Int | |
TraceTxInboundCannotRequestMoreTxs Int |
Instances
Eq ( TraceTxSubmissionInbound txid tx) Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound (==) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool Source # (/=) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool Source # |
|
Show ( TraceTxSubmissionInbound txid tx) Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound |
data TxSubmissionProtocolError Source #
Instances
data ProcessedTxCount Source #
ProcessedTxCount | |
|
Instances
Eq ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound (==) :: ProcessedTxCount -> ProcessedTxCount -> Bool Source # (/=) :: ProcessedTxCount -> ProcessedTxCount -> Bool Source # |
|
Show ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound |