prometheus

Documentation

Index

• type StatsCollector
  • func (s StatsCollector) ClientPoll(info stats.PollInfo)
  • func (s StatsCollector) DatastoreOperation(start, end time.Time, operation string, result error)
  • func (s StatsCollector) KillNotificationReceived(cd *db.ClientData, kn *mpb.KillNotification)
  • func (s StatsCollector) MessageDropped(m *fspb.Message, isFirstTry bool, cd *db.ClientData)
  • func (s StatsCollector) MessageErrored(start, end time.Time, isTemp bool, m *fspb.Message, isFirstTry bool, ...)
  • func (s StatsCollector) MessageIngested(backlogged bool, m *fspb.Message, cd *db.ClientData)
  • func (s StatsCollector) MessageProcessed(start, end time.Time, m *fspb.Message, isFirstTry bool, cd *db.ClientData)
  • func (s StatsCollector) MessageSaved(forClient bool, m *fspb.Message, cd *db.ClientData)
  • func (s StatsCollector) ResourceUsageDataReceived(cd *db.ClientData, rud *mpb.ResourceUsageData, v *fspb.ValidationInfo)

Types

type StatsCollector

type StatsCollector struct{}

A PrometheusStatsCollector is an implementation of a Collector interface. It exports stats to a Prometheus HTTP handler, which are exposed at :<configured_port>/metrics and are scrapable by Prometheus (The port is configured in the server components config file).

func (StatsCollector) ClientPoll

func (s StatsCollector) ClientPoll(info stats.PollInfo)

func (StatsCollector) DatastoreOperation

func (s StatsCollector) DatastoreOperation(start, end time.Time, operation string, result error)

func (StatsCollector) KillNotificationReceived

func (s StatsCollector) KillNotificationReceived(cd *db.ClientData, kn *mpb.KillNotification)

func (StatsCollector) MessageDropped

func (s StatsCollector) MessageDropped(m *fspb.Message, isFirstTry bool, cd *db.ClientData)

func (StatsCollector) MessageErrored

func (s StatsCollector) MessageErrored(start, end time.Time, isTemp bool, m *fspb.Message, isFirstTry bool, cd *db.ClientData)

func (StatsCollector) MessageIngested

func (s StatsCollector) MessageIngested(backlogged bool, m *fspb.Message, cd *db.ClientData)

func (StatsCollector) MessageProcessed

func (s StatsCollector) MessageProcessed(start, end time.Time, m *fspb.Message, isFirstTry bool, cd *db.ClientData)

func (StatsCollector) MessageSaved

func (s StatsCollector) MessageSaved(forClient bool, m *fspb.Message, cd *db.ClientData)

func (StatsCollector) ResourceUsageDataReceived

func (s StatsCollector) ResourceUsageDataReceived(cd *db.ClientData, rud *mpb.ResourceUsageData, v *fspb.ValidationInfo)