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)

Types

type Metrics

type Metrics struct {
	metric.Meter

	TransferBytesSent metric.Int64Counter
	TransferBytesRecv metric.Int64Counter
	// 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