Safe Haskell | None |
---|---|
Language | Haskell2010 |
Ouroboros.Network.TxSubmission.Inbound
Synopsis
- txSubmissionInbound :: forall txid tx idx (m :: Type -> Type). (Ord txid, NoThunks txid, NoThunks tx, MonadSTM m, MonadThrow m, MonadDelay m) => Tracer m (TraceTxSubmissionInbound txid tx) -> NumTxIdsToAck -> TxSubmissionMempoolReader txid tx idx m -> TxSubmissionMempoolWriter txid tx idx m -> NodeToNodeVersion -> TxSubmissionServerPipelined txid tx m ()
- data TxSubmissionMempoolWriter txid tx idx (m :: Type -> Type) = TxSubmissionMempoolWriter {
- txId :: tx -> txid
- mempoolAddTxs :: [tx] -> m [txid]
- data TraceTxSubmissionInbound txid tx
- data TxSubmissionProtocolError
- data ProcessedTxCount = ProcessedTxCount {
- ptxcAccepted :: Int
- ptxcRejected :: Int
Documentation
Arguments
:: forall txid tx idx (m :: Type -> Type). (Ord txid, NoThunks txid, NoThunks tx, MonadSTM m, MonadThrow m, MonadDelay m) | |
=> Tracer m (TraceTxSubmissionInbound txid tx) | |
-> NumTxIdsToAck | 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 :: Type -> Type) 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.
Constructors
TxSubmissionMempoolWriter | |
Fields
|
data TraceTxSubmissionInbound txid tx Source #
Constructors
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 Methods 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 Methods (==) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool # (/=) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool # |
data TxSubmissionProtocolError Source #
Instances
Exception TxSubmissionProtocolError Source # | |
Show TxSubmissionProtocolError Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound Methods showsPrec :: Int -> TxSubmissionProtocolError -> ShowS # show :: TxSubmissionProtocolError -> String # showList :: [TxSubmissionProtocolError] -> ShowS # |
data ProcessedTxCount Source #
Constructors
ProcessedTxCount | |
Fields
|
Instances
Show ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound Methods showsPrec :: Int -> ProcessedTxCount -> ShowS # show :: ProcessedTxCount -> String # showList :: [ProcessedTxCount] -> ShowS # | |
Eq ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound Methods (==) :: ProcessedTxCount -> ProcessedTxCount -> Bool # (/=) :: ProcessedTxCount -> ProcessedTxCount -> Bool # |