metrics

Documentation

Index

• type Metrics
  • func NewMetrics(ctx context.Context, meter metric.Meter) (*Metrics, error)
  • func (m *Metrics) PeerActivity(peerID string)
  • func (m *Metrics) PeerConnected(id string)
  • func (m *Metrics) PeerDisconnected(id string)
  • func (m *Metrics) RecordAuthenticationTime(duration time.Duration)
  • func (m *Metrics) RecordPeerStoreTime(duration time.Duration)

Types

type Metrics

type Metrics struct {
	metric.Meter

	TransferBytesSent  metric.Int64Counter
	TransferBytesRecv  metric.Int64Counter
	AuthenticationTime metric.Float64Histogram
	PeerStoreTime      metric.Float64Histogram
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(ctx context.Context, meter metric.Meter) (*Metrics, error)

func (*Metrics) PeerActivity

func (m *Metrics) PeerActivity(peerID string)

PeerActivity increases the active connections

func (*Metrics) PeerConnected

func (m *Metrics) PeerConnected(id string)

PeerConnected increments the number of connected peers and increments number of idle connections

func (*Metrics) PeerDisconnected

func (m *Metrics) PeerDisconnected(id string)

PeerDisconnected decrements the number of connected peers and decrements number of idle or active connections

func (*Metrics) RecordAuthenticationTime

func (m *Metrics) RecordAuthenticationTime(duration time.Duration)

RecordAuthenticationTime measures the time taken for peer authentication

func (*Metrics) RecordPeerStoreTime

func (m *Metrics) RecordPeerStoreTime(duration time.Duration)

RecordPeerStoreTime measures the time to store the peer in map