Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.PeerSelection.LedgerPeers

Contents

Ledger Peers specific functions
DNS based provider for ledger root peers
Internal only exported for testing purposes

Synopsis

data IP
- = IPv4 {
  - ipv4 :: IPv4
  }
- | IPv6 {
  - ipv6 :: IPv6
  }
data LedgerPeers
- = LedgerPeers [(PoolStake, NonEmpty RelayAccessPoint)]
- | BeforeSlot
getLedgerPeers :: forall (m :: Type -> Type) extraAPI. MonadSTM m => SRVPrefix -> LedgerPeersConsensusInterface extraAPI m -> AfterSlot -> STM m LedgerPeers
data RelayAccessPoint
- = RelayAccessDomain !Domain !PortNumber
- | RelayAccessSRVDomain !Domain
- | RelayAccessAddress !IP !PortNumber
newtype PoolStake = PoolStake {
- unPoolStake :: Rational
}
newtype AccPoolStake = AccPoolStake {
- unAccPoolStake :: Rational
}
data TraceLedgerPeers
- = PickedBigLedgerPeer RelayAccessPoint AccPoolStake PoolStake
- | PickedLedgerPeer RelayAccessPoint AccPoolStake PoolStake
- | PickedBigLedgerPeers NumberOfPeers [RelayAccessPoint]
- | PickedLedgerPeers NumberOfPeers [RelayAccessPoint]
- | FetchingNewLedgerState Int Int
- | TraceLedgerPeersDomains [RelayAccessPoint]
- | DisabledLedgerPeers
- | TraceUseLedgerPeers UseLedgerPeers
- | WaitingOnRequest
- | RequestForPeers NumberOfPeers
- | ReusingLedgerState Int DiffTime
- | FallingBackToPublicRootPeers
- | NotEnoughBigLedgerPeers NumberOfPeers Int
- | NotEnoughLedgerPeers NumberOfPeers Int
- | UsingBigLedgerPeerSnapshot
newtype NumberOfPeers = NumberOfPeers {
- getNumberOfPeers :: Word16
}
data LedgerPeersKind
- = AllLedgerPeers
- | BigLedgerPeers
data StakeMapOverSource = StakeMapOverSource {
- ledgerWithOrigin :: WithOrigin SlotNo
- ledgerPeers :: LedgerPeers
- peerSnapshot :: Maybe LedgerPeerSnapshot
- cachedSlot :: Maybe SlotNo
- peerMap :: Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint)
- bigPeerMap :: Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint)
- useLedgerAfter :: AfterSlot
- srvPrefix :: SRVPrefix
}
accPoolStake :: [(PoolStake, NonEmpty relayAccessPoint)] -> Map AccPoolStake (PoolStake, NonEmpty relayAccessPoint)
accumulateBigLedgerStake :: [(PoolStake, NonEmpty relayAccessPoint)] -> [(AccPoolStake, (PoolStake, NonEmpty relayAccessPoint))]
accBigPoolStakeMap :: [(PoolStake, NonEmpty relayAccessPoint)] -> Map AccPoolStake (PoolStake, NonEmpty relayAccessPoint)
bigLedgerPeerQuota :: AccPoolStake
stakeMapWithSlotOverSource :: StakeMapOverSource -> (Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint), Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint), Maybe SlotNo)
data WithLedgerPeersArgs extraAPI (m :: Type -> Type) = WithLedgerPeersArgs {
- wlpRng :: StdGen
- wlpConsensusInterface :: LedgerPeersConsensusInterface extraAPI m
- wlpTracer :: Tracer m TraceLedgerPeers
- wlpGetUseLedgerPeers :: STM m UseLedgerPeers
- wlpGetLedgerPeerSnapshot :: STM m (Maybe LedgerPeerSnapshot)
- wlpSemaphore :: DNSSemaphore m
- wlpSRVPrefix :: SRVPrefix
}
withLedgerPeers :: forall peerAddr resolver extraAPI m a. (MonadAsync m, MonadThrow m, MonadMonotonicTime m, Ord peerAddr) => PeerActionsDNS peerAddr resolver m -> WithLedgerPeersArgs extraAPI m -> ((NumberOfPeers -> LedgerPeersKind -> m (Maybe (Set peerAddr, DiffTime))) -> Async m Void -> m a) -> m a
data AfterSlot
- = Always
- | After SlotNo
data UseLedgerPeers
- = DontUseLedgerPeers
- | UseLedgerPeers AfterSlot
data RelayAccessPoint
- = RelayAccessDomain !Domain !PortNumber
- | RelayAccessSRVDomain !Domain
- | RelayAccessAddress !IP !PortNumber
type SRVPrefix = Domain
data IsBigLedgerPeer
- = IsBigLedgerPeer
- | IsNotBigLedgerPeer
data LedgerPeerSnapshot where
- LedgerPeerSnapshotV2 (WithOrigin SlotNo, [(AccPoolStake, (PoolStake, NonEmpty LedgerRelayAccessPoint))])
- pattern LedgerPeerSnapshot :: (WithOrigin SlotNo, [(AccPoolStake, (PoolStake, NonEmpty LedgerRelayAccessPoint))]) -> LedgerPeerSnapshot
data LedgerPeersConsensusInterface extraAPI (m :: Type -> Type) = LedgerPeersConsensusInterface {
- lpGetLatestSlot :: STM m (WithOrigin SlotNo)
- lpGetLedgerPeers :: STM m [(PoolStake, NonEmpty LedgerRelayAccessPoint)]
- lpExtraAPI :: extraAPI
}
data LedgerPeersKind
- = AllLedgerPeers
- | BigLedgerPeers
newtype PoolStake = PoolStake {
- unPoolStake :: Rational
}
compareLedgerPeerSnapshotApproximate :: [(AccPoolStake, (PoolStake, NonEmpty RelayAccessPoint))] -> [(AccPoolStake, (PoolStake, NonEmpty RelayAccessPoint))] -> Bool
getRelayAccessPointsFromLedger :: forall (m :: Type -> Type) extraAPI. MonadSTM m => SRVPrefix -> LedgerPeersConsensusInterface extraAPI m -> STM m [(PoolStake, NonEmpty RelayAccessPoint)]
getRelayAccessPointsFromLedgerPeerSnapshot :: SRVPrefix -> LedgerPeerSnapshot -> (WithOrigin SlotNo, [(AccPoolStake, (PoolStake, NonEmpty RelayAccessPoint))])
newtype AccPoolStake = AccPoolStake {
- unAccPoolStake :: Rational
}
data LedgerRelayAccessPoint
- = LedgerRelayAccessDomain !Domain !PortNumber
- | LedgerRelayAccessSRVDomain !Domain
- | LedgerRelayAccessAddress !IP !PortNumber
prefixLedgerRelayAccessPoint :: SRVPrefix -> LedgerRelayAccessPoint -> RelayAccessPoint
data IsLedgerPeer
- = IsLedgerPeer
- | IsNotLedgerPeer
data LedgerPeerSnapshotSRVSupport
- = LedgerPeerSnapshotSupportsSRV
- | LedgerPeerSnapshotDoesntSupportSRV
decodeLedgerPeerSnapshot :: LedgerPeerSnapshotSRVSupport -> Decoder s LedgerPeerSnapshot
encodeLedgerPeerSnapshot :: LedgerPeerSnapshotSRVSupport -> LedgerPeerSnapshot -> Encoding
isLedgerPeersEnabled :: UseLedgerPeers -> Bool
mapExtraAPI :: forall a b (m :: Type -> Type). (a -> b) -> LedgerPeersConsensusInterface a m -> LedgerPeersConsensusInterface b m
resolveLedgerPeers :: forall m peerAddr resolver. (Ord peerAddr, MonadThrow m, MonadAsync m) => DNSSemaphore m -> ResolvConf -> DNSActions peerAddr resolver m -> LedgerPeersKind -> [RelayAccessPoint] -> StdGen -> m (Map Domain (Set peerAddr))

