metrics

Documentation

Index

• type AppMetrics
  • func NewAppMetrics(meter metric.Meter) (*AppMetrics, error)
• type Metrics
  • func NewServer(port int, endpoint string) (*Metrics, error)
  • func (m *Metrics) Shutdown(ctx context.Context) error

Types

type AppMetrics

type AppMetrics struct {
	metric.Meter

	ActivePeers            metric.Int64UpDownCounter
	PeerConnectionDuration metric.Int64Histogram

	Registrations        metric.Int64Counter
	Deregistrations      metric.Int64Counter
	RegistrationFailures metric.Int64Counter
	RegistrationDelay    metric.Float64Histogram
	GetRegistrationDelay metric.Float64Histogram

	MessagesForwarded      metric.Int64Counter
	MessageForwardFailures metric.Int64Counter
	MessageForwardLatency  metric.Float64Histogram
}

AppMetrics holds all the application metrics

func NewAppMetrics

func NewAppMetrics(meter metric.Meter) (*AppMetrics, error)

type Metrics

type Metrics struct {
	Meter api.Meter

	Endpoint string

	*http.Server
	// contains filtered or unexported fields
}

Metrics holds the metrics information and exposes it

func NewServer

func NewServer(port int, endpoint string) (*Metrics, error)

NewServer initializes and returns a new Metrics instance

func (*Metrics) Shutdown

func (m *Metrics) Shutdown(ctx context.Context) error

Shutdown stops the metrics server