metricsaccountant

Documentation

Index

• Constants
• type MetricsAccountant
• type RealMetricsAccountant
  • func New() *RealMetricsAccountant
  • func (m *RealMetricsAccountant) IncrementSentMessageMetrics(starts []models.PendingStartMessage, stops []models.PendingStopMessage) error
  • func (m *RealMetricsAccountant) TrackReceivedHeartbeats(metric int) error
  • func (m *RealMetricsAccountant) TrackSavedHeartbeats(metric int) error
• type UsageTracker

Constants

const (
	ReceivedHeartbeats     = "ReceivedHeartbeats"
	SavedHeartbeats        = "SavedHeartbeats"
	StartCrashed           = "StartCrashed"
	StartMissing           = "StartMissing"
	StartEvacuating        = "StartEvacuating"
	StopExtra              = "StopExtra"
	StopDuplicate          = "StopDuplicate"
	StopEvacuationComplete = "StopEvacuationComplete"
)

Types

type MetricsAccountant

type MetricsAccountant interface {
	TrackReceivedHeartbeats(metric int) error
	TrackSavedHeartbeats(metric int) error
	IncrementSentMessageMetrics(starts []models.PendingStartMessage, stops []models.PendingStopMessage) error
}

type RealMetricsAccountant

type RealMetricsAccountant struct {
}

func New

func New() *RealMetricsAccountant

func (*RealMetricsAccountant) IncrementSentMessageMetrics

func (m *RealMetricsAccountant) IncrementSentMessageMetrics(starts []models.PendingStartMessage, stops []models.PendingStopMessage) error

func (*RealMetricsAccountant) TrackReceivedHeartbeats

func (m *RealMetricsAccountant) TrackReceivedHeartbeats(metric int) error

func (*RealMetricsAccountant) TrackSavedHeartbeats

func (m *RealMetricsAccountant) TrackSavedHeartbeats(metric int) error

type UsageTracker

type UsageTracker interface {
	StartTrackingUsage()
	MeasureUsage() (usage float64, measurementDuration time.Duration)
}