metrics

Documentation

Index

• Constants
• func GetKeyVerificationRefreshCount() int64
• func GetTokenErrors() int64
• func IncrementKeyVerificationRefreshCount()
• func IncrementTokenError()
• type MetricsReporter
  • func NewMetricsReporter(database db.DB, stats PartialStatsdClient, ticker *time.Ticker, ...) *MetricsReporter
  • func (r *MetricsReporter) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type PartialStatsdClient

Constants

const (
	TotalHttpSubscriptions = "total_http_subscriptions"
	TotalHttpRoutes        = "total_http_routes"
	TotalTcpSubscriptions  = "total_tcp_subscriptions"
	TotalTcpRoutes         = "total_tcp_routes"
	TotalTokenErrors       = "total_token_errors"
	KeyRefreshEvents       = "key_refresh_events"
)

Functions

func GetKeyVerificationRefreshCount

func GetKeyVerificationRefreshCount() int64

func GetTokenErrors

func GetTokenErrors() int64

func IncrementKeyVerificationRefreshCount

func IncrementKeyVerificationRefreshCount()

func IncrementTokenError

func IncrementTokenError()

Types

type MetricsReporter

type MetricsReporter struct {
	// contains filtered or unexported fields
}

func NewMetricsReporter

func NewMetricsReporter(database db.DB, stats PartialStatsdClient, ticker *time.Ticker, logger lager.Logger) *MetricsReporter

func (*MetricsReporter) Run

func (r *MetricsReporter) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type PartialStatsdClient

type PartialStatsdClient interface {
	GaugeDelta(stat string, value int64, rate float32) error
	Gauge(stat string, value int64, rate float32) error
}