generator

package
v0.0.0-...-52fabeb Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL