generator

Documentation

Index

• type AppEvaluationManager
  • func NewAppEvaluationManager(logger lager.Logger, evaluateInterval time.Duration, emClock clock.Clock, ...) (*AppEvaluationManager, error)
  • func (a *AppEvaluationManager) GetBreaker(appID string) *circuit.Breaker
  • func (a *AppEvaluationManager) SetCoolDownExpired(appID string, expiredAt int64)
  • func (a *AppEvaluationManager) Start()
  • func (a *AppEvaluationManager) Stop()
• type ConsumeAppMonitorMap
• type Evaluator
  • func NewEvaluator(logger lager.Logger, httpClient *http.Client, scalingEngineUrl string, ...) *Evaluator
  • func (e *Evaluator) Start()
  • func (e *Evaluator) Stop()

Types

type AppEvaluationManager

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

func NewAppEvaluationManager

func NewAppEvaluationManager(logger lager.Logger, evaluateInterval time.Duration, emClock clock.Clock,
	triggerChan chan []*models.Trigger, getPolicies aggregator.GetPoliciesFunc,
	breakerConfig config.CircuitBreakerConfig) (*AppEvaluationManager, error)

func (*AppEvaluationManager) GetBreaker

func (a *AppEvaluationManager) GetBreaker(appID string) *circuit.Breaker

func (*AppEvaluationManager) SetCoolDownExpired

func (a *AppEvaluationManager) SetCoolDownExpired(appID string, expiredAt int64)

func (*AppEvaluationManager) Start

func (a *AppEvaluationManager) Start()

func (*AppEvaluationManager) Stop

func (a *AppEvaluationManager) Stop()

type ConsumeAppMonitorMap

type ConsumeAppMonitorMap func(map[string][]*models.Trigger, chan []*models.Trigger)

type Evaluator

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

func NewEvaluator

func NewEvaluator(logger lager.Logger, httpClient *http.Client, scalingEngineUrl string, triggerChan chan []*models.Trigger,
	defaultBreachDurationSecs int, queryAppMetrics aggregator.QueryAppMetricsFunc, getBreaker func(string) *circuit.Breaker, setCoolDownExpired func(string, int64)) *Evaluator

func (*Evaluator) Start

func (e *Evaluator) Start()

func (*Evaluator) Stop

func (e *Evaluator) Stop()