Safe Haskell	None
Language	Haskell2010

Ouroboros.Network.PeerSelection.PeerMetric

Contents

Peer metrics
Metric calculations
Tracers
Metrics reporters
Internals

Synopsis

data PeerMetrics (m :: Type -> Type) p
newtype PeerMetricsConfiguration = PeerMetricsConfiguration {
- maxEntriesToTrack :: Int
}
newPeerMetric :: (MonadLabelledSTM m, NoThunks p, NFData p) => PeerMetricsConfiguration -> m (PeerMetrics m p)
joinedPeerMetricAt :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p SlotNo)
upstreamyness :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p Int)
fetchynessBytes :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p Int)
fetchynessBlocks :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p Int)
headerMetricTracer :: forall (m :: Type -> Type) p. (MonadSTM m, Ord p) => PeerMetricsConfiguration -> PeerMetrics m p -> Tracer (STM m) (TraceLabelPeer (ConnectionId p) (SlotNo, Time))
fetchedMetricTracer :: forall (m :: Type -> Type) p. (MonadSTM m, Ord p) => PeerMetricsConfiguration -> PeerMetrics m p -> Tracer (STM m) (TraceLabelPeer (ConnectionId p) (SizeInBytes, SlotNo, Time))
data ReportPeerMetrics (m :: Type -> Type) peerAddr = ReportPeerMetrics {
- reportHeader :: Tracer (STM m) (TraceLabelPeer peerAddr (SlotNo, Time))
- reportFetch :: Tracer (STM m) (TraceLabelPeer peerAddr (SizeInBytes, SlotNo, Time))
}
nullMetric :: forall (m :: Type -> Type) p. MonadSTM m => ReportPeerMetrics m p
reportMetric :: forall (m :: Type -> Type) p. (MonadSTM m, Ord p) => PeerMetricsConfiguration -> PeerMetrics m p -> ReportPeerMetrics m (ConnectionId p)
type SlotMetric p = IntPSQ SlotNo (p, Time)
newPeerMetric' :: (MonadLabelledSTM m, NoThunks p, NFData p) => SlotMetric p -> SlotMetric (p, SizeInBytes) -> PeerMetricsConfiguration -> m (PeerMetrics m p)

Peer metrics

data PeerMetrics (m :: Type -> Type) p Source #

Mutable peer metrics state accessible via STM.

newtype PeerMetricsConfiguration Source #

Constructors

PeerMetricsConfiguration
Fields maxEntriesToTrack :: Int The maximum numbers of slots we will store data for. On some chains sometimes this corresponds to 1h worth of metrics sighs. this number MUST correspond to number of headers / blocks which are produced in one hour.

Instances

Instances details

NFData PeerMetricsConfiguration Source #

Instance details

Defined in Ouroboros.Network.PeerSelection.PeerMetric

Methods

rnf :: PeerMetricsConfiguration -> () #

Generic PeerMetricsConfiguration Source #

Instance details

Defined in Ouroboros.Network.PeerSelection.PeerMetric

Associated Types

type Rep PeerMetricsConfiguration

Instance details

Defined in Ouroboros.Network.PeerSelection.PeerMetric

type Rep PeerMetricsConfiguration = D1 ('MetaData "PeerMetricsConfiguration" "Ouroboros.Network.PeerSelection.PeerMetric" "ouroboros-network-0.18.0.0-inplace" 'True) (C1 ('MetaCons "PeerMetricsConfiguration" 'PrefixI 'True) (S1 ('MetaSel ('Just "maxEntriesToTrack") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

Methods

from :: PeerMetricsConfiguration -> Rep PeerMetricsConfiguration x #

to :: Rep PeerMetricsConfiguration x -> PeerMetricsConfiguration #

Show PeerMetricsConfiguration Source #

Instance details

Defined in Ouroboros.Network.PeerSelection.PeerMetric

Methods

showsPrec :: Int -> PeerMetricsConfiguration -> ShowS #

show :: PeerMetricsConfiguration -> String #

showList :: [PeerMetricsConfiguration] -> ShowS #

NoThunks PeerMetricsConfiguration Source #

Instance details

Defined in Ouroboros.Network.PeerSelection.PeerMetric

Methods

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

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

showTypeOf :: Proxy PeerMetricsConfiguration -> String #

type Rep PeerMetricsConfiguration Source #

Instance details

Defined in Ouroboros.Network.PeerSelection.PeerMetric

type Rep PeerMetricsConfiguration = D1 ('MetaData "PeerMetricsConfiguration" "Ouroboros.Network.PeerSelection.PeerMetric" "ouroboros-network-0.18.0.0-inplace" 'True) (C1 ('MetaCons "PeerMetricsConfiguration" 'PrefixI 'True) (S1 ('MetaSel ('Just "maxEntriesToTrack") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

newPeerMetric :: (MonadLabelledSTM m, NoThunks p, NFData p) => PeerMetricsConfiguration -> m (PeerMetrics m p) Source #

Metric calculations

joinedPeerMetricAt :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p SlotNo) Source #

upstreamyness :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p Int) Source #

Returns a Map which counts the number of times a given peer was the first to present us with a block/header.

fetchynessBytes :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p Int) Source #

Returns a Map which counts the number of bytes downloaded for a given peer.

fetchynessBlocks :: forall p (m :: Type -> Type). (MonadSTM m, Ord p) => PeerMetrics m p -> STM m (Map p Int) Source #

Returns a Map which counts the number of times a given peer was the first we downloaded a block from.

Tracers

headerMetricTracer :: forall (m :: Type -> Type) p. (MonadSTM m, Ord p) => PeerMetricsConfiguration -> PeerMetrics m p -> Tracer (STM m) (TraceLabelPeer (ConnectionId p) (SlotNo, Time)) Source #

Tracer which updates header metrics (upstreameness) and inserts new peers into peerRegistry.

fetchedMetricTracer :: forall (m :: Type -> Type) p. (MonadSTM m, Ord p) => PeerMetricsConfiguration -> PeerMetrics m p -> Tracer (STM m) (TraceLabelPeer (ConnectionId p) (SizeInBytes, SlotNo, Time)) Source #

Tracer which updates fetched metrics (fetchyness) and inserts new peers into peerRegistry.

Metrics reporters

data ReportPeerMetrics (m :: Type -> Type) peerAddr #

Constructors

ReportPeerMetrics
Fields reportHeader :: Tracer (STM m) (TraceLabelPeer peerAddr (SlotNo, Time)) reportFetch :: Tracer (STM m) (TraceLabelPeer peerAddr (SizeInBytes, SlotNo, Time))

nullMetric :: forall (m :: Type -> Type) p. MonadSTM m => ReportPeerMetrics m p Source #

reportMetric :: forall (m :: Type -> Type) p. (MonadSTM m, Ord p) => PeerMetricsConfiguration -> PeerMetrics m p -> ReportPeerMetrics m (ConnectionId p) Source #

Internals

type SlotMetric p = IntPSQ SlotNo (p, Time) Source #

Integer based metric ordered by SlotNo which holds the peer and time.

The p parameter is truly polymorphic. For upstreamyness and we use peer address, and for fetchyness it is a pair of peer id and bytes downloaded.

newPeerMetric' :: (MonadLabelledSTM m, NoThunks p, NFData p) => SlotMetric p -> SlotMetric (p, SizeInBytes) -> PeerMetricsConfiguration -> m (PeerMetrics m p) Source #