libp2p/protocols/pubsub/bandwidth

Search:
Group by:
Source   Edit  

Types

BandwidthTracking = ref object
  download*: ExponentialMovingAverage
Source   Edit  
ExponentialMovingAverage = ref object
Source   Edit  

Procs

proc calculateReceiveTimeMs(msgLen: int64; dataRate: int64 = InitialRate): int64 {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc init(T: type[BandwidthTracking]; alpha: float = DefaultAlpha): T:type
Source   Edit  
proc init(T: type[ExponentialMovingAverage]; alpha: float = DefaultAlpha): T:type
Source   Edit  
proc update(e: var ExponentialMovingAverage; startAt: Moment; bytes: int) {.
    ...raises: [], tags: [], forbids: [].}
Source   Edit  
proc value(e: var ExponentialMovingAverage): float {....raises: [], tags: [],
    forbids: [].}
Source   Edit