kubernetes
/
autoscaler
mirror of https://github.com/kubernetes/autoscaler.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add NoOpScaleUpStatusProcessor 

This will be useful for the purposes of testing.
This commit is contained in:
Beata Skiba 2018-06-07 15:11:15 +02:00
parent b8ae6df5d3
commit e9d2afda21
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
cluster-autoscaler/processors/status/scale_up_status_processor.go
View File

@ -33,12 +33,19 @@ type ScaleUpStatus struct {
PodsAwaitEvaluation []*apiv1.Pod PodsAwaitEvaluation []*apiv1.Pod
} }
// ScaleUpStatusProcessor processes the state of the cluster after a scale-up. // ScaleUpStatusProcessor processes the status of the cluster after a scale-up.
type ScaleUpStatusProcessor interface { type ScaleUpStatusProcessor interface {
Process(context *context.AutoscalingContext, state *ScaleUpStatus) Process(context *context.AutoscalingContext, status *ScaleUpStatus)
} }
// NewDefaultScaleUpStatusProcessor creates a default instance of ScaleUpStatusProcessor. // NewDefaultScaleUpStatusProcessor creates a default instance of ScaleUpStatusProcessor.
func NewDefaultScaleUpStatusProcessor() ScaleUpStatusProcessor { func NewDefaultScaleUpStatusProcessor() ScaleUpStatusProcessor {
return &EventingScaleUpStatusProcessor{} return &EventingScaleUpStatusProcessor{}
} }
// NoOpScaleUpStatusProcessor is a ScaleUpStatusProcessor implementations useful for testing.
type NoOpScaleUpStatusProcessor struct{}
// Process processes the status of the cluster after a scale-up.
func (p *NoOpScaleUpStatusProcessor) Process(context *context.AutoscalingContext, status *ScaleUpStatus) {
}