metrics

Jun 12, 2021

Changes in this version

+ type Collector struct

+ func NewCollector(db *shed.DB) *Collector

+ func (c *Collector) Finalize(t time.Time) error

+ func (c *Collector) Flush(addresses ...swarm.Address) error

+ func (c *Collector) Inspect(addr swarm.Address, fn func(ss *Snapshot))

+ func (c *Collector) Record(addr swarm.Address, rop ...RecordOp)

+ func (c *Collector) Snapshot(t time.Time, addresses ...swarm.Address) map[string]*Snapshot

+ type Counters struct

+ type PeerConnectionDirection string

+ const PeerConnectionDirectionInbound

+ const PeerConnectionDirectionOutbound

+ type RecordOp func(*Counters)

+ func IncSessionConnectionRetry() RecordOp

+ func PeerLogIn(t time.Time, dir PeerConnectionDirection) RecordOp

+ func PeerLogOut(t time.Time) RecordOp

+ type Snapshot struct

+ ConnectionTotalDuration time.Duration

+ LastSeenTimestamp int64

+ SessionConnectionDirection PeerConnectionDirection

+ SessionConnectionDuration time.Duration

+ SessionConnectionRetry uint64

+ func (ss *Snapshot) HasAtMaxOneConnectionAttempt() bool