Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Synopsis
- txSubmissionInbound ∷ ∀ 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 {}
Documentation
∷ ∀ 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
Show (TraceTxSubmissionInbound txid tx) Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound showsPrec ∷ Int → TraceTxSubmissionInbound txid tx → ShowS # show ∷ TraceTxSubmissionInbound txid tx → String # showList ∷ [TraceTxSubmissionInbound txid tx] → ShowS # | |
Eq (TraceTxSubmissionInbound txid tx) Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound (==) ∷ TraceTxSubmissionInbound txid tx → TraceTxSubmissionInbound txid tx → Bool # (/=) ∷ TraceTxSubmissionInbound txid tx → TraceTxSubmissionInbound txid tx → Bool # |
data ProcessedTxCount Source #
ProcessedTxCount | |
|
Instances
Show ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound showsPrec ∷ Int → ProcessedTxCount → ShowS # show ∷ ProcessedTxCount → String # showList ∷ [ProcessedTxCount] → ShowS # | |
Eq ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound |