Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.Protocol.TxSubmission2.Type

Description

The type of the transaction submission protocol.

This is used to relay transactions between nodes.

Synopsis

data TxSubmission2 txid tx where
- StInit :: forall txid tx. TxSubmission2 txid tx
- StIdle :: forall txid tx. TxSubmission2 txid tx
- StTxIds :: forall txid tx. StBlockingStyle -> TxSubmission2 txid tx
- StTxs :: forall txid tx. TxSubmission2 txid tx
- StDone :: forall txid tx. TxSubmission2 txid tx
data family Message ps (st :: ps) (st' :: ps)
data SingTxSubmission (k :: TxSubmission2 txid tx) where
- SingInit :: forall {txid} {tx}. SingTxSubmission ('StInit :: TxSubmission2 txid tx)
- SingIdle :: forall {txid} {tx}. SingTxSubmission ('StIdle :: TxSubmission2 txid tx)
- SingTxIds :: forall {txid} {tx} (stBlocking :: StBlockingStyle). SingBlockingStyle stBlocking -> SingTxSubmission ('StTxIds stBlocking :: TxSubmission2 txid tx)
- SingTxs :: forall {txid} {tx}. SingTxSubmission ('StTxs :: TxSubmission2 txid tx)
- SingDone :: forall {txid} {tx}. SingTxSubmission ('StDone :: TxSubmission2 txid tx)
data SingBlockingStyle (k :: StBlockingStyle) where
- SingBlocking :: SingBlockingStyle 'StBlocking
- SingNonBlocking :: SingBlockingStyle 'StNonBlocking
data StBlockingStyle where
- StBlocking :: StBlockingStyle
- StNonBlocking :: StBlockingStyle
data BlockingReplyList (blocking :: StBlockingStyle) a where
- BlockingReply :: forall a. NonEmpty a -> BlockingReplyList 'StBlocking a
- NonBlockingReply :: forall a. [a] -> BlockingReplyList 'StNonBlocking a
newtype NumTxIdsToAck = NumTxIdsToAck {
- getNumTxIdsToAck :: Word16
}
newtype NumTxIdsToReq = NumTxIdsToReq {
- getNumTxIdsToReq :: Word16
}
newtype SizeInBytes = SizeInBytes {
- getSizeInBytes :: Word32
}

Documentation

data TxSubmission2 txid tx where Source #

The kind of the transaction-submission protocol, and the types of the states in the protocol state machine.

We describe this protocol using the label "client" for the peer that is submitting transactions, and "server" for the one receiving them. The protocol is however pull based, so it is typically the server that has agency in this protocol. This is the opposite of the chain sync and block fetch protocols, but that makes sense because the information flow is also reversed: submitting transactions rather than receiving headers and blocks.

Because these client/server labels are somewhat confusing in this case, we sometimes clarify by using the terms inbound and outbound. This refers to whether transactions are flowing towards a peer or away, and thus indicates what role the peer is playing.

Constructors

StInit :: forall txid tx. TxSubmission2 txid tx	Initial protocol message.
StIdle :: forall txid tx. TxSubmission2 txid tx	The server (inbound side) has agency; it can either terminate, ask for transaction identifiers or ask for transactions. There is no timeout in this state.
StTxIds :: forall txid tx. StBlockingStyle -> TxSubmission2 txid tx	The client (outbound side) has agency; it must reply with a list of transaction identifiers that it wishes to submit. There are two sub-states for this, for blocking and non-blocking cases.
StTxs :: forall txid tx. TxSubmission2 txid tx	The client (outbound side) has agency; it must reply with the list of transactions.
StDone :: forall txid tx. TxSubmission2 txid tx	Nobody has agency; termination state.

Instances

Instances details

(ShowProxy txid, ShowProxy tx) => ShowProxy (TxSubmission2 txid tx :: Type) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

showProxy :: Proxy (TxSubmission2 txid tx) -> String #

Protocol (TxSubmission2 txid tx) Source #

There are some constraints of the protocol that are not captured in the types of the messages, but are documented with the messages. Violation of these constraints is also a protocol error. The constraints are intended to ensure that implementations are able to work in bounded space.

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Associated Types

type StateToken
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type type StateToken = SingTxSubmission :: TxSubmission2 txid tx -> Type

ShowProxy ('StIdle :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

showProxy :: Proxy ('StIdle :: TxSubmission2 txid tx) -> String #

StateTokenI ('StDone :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

stateToken :: StateToken ('StDone :: TxSubmission2 txid tx) #

StateTokenI ('StIdle :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

stateToken :: StateToken ('StIdle :: TxSubmission2 txid tx) #

StateTokenI ('StInit :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

stateToken :: StateToken ('StInit :: TxSubmission2 txid tx) #

StateTokenI ('StTxs :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

stateToken :: StateToken ('StTxs :: TxSubmission2 txid tx) #

SingI stBlocking => StateTokenI ('StTxIds stBlocking :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

stateToken :: StateToken ('StTxIds stBlocking :: TxSubmission2 txid tx) #

(NFData txid, NFData tx) => NFData (Message (TxSubmission2 txid tx) from to) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

rnf :: Message (TxSubmission2 txid tx) from to -> () #

(Show txid, Show tx) => Show (Message (TxSubmission2 txid tx) from to) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

showsPrec :: Int -> Message (TxSubmission2 txid tx) from to -> ShowS #

show :: Message (TxSubmission2 txid tx) from to -> String #

showList :: [Message (TxSubmission2 txid tx) from to] -> ShowS #

(Eq txid, Eq tx) => Eq (Message (TxSubmission2 txid tx) from to) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(==) :: Message (TxSubmission2 txid tx) from to -> Message (TxSubmission2 txid tx) from to -> Bool #

(/=) :: Message (TxSubmission2 txid tx) from to -> Message (TxSubmission2 txid tx) from to -> Bool #

data Message (TxSubmission2 txid tx) (from :: TxSubmission2 txid tx) (to :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

data Message (TxSubmission2 txid tx) (from :: TxSubmission2 txid tx) (to :: TxSubmission2 txid tx) where

MsgInit :: forall txid tx. Message (TxSubmission2 txid tx) ('StInit :: TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx)
MsgRequestTxIds :: forall (blocking :: StBlockingStyle) txid tx. SingBlockingStyle blocking -> NumTxIdsToAck -> NumTxIdsToReq -> Message (TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) ('StTxIds blocking :: TxSubmission2 txid tx)
MsgReplyTxIds :: forall (blocking :: StBlockingStyle) txid tx. BlockingReplyList blocking (txid, SizeInBytes) -> Message (TxSubmission2 txid tx) ('StTxIds blocking :: TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx)
MsgRequestTxs :: forall txid tx. [txid] -> Message (TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) ('StTxs :: TxSubmission2 txid tx)
MsgReplyTxs :: forall tx txid. [tx] -> Message (TxSubmission2 txid tx) ('StTxs :: TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx)
MsgDone :: forall txid tx. Message (TxSubmission2 txid tx) ('StTxIds 'StBlocking :: TxSubmission2 txid tx) ('StDone :: TxSubmission2 txid tx)

type StateToken Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type StateToken = SingTxSubmission :: TxSubmission2 txid tx -> Type

type StateAgency ('StDone :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type StateAgency ('StDone :: TxSubmission2 txid tx) = 'NobodyAgency

type StateAgency ('StIdle :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type StateAgency ('StIdle :: TxSubmission2 txid tx) = 'ServerAgency

type StateAgency ('StInit :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type StateAgency ('StInit :: TxSubmission2 txid tx) = 'ClientAgency

type StateAgency ('StTxs :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type StateAgency ('StTxs :: TxSubmission2 txid tx) = 'ClientAgency

type StateAgency ('StTxIds b :: TxSubmission2 txid tx) Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type StateAgency ('StTxIds b :: TxSubmission2 txid tx) = 'ClientAgency

data family Message ps (st :: ps) (st' :: ps) #

The messages for this protocol. It is expected to be a GADT that is indexed by the from and to protocol states. That is the protocol state the message transitions from, and the protocol state it transitions into. These are the edges of the protocol state transition system.

Instances

Instances details

(NFData block, NFData point) => NFData (Message (BlockFetch block point) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.BlockFetch.Type Methods rnf :: Message (BlockFetch block point) from to -> () #
(NFData header, NFData point, NFData tip) => NFData (Message (ChainSync header point tip) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.ChainSync.Type Methods rnf :: Message (ChainSync header point tip) from to -> () #
NFData (Message KeepAlive from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.KeepAlive.Type Methods rnf :: Message KeepAlive from to -> () #
(forall result. NFData (query result), NFData point) => NFData (Message (LocalStateQuery block point query) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalStateQuery.Type Methods rnf :: Message (LocalStateQuery block point query) from to -> () #
(NFData txid, NFData tx, NFData slot) => NFData (Message (LocalTxMonitor txid tx slot) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxMonitor.Type Methods rnf :: Message (LocalTxMonitor txid tx slot) from to -> () #
(NFData tx, NFData reject) => NFData (Message (LocalTxSubmission tx reject) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxSubmission.Type Methods rnf :: Message (LocalTxSubmission tx reject) from to -> () #
NFData peerAddress => NFData (Message (PeerSharing peerAddress) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.PeerSharing.Type Methods rnf :: Message (PeerSharing peerAddress) from to -> () #
(NFData txid, NFData tx) => NFData (Message (TxSubmission2 txid tx) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods rnf :: Message (TxSubmission2 txid tx) from to -> () #
(Show block, Show point) => Show (Message (BlockFetch block point) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.BlockFetch.Type Methods showsPrec :: Int -> Message (BlockFetch block point) from to -> ShowS # show :: Message (BlockFetch block point) from to -> String # showList :: [Message (BlockFetch block point) from to] -> ShowS #
(Show header, Show point, Show tip) => Show (Message (ChainSync header point tip) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.ChainSync.Type Methods showsPrec :: Int -> Message (ChainSync header point tip) from to -> ShowS # show :: Message (ChainSync header point tip) from to -> String # showList :: [Message (ChainSync header point tip) from to] -> ShowS #
Show (Message KeepAlive from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.KeepAlive.Type Methods showsPrec :: Int -> Message KeepAlive from to -> ShowS # show :: Message KeepAlive from to -> String # showList :: [Message KeepAlive from to] -> ShowS #
(Show txid, Show tx, Show slot) => Show (Message (LocalTxMonitor txid tx slot) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxMonitor.Type Methods showsPrec :: Int -> Message (LocalTxMonitor txid tx slot) from to -> ShowS # show :: Message (LocalTxMonitor txid tx slot) from to -> String # showList :: [Message (LocalTxMonitor txid tx slot) from to] -> ShowS #
(Show tx, Show reject) => Show (Message (LocalTxSubmission tx reject) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxSubmission.Type Methods showsPrec :: Int -> Message (LocalTxSubmission tx reject) from to -> ShowS # show :: Message (LocalTxSubmission tx reject) from to -> String # showList :: [Message (LocalTxSubmission tx reject) from to] -> ShowS #
Show peer => Show (Message (PeerSharing peer) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.PeerSharing.Type Methods showsPrec :: Int -> Message (PeerSharing peer) from to -> ShowS # show :: Message (PeerSharing peer) from to -> String # showList :: [Message (PeerSharing peer) from to] -> ShowS #
(Show txid, Show tx) => Show (Message (TxSubmission2 txid tx) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods showsPrec :: Int -> Message (TxSubmission2 txid tx) from to -> ShowS # show :: Message (TxSubmission2 txid tx) from to -> String # showList :: [Message (TxSubmission2 txid tx) from to] -> ShowS #
(Eq tx, Eq reject) => Eq (Message (LocalTxSubmission tx reject) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxSubmission.Type Methods (==) :: Message (LocalTxSubmission tx reject) from to -> Message (LocalTxSubmission tx reject) from to -> Bool # (/=) :: Message (LocalTxSubmission tx reject) from to -> Message (LocalTxSubmission tx reject) from to -> Bool #
(Eq txid, Eq tx) => Eq (Message (TxSubmission2 txid tx) from to) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods (==) :: Message (TxSubmission2 txid tx) from to -> Message (TxSubmission2 txid tx) from to -> Bool # (/=) :: Message (TxSubmission2 txid tx) from to -> Message (TxSubmission2 txid tx) from to -> Bool #
data Message KeepAlive (from :: KeepAlive) (to :: KeepAlive) Source #
Instance details Defined in Ouroboros.Network.Protocol.KeepAlive.Type data Message KeepAlive (from :: KeepAlive) (to :: KeepAlive) where MsgKeepAlive :: Cookie -> Message KeepAlive 'StClient 'StServer MsgKeepAliveResponse :: Cookie -> Message KeepAlive 'StServer 'StClient MsgDone :: Message KeepAlive 'StClient 'StDone
data Message (PeerSharing peerAddress) (from :: PeerSharing peerAddress) (to :: PeerSharing peerAddress) Source #
Instance details Defined in Ouroboros.Network.Protocol.PeerSharing.Type data Message (PeerSharing peerAddress) (from :: PeerSharing peerAddress) (to :: PeerSharing peerAddress) where MsgShareRequest :: forall peerAddress. PeerSharingAmount -> Message (PeerSharing peerAddress) ('StIdle :: PeerSharing peerAddress) ('StBusy :: PeerSharing peerAddress) MsgSharePeers :: forall peerAddress. [peerAddress] -> Message (PeerSharing peerAddress) ('StBusy :: PeerSharing peerAddress) ('StIdle :: PeerSharing peerAddress) MsgDone :: forall peerAddress. Message (PeerSharing peerAddress) ('StIdle :: PeerSharing peerAddress) ('StDone :: PeerSharing peerAddress)
data Message (BlockFetch block point) (from :: BlockFetch block point) (to :: BlockFetch block point) Source #
Instance details Defined in Ouroboros.Network.Protocol.BlockFetch.Type data Message (BlockFetch block point) (from :: BlockFetch block point) (to :: BlockFetch block point) where MsgRequestRange :: forall point block. ChainRange point -> Message (BlockFetch block point) ('BFIdle :: BlockFetch block point) ('BFBusy :: BlockFetch block point) MsgStartBatch :: forall block point. Message (BlockFetch block point) ('BFBusy :: BlockFetch block point) ('BFStreaming :: BlockFetch block point) MsgNoBlocks :: forall block point. Message (BlockFetch block point) ('BFBusy :: BlockFetch block point) ('BFIdle :: BlockFetch block point) MsgBlock :: forall block point. block -> Message (BlockFetch block point) ('BFStreaming :: BlockFetch block point) ('BFStreaming :: BlockFetch block point) MsgBatchDone :: forall block point. Message (BlockFetch block point) ('BFStreaming :: BlockFetch block point) ('BFIdle :: BlockFetch block point) MsgClientDone :: forall block point. Message (BlockFetch block point) ('BFIdle :: BlockFetch block point) ('BFDone :: BlockFetch block point)
data Message (LocalTxSubmission tx reject) (from :: LocalTxSubmission tx reject) (to :: LocalTxSubmission tx reject) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxSubmission.Type data Message (LocalTxSubmission tx reject) (from :: LocalTxSubmission tx reject) (to :: LocalTxSubmission tx reject) where MsgSubmitTx :: forall tx reject. tx -> Message (LocalTxSubmission tx reject) ('StIdle :: LocalTxSubmission tx reject) ('StBusy :: LocalTxSubmission tx reject) MsgAcceptTx :: forall tx reject. Message (LocalTxSubmission tx reject) ('StBusy :: LocalTxSubmission tx reject) ('StIdle :: LocalTxSubmission tx reject) MsgRejectTx :: forall reject tx. reject -> Message (LocalTxSubmission tx reject) ('StBusy :: LocalTxSubmission tx reject) ('StIdle :: LocalTxSubmission tx reject) MsgDone :: forall tx reject. Message (LocalTxSubmission tx reject) ('StIdle :: LocalTxSubmission tx reject) ('StDone :: LocalTxSubmission tx reject)
data Message (TxSubmission2 txid tx) (from :: TxSubmission2 txid tx) (to :: TxSubmission2 txid tx) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type data Message (TxSubmission2 txid tx) (from :: TxSubmission2 txid tx) (to :: TxSubmission2 txid tx) where MsgInit :: forall txid tx. Message (TxSubmission2 txid tx) ('StInit :: TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) MsgRequestTxIds :: forall (blocking :: StBlockingStyle) txid tx. SingBlockingStyle blocking -> NumTxIdsToAck -> NumTxIdsToReq -> Message (TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) ('StTxIds blocking :: TxSubmission2 txid tx) MsgReplyTxIds :: forall (blocking :: StBlockingStyle) txid tx. BlockingReplyList blocking (txid, SizeInBytes) -> Message (TxSubmission2 txid tx) ('StTxIds blocking :: TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) MsgRequestTxs :: forall txid tx. [txid] -> Message (TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) ('StTxs :: TxSubmission2 txid tx) MsgReplyTxs :: forall tx txid. [tx] -> Message (TxSubmission2 txid tx) ('StTxs :: TxSubmission2 txid tx) ('StIdle :: TxSubmission2 txid tx) MsgDone :: forall txid tx. Message (TxSubmission2 txid tx) ('StTxIds 'StBlocking :: TxSubmission2 txid tx) ('StDone :: TxSubmission2 txid tx)
data Message (ChainSync header point tip) (from :: ChainSync header point tip) (to :: ChainSync header point tip) Source #
Instance details Defined in Ouroboros.Network.Protocol.ChainSync.Type data Message (ChainSync header point tip) (from :: ChainSync header point tip) (to :: ChainSync header point tip) where MsgRequestNext :: forall header point tip. Message (ChainSync header point tip) ('StIdle :: ChainSync header point tip) ('StNext 'StCanAwait :: ChainSync header point tip) MsgAwaitReply :: forall header point tip. Message (ChainSync header point tip) ('StNext 'StCanAwait :: ChainSync header point tip) ('StNext 'StMustReply :: ChainSync header point tip) MsgRollForward :: forall header tip point (any :: StNextKind). header -> tip -> Message (ChainSync header point tip) ('StNext any :: ChainSync header point tip) ('StIdle :: ChainSync header point tip) MsgRollBackward :: forall point tip header (any :: StNextKind). point -> tip -> Message (ChainSync header point tip) ('StNext any :: ChainSync header point tip) ('StIdle :: ChainSync header point tip) MsgFindIntersect :: forall point header tip. [point] -> Message (ChainSync header point tip) ('StIdle :: ChainSync header point tip) ('StIntersect :: ChainSync header point tip) MsgIntersectFound :: forall point tip header. point -> tip -> Message (ChainSync header point tip) ('StIntersect :: ChainSync header point tip) ('StIdle :: ChainSync header point tip) MsgIntersectNotFound :: forall tip header point. tip -> Message (ChainSync header point tip) ('StIntersect :: ChainSync header point tip) ('StIdle :: ChainSync header point tip) MsgDone :: forall header point tip. Message (ChainSync header point tip) ('StIdle :: ChainSync header point tip) ('StDone :: ChainSync header point tip)
data Message (LocalStateQuery block point query) (from :: LocalStateQuery block point query) (to :: LocalStateQuery block point query) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalStateQuery.Type data Message (LocalStateQuery block point query) (from :: LocalStateQuery block point query) (to :: LocalStateQuery block point query) where MsgAcquire :: forall point block (query :: Type -> Type). Target point -> Message (LocalStateQuery block point query) ('StIdle :: LocalStateQuery block point query) ('StAcquiring :: LocalStateQuery block point query) MsgAcquired :: forall block point (query :: Type -> Type). Message (LocalStateQuery block point query) ('StAcquiring :: LocalStateQuery block point query) ('StAcquired :: LocalStateQuery block point query) MsgFailure :: forall block point (query :: Type -> Type). AcquireFailure -> Message (LocalStateQuery block point query) ('StAcquiring :: LocalStateQuery block point query) ('StIdle :: LocalStateQuery block point query) MsgQuery :: forall (query :: Type -> Type) result block point. query result -> Message (LocalStateQuery block point query) ('StAcquired :: LocalStateQuery block point query) ('StQuerying result :: LocalStateQuery block point query) MsgResult :: forall result block point (query :: Type -> Type). result -> Message (LocalStateQuery block point query) ('StQuerying result :: LocalStateQuery block point query) ('StAcquired :: LocalStateQuery block point query) MsgRelease :: forall block point (query :: Type -> Type). Message (LocalStateQuery block point query) ('StAcquired :: LocalStateQuery block point query) ('StIdle :: LocalStateQuery block point query) MsgReAcquire :: forall point block (query :: Type -> Type). Target point -> Message (LocalStateQuery block point query) ('StAcquired :: LocalStateQuery block point query) ('StAcquiring :: LocalStateQuery block point query) MsgDone :: forall block point (query :: Type -> Type). Message (LocalStateQuery block point query) ('StIdle :: LocalStateQuery block point query) ('StDone :: LocalStateQuery block point query)
data Message (LocalTxMonitor txid tx slot) (from :: LocalTxMonitor txid tx slot) (to :: LocalTxMonitor txid tx slot) Source #
Instance details Defined in Ouroboros.Network.Protocol.LocalTxMonitor.Type data Message (LocalTxMonitor txid tx slot) (from :: LocalTxMonitor txid tx slot) (to :: LocalTxMonitor txid tx slot) where MsgAcquire :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StIdle :: LocalTxMonitor txid tx slot) ('StAcquiring :: LocalTxMonitor txid tx slot) MsgAcquired :: forall slot txid tx. slot -> Message (LocalTxMonitor txid tx slot) ('StAcquiring :: LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) MsgAwaitAcquire :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) ('StAcquiring :: LocalTxMonitor txid tx slot) MsgNextTx :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) ('StBusy 'NextTx :: LocalTxMonitor txid tx slot) MsgReplyNextTx :: forall tx txid slot. Maybe tx -> Message (LocalTxMonitor txid tx slot) ('StBusy 'NextTx :: LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) MsgHasTx :: forall txid tx slot. txid -> Message (LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) ('StBusy 'HasTx :: LocalTxMonitor txid tx slot) MsgReplyHasTx :: forall txid tx slot. Bool -> Message (LocalTxMonitor txid tx slot) ('StBusy 'HasTx :: LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) MsgGetSizes :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) ('StBusy 'GetSizes :: LocalTxMonitor txid tx slot) MsgReplyGetSizes :: forall txid tx slot. MempoolSizeAndCapacity -> Message (LocalTxMonitor txid tx slot) ('StBusy 'GetSizes :: LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) MsgGetMeasures :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) ('StBusy 'GetMeasures :: LocalTxMonitor txid tx slot) MsgReplyGetMeasures :: forall txid tx slot. MempoolMeasures -> Message (LocalTxMonitor txid tx slot) ('StBusy 'GetMeasures :: LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) MsgRelease :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StAcquired :: LocalTxMonitor txid tx slot) ('StIdle :: LocalTxMonitor txid tx slot) MsgDone :: forall txid tx slot. Message (LocalTxMonitor txid tx slot) ('StIdle :: LocalTxMonitor txid tx slot) ('StDone :: LocalTxMonitor txid tx slot)

data SingTxSubmission (k :: TxSubmission2 txid tx) where Source #

Constructors

SingInit :: forall {txid} {tx}. SingTxSubmission ('StInit :: TxSubmission2 txid tx)
SingIdle :: forall {txid} {tx}. SingTxSubmission ('StIdle :: TxSubmission2 txid tx)
SingTxIds :: forall {txid} {tx} (stBlocking :: StBlockingStyle). SingBlockingStyle stBlocking -> SingTxSubmission ('StTxIds stBlocking :: TxSubmission2 txid tx)
SingTxs :: forall {txid} {tx}. SingTxSubmission ('StTxs :: TxSubmission2 txid tx)
SingDone :: forall {txid} {tx}. SingTxSubmission ('StDone :: TxSubmission2 txid tx)

Instances

Instances details

Show (SingTxSubmission k) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods showsPrec :: Int -> SingTxSubmission k -> ShowS # show :: SingTxSubmission k -> String # showList :: [SingTxSubmission k] -> ShowS #

data SingBlockingStyle (k :: StBlockingStyle) where Source #

The value level equivalent of BlockingStyle.

This is also used in MsgRequestTxIds where it is interpreted (and can be encoded) as a Bool with True for blocking, and False for non-blocking.

Constructors

SingBlocking :: SingBlockingStyle 'StBlocking
SingNonBlocking :: SingBlockingStyle 'StNonBlocking

Instances

Instances details

NFData (SingBlockingStyle b) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods rnf :: SingBlockingStyle b -> () #
Show (SingBlockingStyle b) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods showsPrec :: Int -> SingBlockingStyle b -> ShowS # show :: SingBlockingStyle b -> String # showList :: [SingBlockingStyle b] -> ShowS #
Eq (SingBlockingStyle b) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods (==) :: SingBlockingStyle b -> SingBlockingStyle b -> Bool # (/=) :: SingBlockingStyle b -> SingBlockingStyle b -> Bool #

data StBlockingStyle where Source #

Constructors

StBlocking :: StBlockingStyle	In this sub-state the reply need not be prompt. There is no timeout.
StNonBlocking :: StBlockingStyle	In this state the peer must reply. There is a timeout.

Instances

Instances details

SingI 'StBlocking Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods sing :: Sing 'StBlocking #
SingI 'StNonBlocking Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods sing :: Sing 'StNonBlocking #
type Sing Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type type Sing = SingBlockingStyle

data BlockingReplyList (blocking :: StBlockingStyle) a where Source #

We have requests for lists of things. In the blocking case the corresponding reply must be non-empty, whereas in the non-blocking case and empty reply is fine.

Constructors

BlockingReply :: forall a. NonEmpty a -> BlockingReplyList 'StBlocking a
NonBlockingReply :: forall a. [a] -> BlockingReplyList 'StNonBlocking a

Instances

Instances details

NFData a => NFData (BlockingReplyList blocking a) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods rnf :: BlockingReplyList blocking a -> () #
Show a => Show (BlockingReplyList blocking a) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods showsPrec :: Int -> BlockingReplyList blocking a -> ShowS # show :: BlockingReplyList blocking a -> String # showList :: [BlockingReplyList blocking a] -> ShowS #
Eq a => Eq (BlockingReplyList blocking a) Source #
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type Methods (==) :: BlockingReplyList blocking a -> BlockingReplyList blocking a -> Bool # (/=) :: BlockingReplyList blocking a -> BlockingReplyList blocking a -> Bool #

newtype NumTxIdsToAck Source #

Constructors

NumTxIdsToAck
Fields getNumTxIdsToAck :: Word16

Instances

Instances details

NFData NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

rnf :: NumTxIdsToAck -> () #

Monoid NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

mempty :: NumTxIdsToAck #

mappend :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

mconcat :: [NumTxIdsToAck] -> NumTxIdsToAck #

Semigroup NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(<>) :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

sconcat :: NonEmpty NumTxIdsToAck -> NumTxIdsToAck #

stimes :: Integral b => b -> NumTxIdsToAck -> NumTxIdsToAck #

Bounded NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

minBound :: NumTxIdsToAck #

maxBound :: NumTxIdsToAck #

Enum NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

succ :: NumTxIdsToAck -> NumTxIdsToAck #

pred :: NumTxIdsToAck -> NumTxIdsToAck #

toEnum :: Int -> NumTxIdsToAck #

fromEnum :: NumTxIdsToAck -> Int #

enumFrom :: NumTxIdsToAck -> [NumTxIdsToAck] #

enumFromThen :: NumTxIdsToAck -> NumTxIdsToAck -> [NumTxIdsToAck] #

enumFromTo :: NumTxIdsToAck -> NumTxIdsToAck -> [NumTxIdsToAck] #

enumFromThenTo :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck -> [NumTxIdsToAck] #

Generic NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Associated Types

type Rep NumTxIdsToAck
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type type Rep NumTxIdsToAck = D1 ('MetaData "NumTxIdsToAck" "Ouroboros.Network.Protocol.TxSubmission2.Type" "ouroboros-network-protocols-0.14.0.0-inplace" 'True) (C1 ('MetaCons "NumTxIdsToAck" 'PrefixI 'True) (S1 ('MetaSel ('Just "getNumTxIdsToAck") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Word16)))

Methods

from :: NumTxIdsToAck -> Rep NumTxIdsToAck x #

to :: Rep NumTxIdsToAck x -> NumTxIdsToAck #

Num NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(+) :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

(-) :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

(*) :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

negate :: NumTxIdsToAck -> NumTxIdsToAck #

abs :: NumTxIdsToAck -> NumTxIdsToAck #

signum :: NumTxIdsToAck -> NumTxIdsToAck #

fromInteger :: Integer -> NumTxIdsToAck #

Integral NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

quot :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

rem :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

div :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

mod :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

quotRem :: NumTxIdsToAck -> NumTxIdsToAck -> (NumTxIdsToAck, NumTxIdsToAck) #

divMod :: NumTxIdsToAck -> NumTxIdsToAck -> (NumTxIdsToAck, NumTxIdsToAck) #

toInteger :: NumTxIdsToAck -> Integer #

Real NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

toRational :: NumTxIdsToAck -> Rational #

Show NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

showsPrec :: Int -> NumTxIdsToAck -> ShowS #

show :: NumTxIdsToAck -> String #

showList :: [NumTxIdsToAck] -> ShowS #

Eq NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(==) :: NumTxIdsToAck -> NumTxIdsToAck -> Bool #

(/=) :: NumTxIdsToAck -> NumTxIdsToAck -> Bool #

Ord NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

compare :: NumTxIdsToAck -> NumTxIdsToAck -> Ordering #

(<) :: NumTxIdsToAck -> NumTxIdsToAck -> Bool #

(<=) :: NumTxIdsToAck -> NumTxIdsToAck -> Bool #

(>) :: NumTxIdsToAck -> NumTxIdsToAck -> Bool #

(>=) :: NumTxIdsToAck -> NumTxIdsToAck -> Bool #

max :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

min :: NumTxIdsToAck -> NumTxIdsToAck -> NumTxIdsToAck #

NoThunks NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

noThunks :: Context -> NumTxIdsToAck -> IO (Maybe ThunkInfo) #

wNoThunks :: Context -> NumTxIdsToAck -> IO (Maybe ThunkInfo) #

showTypeOf :: Proxy NumTxIdsToAck -> String #

type Rep NumTxIdsToAck Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type Rep NumTxIdsToAck = D1 ('MetaData "NumTxIdsToAck" "Ouroboros.Network.Protocol.TxSubmission2.Type" "ouroboros-network-protocols-0.14.0.0-inplace" 'True) (C1 ('MetaCons "NumTxIdsToAck" 'PrefixI 'True) (S1 ('MetaSel ('Just "getNumTxIdsToAck") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Word16)))

newtype NumTxIdsToReq Source #

Constructors

NumTxIdsToReq
Fields getNumTxIdsToReq :: Word16

Instances

Instances details

NFData NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

rnf :: NumTxIdsToReq -> () #

Monoid NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

mempty :: NumTxIdsToReq #

mappend :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

mconcat :: [NumTxIdsToReq] -> NumTxIdsToReq #

Semigroup NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(<>) :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

sconcat :: NonEmpty NumTxIdsToReq -> NumTxIdsToReq #

stimes :: Integral b => b -> NumTxIdsToReq -> NumTxIdsToReq #

Bounded NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

minBound :: NumTxIdsToReq #

maxBound :: NumTxIdsToReq #

Enum NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

succ :: NumTxIdsToReq -> NumTxIdsToReq #

pred :: NumTxIdsToReq -> NumTxIdsToReq #

toEnum :: Int -> NumTxIdsToReq #

fromEnum :: NumTxIdsToReq -> Int #

enumFrom :: NumTxIdsToReq -> [NumTxIdsToReq] #

enumFromThen :: NumTxIdsToReq -> NumTxIdsToReq -> [NumTxIdsToReq] #

enumFromTo :: NumTxIdsToReq -> NumTxIdsToReq -> [NumTxIdsToReq] #

enumFromThenTo :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq -> [NumTxIdsToReq] #

Generic NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Associated Types

type Rep NumTxIdsToReq
Instance details Defined in Ouroboros.Network.Protocol.TxSubmission2.Type type Rep NumTxIdsToReq = D1 ('MetaData "NumTxIdsToReq" "Ouroboros.Network.Protocol.TxSubmission2.Type" "ouroboros-network-protocols-0.14.0.0-inplace" 'True) (C1 ('MetaCons "NumTxIdsToReq" 'PrefixI 'True) (S1 ('MetaSel ('Just "getNumTxIdsToReq") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Word16)))

Methods

from :: NumTxIdsToReq -> Rep NumTxIdsToReq x #

to :: Rep NumTxIdsToReq x -> NumTxIdsToReq #

Num NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(+) :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

(-) :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

(*) :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

negate :: NumTxIdsToReq -> NumTxIdsToReq #

abs :: NumTxIdsToReq -> NumTxIdsToReq #

signum :: NumTxIdsToReq -> NumTxIdsToReq #

fromInteger :: Integer -> NumTxIdsToReq #

Integral NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

quot :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

rem :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

div :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

mod :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

quotRem :: NumTxIdsToReq -> NumTxIdsToReq -> (NumTxIdsToReq, NumTxIdsToReq) #

divMod :: NumTxIdsToReq -> NumTxIdsToReq -> (NumTxIdsToReq, NumTxIdsToReq) #

toInteger :: NumTxIdsToReq -> Integer #

Real NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

toRational :: NumTxIdsToReq -> Rational #

Show NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

showsPrec :: Int -> NumTxIdsToReq -> ShowS #

show :: NumTxIdsToReq -> String #

showList :: [NumTxIdsToReq] -> ShowS #

Eq NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

(==) :: NumTxIdsToReq -> NumTxIdsToReq -> Bool #

(/=) :: NumTxIdsToReq -> NumTxIdsToReq -> Bool #

Ord NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

compare :: NumTxIdsToReq -> NumTxIdsToReq -> Ordering #

(<) :: NumTxIdsToReq -> NumTxIdsToReq -> Bool #

(<=) :: NumTxIdsToReq -> NumTxIdsToReq -> Bool #

(>) :: NumTxIdsToReq -> NumTxIdsToReq -> Bool #

(>=) :: NumTxIdsToReq -> NumTxIdsToReq -> Bool #

max :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

min :: NumTxIdsToReq -> NumTxIdsToReq -> NumTxIdsToReq #

NoThunks NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

Methods

noThunks :: Context -> NumTxIdsToReq -> IO (Maybe ThunkInfo) #

wNoThunks :: Context -> NumTxIdsToReq -> IO (Maybe ThunkInfo) #

showTypeOf :: Proxy NumTxIdsToReq -> String #

type Rep NumTxIdsToReq Source #

Instance details

Defined in Ouroboros.Network.Protocol.TxSubmission2.Type

type Rep NumTxIdsToReq = D1 ('MetaData "NumTxIdsToReq" "Ouroboros.Network.Protocol.TxSubmission2.Type" "ouroboros-network-protocols-0.14.0.0-inplace" 'True) (C1 ('MetaCons "NumTxIdsToReq" 'PrefixI 'True) (S1 ('MetaSel ('Just "getNumTxIdsToReq") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Word16)))

newtype SizeInBytes #

Constructors

SizeInBytes
Fields getSizeInBytes :: Word32

Instances

Instances details

NFData SizeInBytes

Instance details

Defined in Ouroboros.Network.SizeInBytes

Methods

rnf :: SizeInBytes -> () #

Monoid SizeInBytes

Instance details

Defined in Ouroboros.Network.SizeInBytes

Methods

mempty :: SizeInBytes #

mappend :: SizeInBytes -> SizeInBytes -> SizeInBytes #

mconcat :: [SizeInBytes] -> SizeInBytes #

Semigroup SizeInBytes

Instance details

Defined in Ouroboros.Network.SizeInBytes

Methods

(<>) :: SizeInBytes -> SizeInBytes -> SizeInBytes #

sconcat :: NonEmpty SizeInBytes -> SizeInBytes #

stimes :: Integral b => b -> SizeInBytes -> SizeInBytes #

Enum SizeInBytes

Instance details

Defined in Ouroboros.Network.SizeInBytes

Methods

succ :: SizeInBytes -> SizeInBytes #

pred :: SizeInBytes -> SizeInBytes #

toEnum :: Int -> SizeInBytes #

fromEnum :: SizeInBytes -> Int #

enumFrom :: SizeInBytes -> [SizeInBytes] #

enumFromThen :: SizeInBytes -> SizeInBytes -> [SizeInBytes] #

enumFromTo :: SizeInBytes -> SizeInBytes -> [SizeInBytes] #

enumFromThenTo :: SizeInBytes -> SizeInBytes -> SizeInBytes -> [SizeInBytes] #

Generic SizeInBytes

Instance details

Defined in Ouroboros.Network.SizeInBytes

Associated Types

type Rep SizeInBytes
Instance details Defined in Ouroboros.Network.SizeInBytes type Rep SizeInBytes = D1 ('MetaData "SizeInBytes" "Ouroboros.Network.SizeInBytes" "ouroboros-network-api-0.13.0.0-inplace" 'True) (C1 ('MetaCons "SizeInBytes" 'PrefixI 'True) (S1 ('MetaSel ('Just "getSizeInBytes") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Word32)))