Versions in this module Expand all Collapse all v1 v1.13.2 Mar 3, 2021 v1.13.1 Nov 17, 2020 Changes in this version + func StatScaleToTime(r float64) time.Duration + func TimeToStatScale(d time.Duration) float64 + type FillSet struct + func NewFillSet(ns *nodestate.NodeStateMachine, input enode.Iterator, flags nodestate.Flags) *FillSet + func (fs *FillSet) Close() + func (fs *FillSet) SetTarget(target int) + type NodeValueTracker struct + func (nv *NodeValueTracker) RtStats() ResponseTimeStats + type PrivateClientAPI struct + func NewPrivateClientAPI(vt *ValueTracker) *PrivateClientAPI + func (api *PrivateClientAPI) Distribution(nodeStr string, normalized bool) (RtDistribution, error) + func (api *PrivateClientAPI) RequestStats() []RequestStatsItem + func (api *PrivateClientAPI) Timeout(nodeStr string, failRate float64) (float64, error) + func (api *PrivateClientAPI) Value(nodeStr string, timeout float64) (float64, error) + type QueueIterator struct + func NewQueueIterator(ns *nodestate.NodeStateMachine, requireFlags, disableFlags nodestate.Flags, ...) *QueueIterator + func (qi *QueueIterator) Close() + func (qi *QueueIterator) Next() bool + func (qi *QueueIterator) Node() *enode.Node + type RequestInfo struct + InitAmount float64 + InitValue float64 + Name string + type RequestStatsItem struct + Name string + ReqAmount float64 + ReqValue float64 + type ResponseTimeStats struct + func (rt *ResponseTimeStats) Add(respTime time.Duration, weight float64, expFactor utils.ExpirationFactor) + func (rt *ResponseTimeStats) AddStats(s *ResponseTimeStats) + func (rt *ResponseTimeStats) DecodeRLP(s *rlp.Stream) error + func (rt *ResponseTimeStats) EncodeRLP(w io.Writer) error + func (rt *ResponseTimeStats) SubStats(s *ResponseTimeStats) + func (rt ResponseTimeStats) Distribution(normalized bool, expFactor utils.ExpirationFactor) (res RtDistribution) + func (rt ResponseTimeStats) Timeout(failRatio float64) time.Duration + func (rt ResponseTimeStats) Value(weights ResponseTimeWeights, expFactor utils.ExpirationFactor) float64 + type ResponseTimeWeights [timeStatLength]float64 + func TimeoutWeights(timeout time.Duration) (res ResponseTimeWeights) + type RtDistribution [timeStatLength][2]float64 + type ServedRequest struct + Amount uint32 + ReqType uint32 + type ValueTracker struct + func NewValueTracker(db ethdb.KeyValueStore, clock mclock.Clock, reqInfo []RequestInfo, ...) *ValueTracker + func (vt *ValueTracker) GetNode(id enode.ID) *NodeValueTracker + func (vt *ValueTracker) Register(id enode.ID) *NodeValueTracker + func (vt *ValueTracker) RequestStats() []RequestStatsItem + func (vt *ValueTracker) RtStats() ResponseTimeStats + func (vt *ValueTracker) Served(nv *NodeValueTracker, reqs []ServedRequest, respTime time.Duration) + func (vt *ValueTracker) StatsExpFactor() utils.ExpirationFactor + func (vt *ValueTracker) StatsExpirer() *utils.Expirer + func (vt *ValueTracker) Stop() + func (vt *ValueTracker) Unregister(id enode.ID) + func (vt *ValueTracker) UpdateCosts(nv *NodeValueTracker, reqCosts []uint64) + type WrsIterator struct + func NewWrsIterator(ns *nodestate.NodeStateMachine, requireFlags, disableFlags nodestate.Flags, ...) *WrsIterator + func (w *WrsIterator) Close() + func (w *WrsIterator) Next() bool + func (w *WrsIterator) Node() *enode.Node
Go to main page