Versions in this module Expand all Collapse all v0 v0.9.2 May 24, 2021 Changes in this version + const Dead + const FullHealth + const ModerateHealth + func RecalculateNetworkUptimeEvery(d time.Duration) func(m *Monitor) + func SetCheckIsValidatorInterval(d time.Duration) func(n *Node) + func SetNumValidatorsUpdateInterval(d time.Duration) func(m *Monitor) + func UnmarshalEvent(b json.RawMessage) (string, events.EventData, error) + type Health int + type Monitor struct + Network *Network + Nodes []*Node + func NewMonitor(options ...func(*Monitor)) *Monitor + func (m *Monitor) Monitor(n *Node) error + func (m *Monitor) NodeByName(name string) (index int, node *Node) + func (m *Monitor) NodeIsOnline(name string) + func (m *Monitor) SetLogger(l log.Logger) + func (m *Monitor) Start() error + func (m *Monitor) Stop() + func (m *Monitor) Unmonitor(n *Node) + type Network struct + AvgBlockLatency float64 + AvgBlockTime float64 + AvgTxThroughput float64 + Health Health + Height int64 + NumNodesMonitored int + NumNodesMonitoredOnline int + NumValidators int + UptimeData *UptimeData + func NewNetwork() *Network + func (n *Network) GetHealthString() string + func (n *Network) NewBlock(b tmtypes.Header) + func (n *Network) NewBlockLatency(l float64) + func (n *Network) NewNode(name string) + func (n *Network) NodeDeleted(name string) + func (n *Network) NodeIsDown(name string) + func (n *Network) NodeIsOnline(name string) + func (n *Network) RecalculateUptime() + func (n *Network) StartTime() time.Time + func (n *Network) UpdateNumValidatorsForHeight(num int, height int64) + func (n *Network) Uptime() float64 + type Node struct + BlockLatency float64 + Height int64 + IsValidator bool + Name string + Online bool + func NewNode(rpcAddr string, options ...func(*Node)) *Node + func NewNodeWithEventMeterAndRpcClient(rpcAddr string, em eventMeter, rpcClient rpc_client.HTTPClient, ...) *Node + func (n *Node) NotifyAboutDisconnects(ch chan<- bool) + func (n *Node) NumValidators() (height int64, num int, err error) + func (n *Node) RestartEventMeterBackoff() error + func (n *Node) SendBlockLatenciesTo(ch chan<- float64) + func (n *Node) SendBlocksTo(ch chan<- tmtypes.Header) + func (n *Node) SetLogger(l log.Logger) + func (n *Node) Start() error + func (n *Node) Stop() + type UptimeData struct + StartTime time.Time + Uptime float64
Go to main page