Documentation

data IP #

A unified IP data for IPv4 and IPv6. To create this, use the data constructors. Or use read "192.0.2.1" :: IP, for example. Also, "192.0.2.1" can be used as literal with OverloadedStrings.

>>> (read "192.0.2.1" :: IP) == IPv4 (read "192.0.2.1" :: IPv4)
True
>>> (read "2001:db8:00:00:00:00:00:01" :: IP) == IPv6 (read "2001:db8:00:00:00:00:00:01" :: IPv6)
True

Constructors

IPv4
Fields ipv4 :: IPv4
IPv6
Fields ipv6 :: IPv6

Instances

Instances details

Data IP

Instance details

Defined in Data.IP.Addr

Methods

gfoldl :: (forall d b. Data d => c (d -> b) -> d -> c b) -> (forall g. g -> c g) -> IP -> c IP #

gunfold :: (forall b r. Data b => c (b -> r) -> c r) -> (forall r. r -> c r) -> Constr -> c IP #

toConstr :: IP -> Constr #

dataTypeOf :: IP -> DataType #

dataCast1 :: Typeable t => (forall d. Data d => c (t d)) -> Maybe (c IP) #

dataCast2 :: Typeable t => (forall d e. (Data d, Data e) => c (t d e)) -> Maybe (c IP) #

gmapT :: (forall b. Data b => b -> b) -> IP -> IP #

gmapQl :: (r -> r' -> r) -> r -> (forall d. Data d => d -> r') -> IP -> r #

