Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.TxSubmission.Inbound.V1

Synopsis

Documentation

Arguments

:: forall txid tx idx (m :: Type -> Type) err 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 err
-> version
-> TxSubmissionServerPipelined txid tx m ()

Constructors

TxSubmissionInitDelay DiffTime
NoTxSubmissionInitDelay

Instances details

Show TxSubmissionInitDelay Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods showsPrec :: Int -> TxSubmissionInitDelay -> ShowS # show :: TxSubmissionInitDelay -> String # showList :: [TxSubmissionInitDelay] -> ShowS #
Eq TxSubmissionInitDelay Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: TxSubmissionInitDelay -> TxSubmissionInitDelay -> Bool # (/=) :: TxSubmissionInitDelay -> TxSubmissionInitDelay -> Bool #

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

Fields

txId :: tx -> txid
Compute the transaction id from a transaction.
This is used in the protocol handler to verify a full transaction matches a previously given transaction id.
mempoolAddTxs :: [tx] -> m ([txid], [(txid, err)])
Supply a batch of transactions to the mempool. They are either accepted or rejected individually, but in the order supplied.
Return list of valid tx's added to the mempool and a list of invalid tx's with the corresponding error.

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 `MsgDone`
TraceTxInboundDecision (TxDecision txid tx)

Instances details

(Show txid, Show tx) => Show (TraceTxSubmissionInbound txid tx) Source #
Instance details 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 #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool # (/=) :: TraceTxSubmissionInbound txid tx -> TraceTxSubmissionInbound txid tx -> Bool #

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 details

Exception TxSubmissionProtocolError Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods toException :: TxSubmissionProtocolError -> SomeException # fromException :: SomeException -> Maybe TxSubmissionProtocolError # displayException :: TxSubmissionProtocolError -> String # backtraceDesired :: TxSubmissionProtocolError -> Bool #
Show TxSubmissionProtocolError Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods showsPrec :: Int -> TxSubmissionProtocolError -> ShowS # show :: TxSubmissionProtocolError -> String # showList :: [TxSubmissionProtocolError] -> ShowS #
Eq TxSubmissionProtocolError Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: TxSubmissionProtocolError -> TxSubmissionProtocolError -> Bool # (/=) :: TxSubmissionProtocolError -> TxSubmissionProtocolError -> Bool #

Constructors

ProcessedTxCount
Fields ptxcAccepted :: Int Just accepted this many transactions. ptxcRejected :: Int Just rejected this many transactions. ptxcScore :: Double

Instances details

Show ProcessedTxCount Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods showsPrec :: Int -> ProcessedTxCount -> ShowS # show :: ProcessedTxCount -> String # showList :: [ProcessedTxCount] -> ShowS #
Eq ProcessedTxCount Source #
Instance details Defined in Ouroboros.Network.TxSubmission.Inbound.V2.Types Methods (==) :: ProcessedTxCount -> ProcessedTxCount -> Bool # (/=) :: ProcessedTxCount -> ProcessedTxCount -> Bool #