| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Ouroboros.Network.TxSubmission.Inbound.V1
Synopsis
- txSubmissionInbound :: forall txid tx idx (m :: Type -> Type) version. (Ord txid, NoThunks txid, NoThunks tx, MonadSTM m, MonadThrow m, MonadDelay m) => Tracer m (TraceTxSubmissionInbound txid tx) -> TxSubmissionInitDelay -> NumTxIdsToAck -> TxSubmissionMempoolReader txid tx idx m -> TxSubmissionMempoolWriter txid tx idx m -> version -> TxSubmissionServerPipelined txid tx m ()
- data TxSubmissionInitDelay
- data TxSubmissionMempoolWriter txid tx idx (m :: Type -> Type) = TxSubmissionMempoolWriter {
- txId :: tx -> txid
- mempoolAddTxs :: [tx] -> m [txid]
- data TraceTxSubmissionInbound txid tx
- = TraceTxSubmissionCollected [txid]
- | TraceTxSubmissionProcessed ProcessedTxCount
- | TraceTxInboundCanRequestMoreTxs Int
- | TraceTxInboundCannotRequestMoreTxs Int
- | TraceTxInboundAddedToMempool [txid] DiffTime
- | TraceTxInboundRejectedFromMempool [txid] DiffTime
- | TraceTxInboundError TxSubmissionProtocolError
- | TraceTxInboundTerminated
- | TraceTxInboundDecision (TxDecision txid tx)
- data TxSubmissionProtocolError
- = ProtocolErrorTxNotRequested
- | ProtocolErrorTxIdsNotRequested
- | (Typeable txid, Show txid, Eq txid) => ProtocolErrorTxSizeError [(txid, SizeInBytes, SizeInBytes)]
- data ProcessedTxCount = ProcessedTxCount {
- ptxcAccepted :: Int
- ptxcRejected :: Int
- ptxcScore :: Double
Documentation
Arguments
| :: forall txid tx idx (m :: Type -> Type) version. (Ord txid, NoThunks txid, NoThunks tx, MonadSTM m, MonadThrow m, MonadDelay m) | |
| => Tracer m (TraceTxSubmissionInbound txid tx) | |
| -> TxSubmissionInitDelay | |
| -> NumTxIdsToAck | Maximum number of unacknowledged txids allowed |
| -> TxSubmissionMempoolReader txid tx idx m | |
| -> TxSubmissionMempoolWriter txid tx idx m | |
| -> version | |
| -> TxSubmissionServerPipelined txid tx m () |
data TxSubmissionInitDelay Source #
Constructors
| TxSubmissionInitDelay DiffTime | |
| NoTxSubmissionInitDelay |
Instances
| Show TxSubmissionInitDelay Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods showsPrec :: Int -> TxSubmissionInitDelay -> ShowS # show :: TxSubmissionInitDelay -> String # showList :: [TxSubmissionInitDelay] -> ShowS # | |
| Eq TxSubmissionInitDelay Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: TxSubmissionInitDelay -> TxSubmissionInitDelay -> Bool # (/=) :: TxSubmissionInitDelay -> TxSubmissionInitDelay -> Bool # | |
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 [txid] | Number of transactions just about to be inserted. |
| TraceTxSubmissionProcessed ProcessedTxCount | Just processed transaction pass/fail breakdown. |
| TraceTxInboundCanRequestMoreTxs Int | |
| TraceTxInboundCannotRequestMoreTxs Int | |
| TraceTxInboundAddedToMempool [txid] DiffTime | |
| TraceTxInboundRejectedFromMempool [txid] DiffTime | |
| TraceTxInboundError TxSubmissionProtocolError | |
| TraceTxInboundTerminated | Server received |
| TraceTxInboundDecision (TxDecision txid tx) |
Instances
| (Show txid, Show tx) => Show (TraceTxSubmissionInbound txid tx) Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods showsPrec :: Int -> TraceTxSubmissionInbound txid tx -> ShowS # show :: TraceTxSubmissionInbound txid tx -> String # showList :: [TraceTxSubmissionInbound txid tx] -> ShowS # | |
| (Eq txid, Eq tx) => Eq (TraceTxSubmissionInbound txid tx) Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool # (/=) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool # | |
data TxSubmissionProtocolError Source #
Constructors
| ProtocolErrorTxNotRequested | |
| ProtocolErrorTxIdsNotRequested | |
| (Typeable txid, Show txid, Eq txid) => ProtocolErrorTxSizeError [(txid, SizeInBytes, SizeInBytes)] | a list of txid for which the received size and advertised size didn't match. |
Instances
data ProcessedTxCount Source #
Constructors
| ProcessedTxCount | |
Fields
| |
Instances
| Show ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods showsPrec :: Int -> ProcessedTxCount -> ShowS # show :: ProcessedTxCount -> String # showList :: [ProcessedTxCount] -> ShowS # | |
| Eq ProcessedTxCount Source # | |
Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: ProcessedTxCount -> ProcessedTxCount -> Bool # (/=) :: ProcessedTxCount -> ProcessedTxCount -> Bool # | |