gmapQr :: forall r r'. (r' -> r -> r) -> r -> (forall d. Data d => d -> r') -> IP -> r #

gmapQ :: (forall d. Data d => d -> u) -> IP -> [u] #

gmapQi :: Int -> (forall d. Data d => d -> u) -> IP -> u #

gmapM :: Monad m => (forall d. Data d => d -> m d) -> IP -> m IP #

gmapMp :: MonadPlus m => (forall d. Data d => d -> m d) -> IP -> m IP #

gmapMo :: MonadPlus m => (forall d. Data d => d -> m d) -> IP -> m IP #

IsString IP

Instance details

Defined in Data.IP.Addr

Methods

fromString :: String -> IP #

Enum IP

Instance details

Defined in Data.IP.Addr

Methods

succ :: IP -> IP #

pred :: IP -> IP #

toEnum :: Int -> IP #

fromEnum :: IP -> Int #

enumFrom :: IP -> [IP] #

enumFromThen :: IP -> IP -> [IP] #

enumFromTo :: IP -> IP -> [IP] #

enumFromThenTo :: IP -> IP -> IP -> [IP] #

Generic IP

Instance details

Defined in Data.IP.Addr

Associated Types

type Rep IP

Instance details

Defined in Data.IP.Addr

type Rep IP = D1 ('MetaData "IP" "Data.IP.Addr" "iproute-1.7.15-9cbdeead1ad2dac143f0d52d2bd4e8985efc2da022ee700aca7f7cbbf02b48d0" 'False) (C1 ('MetaCons "IPv4" 'PrefixI 'True) (S1 ('MetaSel ('Just "ipv4") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedUnpack) (Rec0 IPv4)) :+: C1 ('MetaCons "IPv6" 'PrefixI 'True) (S1 ('MetaSel ('Just "ipv6") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 IPv6)))

Methods

from :: IP -> Rep IP x #

to :: Rep IP x -> IP #

Read IP

Instance details

Defined in Data.IP.Addr

Methods

readsPrec :: Int -> ReadS IP #

readList :: ReadS [IP] #

readPrec :: ReadPrec IP #

readListPrec :: ReadPrec [IP] #

Show IP

Instance details

Defined in Data.IP.Addr

Methods

showsPrec :: Int -> IP -> ShowS #

show :: IP -> String #

showList :: [IP] -> ShowS #

Eq IP

Equality over IP addresses. Correctly compare IPv4 and IPv4-embedded-in-IPv6 addresses.

>>> (read "2001:db8:00:00:00:00:00:01" :: IP) == (read "2001:db8:00:00:00:00:00:01" :: IP)
True
>>> (read "2001:db8:00:00:00:00:00:01" :: IP) == (read "2001:db8:00:00:00:00:00:05" :: IP)
False
>>> (read "127.0.0.1" :: IP) == (read "127.0.0.1" :: IP)
True
>>> (read "127.0.0.1" :: IP) == (read "10.0.0.1" :: IP)
False
>>> (read "::ffff:127.0.0.1" :: IP) == (read "127.0.0.1" :: IP)
True
>>> (read "::ffff:127.0.0.1" :: IP) == (read "127.0.0.9" :: IP)
False
>>> (read "::ffff:127.0.0.1" :: IP) >= (read "127.0.0.1" :: IP)
True
>>> (read "::ffff:127.0.0.1" :: IP) <= (read "127.0.0.1" :: IP)
True

Instance details

Defined in Data.IP.Addr

Methods

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

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

Ord IP

Instance details

Defined in Data.IP.Addr

Methods

compare :: IP -> IP -> Ordering #

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

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

(>) :: IP -> IP -> Bool #

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

max :: IP -> IP -> IP #

min :: IP -> IP -> IP #

type Rep IP

Instance details

Defined in Data.IP.Addr

type Rep IP = D1 ('MetaData "IP" "Data.IP.Addr" "iproute-1.7.15-9cbdeead1ad2dac143f0d52d2bd4e8985efc2da022ee700aca7f7cbbf02b48d0" 'False) (C1 ('MetaCons "IPv4" 'PrefixI 'True) (S1 ('MetaSel ('Just "ipv4") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedUnpack) (Rec0 IPv4)) :+: C1 ('MetaCons "IPv6" 'PrefixI 'True) (S1 ('MetaSel ('Just "ipv6") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 IPv6)))

data LedgerPeers Source #

Ledger Peer request result

Constructors

LedgerPeers [(PoolStake, NonEmpty RelayAccessPoint)]	Ledger peers
BeforeSlot	No result because the node is still before the configured UseLedgerAfter slot number

Instances

Instances details

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

getLedgerPeers :: forall (m :: Type -> Type) extraAPI. MonadSTM m => SRVPrefix -> LedgerPeersConsensusInterface extraAPI m -> AfterSlot -> STM m LedgerPeers Source #

Internal API to deal with UseLedgerAfter configuration option

Receiving the LedgerPeersConsensusInterface we are able to compute a function that given a SlotNo will give us LedgerPeers according to the following invariants:

BeforeSlot is returned iff the latest slot is before the slotNo;
'LedgerPeers lsj peers' is returned iff the latest slot is after the slotNo.

data RelayAccessPoint #

Constructors

RelayAccessDomain !Domain !PortNumber
RelayAccessSRVDomain !Domain
RelayAccessAddress !IP !PortNumber

Instances

Instances details

FromJSON RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods parseJSON :: Value -> Parser RelayAccessPoint # parseJSONList :: Value -> Parser [RelayAccessPoint] # omittedField :: Maybe RelayAccessPoint #
ToJSON RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods toJSON :: RelayAccessPoint -> Value # toEncoding :: RelayAccessPoint -> Encoding # toJSONList :: [RelayAccessPoint] -> Value # toEncodingList :: [RelayAccessPoint] -> Encoding # omitField :: RelayAccessPoint -> Bool #
FromCBOR RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods fromCBOR :: Decoder s RelayAccessPoint # label :: Proxy RelayAccessPoint -> Text #
ToCBOR RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods toCBOR :: RelayAccessPoint -> Encoding # encodedSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy RelayAccessPoint -> Size # encodedListSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy [RelayAccessPoint] -> Size #
NFData RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods rnf :: RelayAccessPoint -> () #
Show RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods showsPrec :: Int -> RelayAccessPoint -> ShowS # show :: RelayAccessPoint -> String # showList :: [RelayAccessPoint] -> ShowS #
Eq RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods (==) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (/=) :: RelayAccessPoint -> RelayAccessPoint -> Bool #
Ord RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods compare :: RelayAccessPoint -> RelayAccessPoint -> Ordering # (<) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (<=) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (>) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (>=) :: RelayAccessPoint -> RelayAccessPoint -> Bool # max :: RelayAccessPoint -> RelayAccessPoint -> RelayAccessPoint # min :: RelayAccessPoint -> RelayAccessPoint -> RelayAccessPoint #

newtype PoolStake #

Constructors

PoolStake
Fields unPoolStake :: Rational

Instances

Instances details

NFData PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods rnf :: PoolStake -> () #
Num PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (+) :: PoolStake -> PoolStake -> PoolStake # (-) :: PoolStake -> PoolStake -> PoolStake # (*) :: PoolStake -> PoolStake -> PoolStake # negate :: PoolStake -> PoolStake # abs :: PoolStake -> PoolStake # signum :: PoolStake -> PoolStake # fromInteger :: Integer -> PoolStake #
Fractional PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (/) :: PoolStake -> PoolStake -> PoolStake # recip :: PoolStake -> PoolStake # fromRational :: Rational -> PoolStake #
Show PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> PoolStake -> ShowS # show :: PoolStake -> String # showList :: [PoolStake] -> ShowS #
Eq PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: PoolStake -> PoolStake -> Bool # (/=) :: PoolStake -> PoolStake -> Bool #
Ord PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods compare :: PoolStake -> PoolStake -> Ordering # (<) :: PoolStake -> PoolStake -> Bool # (<=) :: PoolStake -> PoolStake -> Bool # (>) :: PoolStake -> PoolStake -> Bool # (>=) :: PoolStake -> PoolStake -> Bool # max :: PoolStake -> PoolStake -> PoolStake # min :: PoolStake -> PoolStake -> PoolStake #

newtype AccPoolStake #

Constructors

AccPoolStake
Fields unAccPoolStake :: Rational

Instances

Instances details

Num AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (+) :: AccPoolStake -> AccPoolStake -> AccPoolStake # (-) :: AccPoolStake -> AccPoolStake -> AccPoolStake # (*) :: AccPoolStake -> AccPoolStake -> AccPoolStake # negate :: AccPoolStake -> AccPoolStake # abs :: AccPoolStake -> AccPoolStake # signum :: AccPoolStake -> AccPoolStake # fromInteger :: Integer -> AccPoolStake #
Fractional AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (/) :: AccPoolStake -> AccPoolStake -> AccPoolStake # recip :: AccPoolStake -> AccPoolStake # fromRational :: Rational -> AccPoolStake #
Show AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> AccPoolStake -> ShowS # show :: AccPoolStake -> String # showList :: [AccPoolStake] -> ShowS #
Eq AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: AccPoolStake -> AccPoolStake -> Bool # (/=) :: AccPoolStake -> AccPoolStake -> Bool #
Ord AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods compare :: AccPoolStake -> AccPoolStake -> Ordering # (<) :: AccPoolStake -> AccPoolStake -> Bool # (<=) :: AccPoolStake -> AccPoolStake -> Bool # (>) :: AccPoolStake -> AccPoolStake -> Bool # (>=) :: AccPoolStake -> AccPoolStake -> Bool # max :: AccPoolStake -> AccPoolStake -> AccPoolStake # min :: AccPoolStake -> AccPoolStake -> AccPoolStake #

data TraceLedgerPeers Source #

Trace LedgerPeers events.

Constructors

PickedBigLedgerPeer RelayAccessPoint AccPoolStake PoolStake	Trace for a significant ledger peer picked with accumulated and relative stake of its pool.
PickedLedgerPeer RelayAccessPoint AccPoolStake PoolStake	Trace for a ledger peer picked with accumulated and relative stake of its pool.
PickedBigLedgerPeers NumberOfPeers [RelayAccessPoint]
PickedLedgerPeers NumberOfPeers [RelayAccessPoint]	Trace for the number of peers and we wanted to pick and the list of peers picked.
FetchingNewLedgerState Int Int	Trace for fetching a new list of peers from the ledger. The first Int is the number of ledger peers returned the latter is the number of big ledger peers.
TraceLedgerPeersDomains [RelayAccessPoint]
DisabledLedgerPeers	Trace for when getting peers from the ledger is disabled, that is DontUseLedgerPeers.
TraceUseLedgerPeers UseLedgerPeers	Trace UseLedgerPeers value
WaitingOnRequest
RequestForPeers NumberOfPeers
ReusingLedgerState Int DiffTime
FallingBackToPublicRootPeers
NotEnoughBigLedgerPeers NumberOfPeers Int
NotEnoughLedgerPeers NumberOfPeers Int
UsingBigLedgerPeerSnapshot

Instances

Instances details

Show TraceLedgerPeers Source #
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers Methods showsPrec :: Int -> TraceLedgerPeers -> ShowS # show :: TraceLedgerPeers -> String # showList :: [TraceLedgerPeers] -> ShowS #

newtype NumberOfPeers Source #

Number of peers to pick.

Constructors

NumberOfPeers
Fields getNumberOfPeers :: Word16

Instances

Instances details

Show NumberOfPeers Source #
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers Methods showsPrec :: Int -> NumberOfPeers -> ShowS # show :: NumberOfPeers -> String # showList :: [NumberOfPeers] -> ShowS #

data LedgerPeersKind #

Constructors

AllLedgerPeers
BigLedgerPeers

Instances

Instances details

Show LedgerPeersKind
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> LedgerPeersKind -> ShowS # show :: LedgerPeersKind -> String # showList :: [LedgerPeersKind] -> ShowS #

data StakeMapOverSource Source #

Arguments record to stakeMapWithSlotOverSource function

Constructors

StakeMapOverSource
Fields ledgerWithOrigin :: WithOrigin SlotNo ledgerPeers :: LedgerPeers peerSnapshot :: Maybe LedgerPeerSnapshot cachedSlot :: Maybe SlotNo peerMap :: Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint) bigPeerMap :: Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint) useLedgerAfter :: AfterSlot srvPrefix :: SRVPrefix

