Modulecardano-diffusion-1.1.1.0

Cardano.Network.NodeToNode

Synopsis

value addSafetyMargin
value blockFetchMiniProtocolNum
value blockFetchProtocolLimits
value chainSyncMiniProtocolNum
value chainSyncProtocolLimits
value connectTo
value defaultMiniProtocolParameters
value keepAliveMiniProtocolNum
value keepAliveProtocolLimits
value nodeToNodeProtocols
value ntnDataFlow
value peerSharingMiniProtocolNum
value peerSharingProtocolLimits
value perasCertDiffusionMiniProtocolNum
value perasCertDiffusionProtocolLimits
value perasVoteDiffusionMiniProtocolNum
value perasVoteDiffusionProtocolLimits
value txSubmissionMiniProtocolNum
value txSubmissionProtocolLimits
value nodeToNodeVersionCodec
value nodeToNodeVersionDataCodec
value nodeToNodeHandshakeCodec
value combineVersions
value foldMapVersions
value simpleSingletonVersions
value nullNetworkConnectTracers
data MiniProtocolParameters
data NodeToNodeProtocols
type NodeToNodeProtocolsWithExpandedCtx
type NodeToNodeProtocolsWithMinimalCtx
data NodeToNodeVersion
data NodeToNodeVersionData
data Socket
data ConnectionId
data ExceptionInHandler
data ExpandedInitiatorContext
newtype MinimalInitiatorContext
newtype ResponderContext
data TraceSendRecv
data Handshake
newtype Versions
data AcceptConnectionsPolicyTrace
data AcceptedConnectionsLimit
type RemoteAddress
type RemoteConnectionId
data NetworkConnectTracers
data PeerSelectionTargets
data ControlMessage
type ControlMessageSTM
data DiffusionMode
data IsBigLedgerPeer
data PeerAdvertise
data ProtocolLimitFailure
newtype NumTxIdsToAck

Packagecardano-diffusion-1.1.1.0
Exports54
LicenceApache-2.0
SourceTypes.hs

valueaddSafetyMargin :: Int -> Int

valueblockFetchMiniProtocolNum :: MiniProtocolNum

valueblockFetchProtocolLimits :: MiniProtocolParameters -> MiniProtocolLimits

valuechainSyncMiniProtocolNum :: MiniProtocolNum

valuechainSyncProtocolLimits :: MiniProtocolParameters -> MiniProtocolLimits

valueconnectTo

