metricsaccountant

Documentation

Index

• type MetricsAccountant
• type RealMetricsAccountant
  • func New(store store.Store) *RealMetricsAccountant
  • func (m *RealMetricsAccountant) GetMetrics() (map[string]float64, error)
  • func (m *RealMetricsAccountant) IncrementSentMessageMetrics(starts []models.PendingStartMessage, stops []models.PendingStopMessage) error
  • func (m *RealMetricsAccountant) TrackActualStateListenerStoreUsageFraction(usage float64) error
  • func (m *RealMetricsAccountant) TrackDesiredStateSyncTime(dt time.Duration) error
  • func (m *RealMetricsAccountant) TrackReceivedHeartbeats(metric int) error
  • func (m *RealMetricsAccountant) TrackSavedHeartbeats(metric int) error
• type UsageTracker

Types

type MetricsAccountant

type MetricsAccountant interface {
	TrackReceivedHeartbeats(metric int) error
	TrackSavedHeartbeats(metric int) error
	IncrementSentMessageMetrics(starts []models.PendingStartMessage, stops []models.PendingStopMessage) error
	TrackDesiredStateSyncTime(dt time.Duration) error
	TrackActualStateListenerStoreUsageFraction(usage float64) error
	GetMetrics() (map[string]float64, error)
}

type RealMetricsAccountant

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

func New

func New(store store.Store) *RealMetricsAccountant

func (*RealMetricsAccountant) GetMetrics

func (m *RealMetricsAccountant) GetMetrics() (map[string]float64, error)

func (*RealMetricsAccountant) IncrementSentMessageMetrics

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

func (*RealMetricsAccountant) TrackActualStateListenerStoreUsageFraction

func (m *RealMetricsAccountant) TrackActualStateListenerStoreUsageFraction(usage float64) error

func (*RealMetricsAccountant) TrackDesiredStateSyncTime

func (m *RealMetricsAccountant) TrackDesiredStateSyncTime(dt time.Duration) 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)
}