Instances

Instances details

Show StakeMapOverSource Source #
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers Methods showsPrec :: Int -> StakeMapOverSource -> ShowS # show :: StakeMapOverSource -> String # showList :: [StakeMapOverSource] -> ShowS #

Ledger Peers specific functions

accPoolStake :: [(PoolStake, NonEmpty relayAccessPoint)] -> Map AccPoolStake (PoolStake, NonEmpty relayAccessPoint) Source #

Convert a list of pools with stake to a Map keyed on the accumulated stake. Consensus provides a list of pairs of relative stake and corresponding relays for all usable registered pools. By creating a Map keyed on the AccPoolStake that is the sum of the pool's relative stake and the stake of all preceding pools we can support weighted random selection in O(log n) time by taking advantage of Map.lookupGE (returns the smallest key greater or equal to the provided value).

accumulateBigLedgerStake :: [(PoolStake, NonEmpty relayAccessPoint)] -> [(AccPoolStake, (PoolStake, NonEmpty relayAccessPoint))] #

accBigPoolStakeMap :: [(PoolStake, NonEmpty relayAccessPoint)] -> Map AccPoolStake (PoolStake, NonEmpty relayAccessPoint) Source #

Take the result of accBigPoolStake and turn it into

bigLedgerPeerQuota :: AccPoolStake #

