analyzer

Documentation

Index

• Constants
• func ComputeCrashDelay(crashCount int, numberOfCrashesBeforeBackoffBegins int, startinDelay int, ...) (delay int)
• func SendMetrics(apps map[string]*models.App, err error)
• type Analyzer
  • func New(store store.Store, clock clock.Clock, logger lager.Logger, conf *config.Config) *Analyzer
  • func (analyzer *Analyzer) Analyze(appQueue *models.AppQueue) (map[string]*models.App, []models.PendingStartMessage, ...)

Constants

const (
	NumberOfAppsWithAllInstancesReporting = "NumberOfAppsWithAllInstancesReporting"
	NumberOfAppsWithMissingInstances      = "NumberOfAppsWithMissingInstances"
	NumberOfUndesiredRunningApps          = "NumberOfUndesiredRunningApps"
	NumberOfRunningInstances              = "NumberOfRunningInstances"
	NumberOfMissingIndices                = "NumberOfMissingIndices"
	NumberOfCrashedInstances              = "NumberOfCrashedInstances"
	NumberOfCrashedIndices                = "NumberOfCrashedIndices"
	NumberOfDesiredApps                   = "NumberOfDesiredApps"
	NumberOfDesiredInstances              = "NumberOfDesiredInstances"
	NumberOfDesiredAppsPendingStaging     = "NumberOfDesiredAppsPendingStaging"
)

Functions

func ComputeCrashDelay

func ComputeCrashDelay(crashCount int, numberOfCrashesBeforeBackoffBegins int, startinDelay int, maximumDelay int) (delay int)

func SendMetrics

func SendMetrics(apps map[string]*models.App, err error)

Types

type Analyzer

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

func New

func New(store store.Store, clock clock.Clock, logger lager.Logger, conf *config.Config) *Analyzer

func (*Analyzer) Analyze

func (analyzer *Analyzer) Analyze(appQueue *models.AppQueue) (map[string]*models.App, []models.PendingStartMessage, []models.PendingStopMessage, error)