:: (NFData a, NFData b)
=> Snocket IO Socket SockAddr
-> NetworkConnectTracers IO SockAddr NodeToNodeVersion
-> Versions NodeToNodeVersion NodeToNodeVersionData (OuroborosApplicationWithMinimalCtx 'InitiatorMode SockAddr ByteString IO a b)
-> Maybe SockAddr
-> SockAddr
-> IO (Either SomeException (Either a b))

valuedefaultMiniProtocolParameters :: MiniProtocolParameters

valuekeepAliveMiniProtocolNum :: MiniProtocolNum

valuekeepAliveProtocolLimits :: MiniProtocolParameters -> MiniProtocolLimits

valuenodeToNodeProtocols

:: Set CardanoFeatureFlag
-> MiniProtocolParameters
-> NodeToNodeProtocols muxMode initiatorCtx responderCtx bytes m a b
-> NodeToNodeVersion
-> NodeToNodeVersionData
-> OuroborosBundle muxMode initiatorCtx responderCtx bytes m a b

valuentnDataFlow :: NodeToNodeVersionData -> DataFlow

valuepeerSharingMiniProtocolNum :: MiniProtocolNum

valuepeerSharingProtocolLimits :: MiniProtocolParameters -> MiniProtocolLimits

valueperasCertDiffusionMiniProtocolNum :: MiniProtocolNum

valueperasCertDiffusionProtocolLimits

:: MiniProtocolParameters
-> MiniProtocolLimits

valueperasVoteDiffusionMiniProtocolNum :: MiniProtocolNum

valueperasVoteDiffusionProtocolLimits

:: MiniProtocolParameters
-> MiniProtocolLimits

valuetxSubmissionMiniProtocolNum :: MiniProtocolNum

valuetxSubmissionProtocolLimits :: MiniProtocolParameters -> MiniProtocolLimits

valuenodeToNodeVersionCodec :: CodecCBORTerm (Text, Maybe Int) NodeToNodeVersion

valuenodeToNodeVersionDataCodec :: VersionDataCodec NodeToNodeVersion NodeToNodeVersionData

valuenodeToNodeHandshakeCodec :: MonadST m => Codec (Handshake NodeToNodeVersion Term) DeserialiseFailure m ByteString

valuecombineVersions

:: (Ord vNum, Foldable f, HasCallStack)
=> f (Versions vNum extra r)
-> Versions vNum extra r

valuefoldMapVersions

:: (Ord vNum, Foldable f, HasCallStack)
=> x -> Versions vNum extra r
-> f x
-> Versions vNum extra r

valuesimpleSingletonVersions

:: vNum
-> vData
-> vData -> r
-> Versions vNum vData r

valuenullNetworkConnectTracers :: Monad m => NetworkConnectTracers m addr vNumber

datadata MiniProtocolParameters

Constructors

MiniProtocolParameters
- chainSyncPipeliningHighMark :: !Word16
- chainSyncPipeliningLowMark :: !Word16
- blockFetchPipeliningMax :: !Word16
- txDecisionPolicy :: !TxDecisionPolicy
- perasCertDiffusionMaxObjectsUnacknowledged :: !NumObjectsUnacknowledged
- perasVoteDiffusionMaxObjectsUnacknowledged :: !NumObjectsUnacknowledged

datadata NodeToNodeProtocols (appType :: Mode) initiatorCtx responderCtx bytes (m :: Type -> Type) a b

Constructors

NodeToNodeProtocols
- chainSyncProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b
- blockFetchProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b
- txSubmissionProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b
- perasCertDiffusionProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b
- perasVoteDiffusionProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b
- keepAliveProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b
- peerSharingProtocol :: RunMiniProtocol appType initiatorCtx responderCtx bytes m a b

type

type NodeToNodeProtocolsWithExpandedCtx (appType :: Mode) ntnAddr bytes (m :: Type -> Type) a b = NodeToNodeProtocols appType (ExpandedInitiatorContext ntnAddr PeerTrustable m) (ResponderContext ntnAddr) bytes m a b

type

type NodeToNodeProtocolsWithMinimalCtx (appType :: Mode) ntnAddr bytes (m :: Type -> Type) a b = NodeToNodeProtocols appType (MinimalInitiatorContext ntnAddr) (ResponderContext ntnAddr) bytes m a b

datadata NodeToNodeVersion

NodeToNodeV_14 NodeToNodeV_15 NodeToNodeV_16

datadata NodeToNodeVersionData

Constructors

NodeToNodeVersionData
- networkMagic :: !NetworkMagic
- diffusionMode :: !DiffusionMode
- peerSharing :: !PeerSharing
- query :: !Bool
- perasSupport :: !PerasSupport

datadata Socket

Source#

Basic type for a socket.

Instances2Eq, Show

Eq SocketDefined in network-3.2.9.0 · Network.Socket.Types
Show SocketDefined in network-3.2.9.0 · Network.Socket.Types

datadata ConnectionId addr

Constructors

ConnectionId
- localAddress :: !addr
- remoteAddress :: !addr

datadata ExceptionInHandler where

Constructors

ExceptionInHandler :: (Typeable peerAddr, PrettyShow peerAddr) => !peerAddr -> !SomeException -> ExceptionInHandler

datadata ExpandedInitiatorContext addr extraFlags (m :: Type -> Type)

Constructors

ExpandedInitiatorContext
- eicConnectionId :: !ConnectionId addr
- eicControlMessage :: !ControlMessageSTM m
- eicIsBigLedgerPeer :: !IsBigLedgerPeer
- eicExtraFlags :: !extraFlags

newtypenewtype MinimalInitiatorContext addr

Constructors

MinimalInitiatorContext
- micConnectionId :: ConnectionId addr

newtypenewtype ResponderContext addr

Constructors

ResponderContext
- rcConnectionId :: ConnectionId addr

datadata TraceSendRecv ps where

Constructors

TraceSendMsg :: AnyMessage ps -> TraceSendRecv ps
TraceRecvMsg :: AnyMessage ps -> TraceSendRecv ps

datadata Handshake (vNumber :: k) (vParams :: k1) where

newtypenewtype Versions vNum vData r

Constructors

Versions
- getVersions :: Map vNum (Version vData r)

datadata AcceptConnectionsPolicyTrace

Constructors

ServerTraceAcceptConnectionRateLimiting DiffTime Int
ServerTraceAcceptConnectionHardLimit Word32
ServerTraceAcceptConnectionResume Int

datadata AcceptedConnectionsLimit

Constructors

AcceptedConnectionsLimit
- acceptedConnectionsHardLimit :: !Word32
- acceptedConnectionsSoftLimit :: !Word32
- acceptedConnectionsDelay :: !DiffTime

typetype RemoteAddress = SockAddr

typetype RemoteConnectionId = ConnectionId RemoteAddress

datadata NetworkConnectTracers (m :: Type -> Type) addr vNumber

Constructors

NetworkConnectTracers
- nctMuxTracers :: TracersWithBearer (ConnectionId addr) m
- nctHandshakeTracer :: Tracer m (WithBearer (ConnectionId addr) (TraceSendRecv (Handshake vNumber Term)))

datadata PeerSelectionTargets

Constructors

PeerSelectionTargets
- targetNumberOfRootPeers :: !Int
- targetNumberOfKnownPeers :: !Int
- targetNumberOfEstablishedPeers :: !Int
- targetNumberOfActivePeers :: !Int
- targetNumberOfKnownBigLedgerPeers :: !Int
- targetNumberOfEstablishedBigLedgerPeers :: !Int
- targetNumberOfActiveBigLedgerPeers :: !Int

Instances2Eq, Show

Eq PeerSelectionTargetsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.PeerSelection.Governor.Types
Show PeerSelectionTargetsDefined in ouroboros-network-1.2.0.0 · Ouroboros.Network.PeerSelection.Governor.Types

datadata ControlMessage

Continue Quiesce Terminate

typetype ControlMessageSTM (m :: Type -> Type) = STM m ControlMessage

datadata DiffusionMode

InitiatorOnlyDiffusionMode InitiatorAndResponderDiffusionMode

datadata IsBigLedgerPeer

IsBigLedgerPeer IsNotBigLedgerPeer

datadata PeerAdvertise

DoNotAdvertisePeer DoAdvertisePeer

datadata ProtocolLimitFailure where

newtypenewtype NumTxIdsToAck

Constructors

NumTxIdsToAck
- getNumTxIdsToAck :: Word16