stakeMapWithSlotOverSource :: StakeMapOverSource -> (Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint), Map AccPoolStake (PoolStake, NonEmpty RelayAccessPoint), Maybe SlotNo) Source #

Build up a stake map to sample ledger peers from. The SlotNo, if different from 0, indicates that the maps are the stake pools from the snapshot taken from the particular slot number.

DNS based provider for ledger root peers

data WithLedgerPeersArgs extraAPI (m :: Type -> Type) Source #

Argument record for withLedgerPeers

Constructors

WithLedgerPeersArgs

Fields

wlpRng :: StdGen
Random generator for picking ledger peers
wlpConsensusInterface :: LedgerPeersConsensusInterface extraAPI m
wlpTracer :: Tracer m TraceLedgerPeers
Get Ledger Peers comes from here
wlpGetUseLedgerPeers :: STM m UseLedgerPeers
Get Use Ledger After value
wlpGetLedgerPeerSnapshot :: STM m (Maybe LedgerPeerSnapshot)
Get ledger peer snapshot from file read by node
wlpSemaphore :: DNSSemaphore m
wlpSRVPrefix :: SRVPrefix
SRV prefix (CIP#0155)

withLedgerPeers :: forall peerAddr resolver extraAPI m a. (MonadAsync m, MonadThrow m, MonadMonotonicTime m, Ord peerAddr) => PeerActionsDNS peerAddr resolver m -> WithLedgerPeersArgs extraAPI m -> ((NumberOfPeers -> LedgerPeersKind -> m (Maybe (Set peerAddr, DiffTime))) -> Async m Void -> m a) -> m a Source #

For a LedgerPeers worker thread and submit request and receive responses.

data AfterSlot #

Constructors

Always
After SlotNo

Instances

Instances details

Generic AfterSlot

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Associated Types

type Rep AfterSlot

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

type Rep AfterSlot = D1 ('MetaData "AfterSlot" "Ouroboros.Network.PeerSelection.LedgerPeers.Type" "ouroboros-network-0.23.0.0-inplace-api" 'False) (C1 ('MetaCons "Always" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "After" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SlotNo)))

Methods

from :: AfterSlot -> Rep AfterSlot x #

to :: Rep AfterSlot x -> AfterSlot #

Show AfterSlot

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Methods

showsPrec :: Int -> AfterSlot -> ShowS #

show :: AfterSlot -> String #

showList :: [AfterSlot] -> ShowS #

Eq AfterSlot

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Methods

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

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

NoThunks AfterSlot

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Methods

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

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

showTypeOf :: Proxy AfterSlot -> String #

type Rep AfterSlot

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

type Rep AfterSlot = D1 ('MetaData "AfterSlot" "Ouroboros.Network.PeerSelection.LedgerPeers.Type" "ouroboros-network-0.23.0.0-inplace-api" 'False) (C1 ('MetaCons "Always" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "After" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SlotNo)))

data UseLedgerPeers #

Constructors

DontUseLedgerPeers
UseLedgerPeers AfterSlot

Instances

Instances details

Generic UseLedgerPeers

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Associated Types

type Rep UseLedgerPeers

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

type Rep UseLedgerPeers = D1 ('MetaData "UseLedgerPeers" "Ouroboros.Network.PeerSelection.LedgerPeers.Type" "ouroboros-network-0.23.0.0-inplace-api" 'False) (C1 ('MetaCons "DontUseLedgerPeers" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "UseLedgerPeers" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AfterSlot)))

Methods

from :: UseLedgerPeers -> Rep UseLedgerPeers x #

to :: Rep UseLedgerPeers x -> UseLedgerPeers #

Show UseLedgerPeers

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Methods

showsPrec :: Int -> UseLedgerPeers -> ShowS #

show :: UseLedgerPeers -> String #

showList :: [UseLedgerPeers] -> ShowS #

Eq UseLedgerPeers

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Methods

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

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

NoThunks UseLedgerPeers

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

Methods

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

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

showTypeOf :: Proxy UseLedgerPeers -> String #

type Rep UseLedgerPeers

Instance details

Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type

type Rep UseLedgerPeers = D1 ('MetaData "UseLedgerPeers" "Ouroboros.Network.PeerSelection.LedgerPeers.Type" "ouroboros-network-0.23.0.0-inplace-api" 'False) (C1 ('MetaCons "DontUseLedgerPeers" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "UseLedgerPeers" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 AfterSlot)))

data RelayAccessPoint #

Constructors

RelayAccessDomain !Domain !PortNumber
RelayAccessSRVDomain !Domain
RelayAccessAddress !IP !PortNumber

Instances

Instances details

FromJSON RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods parseJSON :: Value -> Parser RelayAccessPoint # parseJSONList :: Value -> Parser [RelayAccessPoint] # omittedField :: Maybe RelayAccessPoint #
ToJSON RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods toJSON :: RelayAccessPoint -> Value # toEncoding :: RelayAccessPoint -> Encoding # toJSONList :: [RelayAccessPoint] -> Value # toEncodingList :: [RelayAccessPoint] -> Encoding # omitField :: RelayAccessPoint -> Bool #
FromCBOR RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods fromCBOR :: Decoder s RelayAccessPoint # label :: Proxy RelayAccessPoint -> Text #
ToCBOR RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods toCBOR :: RelayAccessPoint -> Encoding # encodedSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy RelayAccessPoint -> Size # encodedListSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy [RelayAccessPoint] -> Size #
NFData RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods rnf :: RelayAccessPoint -> () #
Show RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods showsPrec :: Int -> RelayAccessPoint -> ShowS # show :: RelayAccessPoint -> String # showList :: [RelayAccessPoint] -> ShowS #
Eq RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods (==) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (/=) :: RelayAccessPoint -> RelayAccessPoint -> Bool #
Ord RelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods compare :: RelayAccessPoint -> RelayAccessPoint -> Ordering # (<) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (<=) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (>) :: RelayAccessPoint -> RelayAccessPoint -> Bool # (>=) :: RelayAccessPoint -> RelayAccessPoint -> Bool # max :: RelayAccessPoint -> RelayAccessPoint -> RelayAccessPoint # min :: RelayAccessPoint -> RelayAccessPoint -> RelayAccessPoint #

type SRVPrefix = Domain #

data IsBigLedgerPeer #

Constructors

IsBigLedgerPeer
IsNotBigLedgerPeer

Instances

Instances details

Show IsBigLedgerPeer
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> IsBigLedgerPeer -> ShowS # show :: IsBigLedgerPeer -> String # showList :: [IsBigLedgerPeer] -> ShowS #
Eq IsBigLedgerPeer
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: IsBigLedgerPeer -> IsBigLedgerPeer -> Bool # (/=) :: IsBigLedgerPeer -> IsBigLedgerPeer -> Bool #

data LedgerPeerSnapshot #

Constructors

LedgerPeerSnapshotV2 (WithOrigin SlotNo, [(AccPoolStake, (PoolStake, NonEmpty LedgerRelayAccessPoint))])

Bundled Patterns

pattern LedgerPeerSnapshot :: (WithOrigin SlotNo, [(AccPoolStake, (PoolStake, NonEmpty LedgerRelayAccessPoint))]) -> LedgerPeerSnapshot

Instances

Instances details

FromJSON LedgerPeerSnapshot
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods parseJSON :: Value -> Parser LedgerPeerSnapshot # parseJSONList :: Value -> Parser [LedgerPeerSnapshot] # omittedField :: Maybe LedgerPeerSnapshot #
ToJSON LedgerPeerSnapshot
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods toJSON :: LedgerPeerSnapshot -> Value # toEncoding :: LedgerPeerSnapshot -> Encoding # toJSONList :: [LedgerPeerSnapshot] -> Value # toEncodingList :: [LedgerPeerSnapshot] -> Encoding # omitField :: LedgerPeerSnapshot -> Bool #
Show LedgerPeerSnapshot
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> LedgerPeerSnapshot -> ShowS # show :: LedgerPeerSnapshot -> String # showList :: [LedgerPeerSnapshot] -> ShowS #
Eq LedgerPeerSnapshot
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: LedgerPeerSnapshot -> LedgerPeerSnapshot -> Bool # (/=) :: LedgerPeerSnapshot -> LedgerPeerSnapshot -> Bool #

data LedgerPeersConsensusInterface extraAPI (m :: Type -> Type) #

Constructors

LedgerPeersConsensusInterface
Fields lpGetLatestSlot :: STM m (WithOrigin SlotNo) lpGetLedgerPeers :: STM m [(PoolStake, NonEmpty LedgerRelayAccessPoint)] lpExtraAPI :: extraAPI

data LedgerPeersKind #

Constructors

AllLedgerPeers
BigLedgerPeers

Instances

Instances details

Show LedgerPeersKind
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> LedgerPeersKind -> ShowS # show :: LedgerPeersKind -> String # showList :: [LedgerPeersKind] -> ShowS #

newtype PoolStake #

Constructors

PoolStake
Fields unPoolStake :: Rational

Instances

Instances details

NFData PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods rnf :: PoolStake -> () #
Num PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (+) :: PoolStake -> PoolStake -> PoolStake # (-) :: PoolStake -> PoolStake -> PoolStake # (*) :: PoolStake -> PoolStake -> PoolStake # negate :: PoolStake -> PoolStake # abs :: PoolStake -> PoolStake # signum :: PoolStake -> PoolStake # fromInteger :: Integer -> PoolStake #
Fractional PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (/) :: PoolStake -> PoolStake -> PoolStake # recip :: PoolStake -> PoolStake # fromRational :: Rational -> PoolStake #
Show PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> PoolStake -> ShowS # show :: PoolStake -> String # showList :: [PoolStake] -> ShowS #
Eq PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: PoolStake -> PoolStake -> Bool # (/=) :: PoolStake -> PoolStake -> Bool #
Ord PoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods compare :: PoolStake -> PoolStake -> Ordering # (<) :: PoolStake -> PoolStake -> Bool # (<=) :: PoolStake -> PoolStake -> Bool # (>) :: PoolStake -> PoolStake -> Bool # (>=) :: PoolStake -> PoolStake -> Bool # max :: PoolStake -> PoolStake -> PoolStake # min :: PoolStake -> PoolStake -> PoolStake #

compareLedgerPeerSnapshotApproximate :: [(AccPoolStake, (PoolStake, NonEmpty RelayAccessPoint))] -> [(AccPoolStake, (PoolStake, NonEmpty RelayAccessPoint))] -> Bool #

getRelayAccessPointsFromLedger :: forall (m :: Type -> Type) extraAPI. MonadSTM m => SRVPrefix -> LedgerPeersConsensusInterface extraAPI m -> STM m [(PoolStake, NonEmpty RelayAccessPoint)] #

getRelayAccessPointsFromLedgerPeerSnapshot :: SRVPrefix -> LedgerPeerSnapshot -> (WithOrigin SlotNo, [(AccPoolStake, (PoolStake, NonEmpty RelayAccessPoint))]) #

newtype AccPoolStake #

Constructors

AccPoolStake
Fields unAccPoolStake :: Rational

Instances

Instances details

Num AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (+) :: AccPoolStake -> AccPoolStake -> AccPoolStake # (-) :: AccPoolStake -> AccPoolStake -> AccPoolStake # (*) :: AccPoolStake -> AccPoolStake -> AccPoolStake # negate :: AccPoolStake -> AccPoolStake # abs :: AccPoolStake -> AccPoolStake # signum :: AccPoolStake -> AccPoolStake # fromInteger :: Integer -> AccPoolStake #
Fractional AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (/) :: AccPoolStake -> AccPoolStake -> AccPoolStake # recip :: AccPoolStake -> AccPoolStake # fromRational :: Rational -> AccPoolStake #
Show AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> AccPoolStake -> ShowS # show :: AccPoolStake -> String # showList :: [AccPoolStake] -> ShowS #
Eq AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: AccPoolStake -> AccPoolStake -> Bool # (/=) :: AccPoolStake -> AccPoolStake -> Bool #
Ord AccPoolStake
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods compare :: AccPoolStake -> AccPoolStake -> Ordering # (<) :: AccPoolStake -> AccPoolStake -> Bool # (<=) :: AccPoolStake -> AccPoolStake -> Bool # (>) :: AccPoolStake -> AccPoolStake -> Bool # (>=) :: AccPoolStake -> AccPoolStake -> Bool # max :: AccPoolStake -> AccPoolStake -> AccPoolStake # min :: AccPoolStake -> AccPoolStake -> AccPoolStake #

data LedgerRelayAccessPoint #

Constructors

LedgerRelayAccessDomain !Domain !PortNumber
LedgerRelayAccessSRVDomain !Domain
LedgerRelayAccessAddress !IP !PortNumber

Instances

Instances details

FromJSON LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods parseJSON :: Value -> Parser LedgerRelayAccessPoint # parseJSONList :: Value -> Parser [LedgerRelayAccessPoint] # omittedField :: Maybe LedgerRelayAccessPoint #
ToJSON LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods toJSON :: LedgerRelayAccessPoint -> Value # toEncoding :: LedgerRelayAccessPoint -> Encoding # toJSONList :: [LedgerRelayAccessPoint] -> Value # toEncodingList :: [LedgerRelayAccessPoint] -> Encoding # omitField :: LedgerRelayAccessPoint -> Bool #
FromCBOR LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods fromCBOR :: Decoder s LedgerRelayAccessPoint # label :: Proxy LedgerRelayAccessPoint -> Text #
ToCBOR LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods toCBOR :: LedgerRelayAccessPoint -> Encoding # encodedSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy LedgerRelayAccessPoint -> Size # encodedListSizeExpr :: (forall t. ToCBOR t => Proxy t -> Size) -> Proxy [LedgerRelayAccessPoint] -> Size #
NFData LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods rnf :: LedgerRelayAccessPoint -> () #
Show LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods showsPrec :: Int -> LedgerRelayAccessPoint -> ShowS # show :: LedgerRelayAccessPoint -> String # showList :: [LedgerRelayAccessPoint] -> ShowS #
Eq LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods (==) :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Bool # (/=) :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Bool #
Ord LedgerRelayAccessPoint
Instance details Defined in Ouroboros.Network.PeerSelection.RelayAccessPoint Methods compare :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Ordering # (<) :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Bool # (<=) :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Bool # (>) :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Bool # (>=) :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> Bool # max :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> LedgerRelayAccessPoint # min :: LedgerRelayAccessPoint -> LedgerRelayAccessPoint -> LedgerRelayAccessPoint #

prefixLedgerRelayAccessPoint :: SRVPrefix -> LedgerRelayAccessPoint -> RelayAccessPoint #

data IsLedgerPeer #

Constructors

IsLedgerPeer
IsNotLedgerPeer

Instances

Instances details

Show IsLedgerPeer
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> IsLedgerPeer -> ShowS # show :: IsLedgerPeer -> String # showList :: [IsLedgerPeer] -> ShowS #
Eq IsLedgerPeer
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: IsLedgerPeer -> IsLedgerPeer -> Bool # (/=) :: IsLedgerPeer -> IsLedgerPeer -> Bool #

data LedgerPeerSnapshotSRVSupport #

Constructors

LedgerPeerSnapshotSupportsSRV
LedgerPeerSnapshotDoesntSupportSRV

Instances

Instances details

Show LedgerPeerSnapshotSRVSupport
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods showsPrec :: Int -> LedgerPeerSnapshotSRVSupport -> ShowS # show :: LedgerPeerSnapshotSRVSupport -> String # showList :: [LedgerPeerSnapshotSRVSupport] -> ShowS #
Eq LedgerPeerSnapshotSRVSupport
Instance details Defined in Ouroboros.Network.PeerSelection.LedgerPeers.Type Methods (==) :: LedgerPeerSnapshotSRVSupport -> LedgerPeerSnapshotSRVSupport -> Bool # (/=) :: LedgerPeerSnapshotSRVSupport -> LedgerPeerSnapshotSRVSupport -> Bool #

decodeLedgerPeerSnapshot :: LedgerPeerSnapshotSRVSupport -> Decoder s LedgerPeerSnapshot #

encodeLedgerPeerSnapshot :: LedgerPeerSnapshotSRVSupport -> LedgerPeerSnapshot -> Encoding #

isLedgerPeersEnabled :: UseLedgerPeers -> Bool #

mapExtraAPI :: forall a b (m :: Type -> Type). (a -> b) -> LedgerPeersConsensusInterface a m -> LedgerPeersConsensusInterface b m #

Internal only exported for testing purposes

resolveLedgerPeers :: forall m peerAddr resolver. (Ord peerAddr, MonadThrow m, MonadAsync m) => DNSSemaphore m -> ResolvConf -> DNSActions peerAddr resolver m -> LedgerPeersKind -> [RelayAccessPoint] -> StdGen -> m (Map Domain (Set peerAddr)) Source #

Provides DNS resolution functionality.

Concurrently resolve DNS names, respecting the maxDNSConcurrency limit.