ehpa

package

v0.2.0 Latest Latest Go to latest Published: Feb 17, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gocrane/crane

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetPredictionMetricName(Name v1.ResourceName) (string, error)
func IsPredictionEnabled(ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) bool
func RecordMetrics(ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler)
type EffectiveHPAController
type EhpaControllerConfig
type EhpaControllerPropagationConfig
type HPAReplicasController
- func (c *HPAReplicasController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (c *HPAReplicasController) SetupWithManager(mgr ctrl.Manager) error
type SubstituteController
- func (c *SubstituteController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (c *SubstituteController) SetupWithManager(mgr ctrl.Manager) error

Constants ¶

View Source

const (
	RsyncPeriod = 15 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func GetPredictionMetricName ¶

func GetPredictionMetricName(Name v1.ResourceName) (string, error)

GetPredictionMetricName return metric name used by prediction

func IsPredictionEnabled ¶

func IsPredictionEnabled(ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) bool

func RecordMetrics ¶

func RecordMetrics(ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler)

Types ¶

type EffectiveHPAController ¶

type EffectiveHPAController struct {
	client.Client
	Scheme      *runtime.Scheme
	RestMapper  meta.RESTMapper
	Recorder    record.EventRecorder
	ScaleClient scale.ScalesGetter
	K8SVersion  *version.Version
	Config      EhpaControllerConfig
}

EffectiveHPAController is responsible for scaling workload's replica based on EffectiveHorizontalPodAutoscaler spec

func (*EffectiveHPAController) CreateHPA ¶

func (c *EffectiveHPAController) CreateHPA(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, substitute *autoscalingapi.Substitute) (*autoscalingv2.HorizontalPodAutoscaler, error)

func (*EffectiveHPAController) CreatePrediction ¶

func (c *EffectiveHPAController) CreatePrediction(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) (*predictionapi.TimeSeriesPrediction, error)

func (*EffectiveHPAController) CreateSubstitute ¶

func (c *EffectiveHPAController) CreateSubstitute(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, scale *autoscalingapiv1.Scale) (*autoscalingapi.Substitute, error)

func (*EffectiveHPAController) GetHPA ¶

func (c *EffectiveHPAController) GetHPA(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) (*autoscalingv2.HorizontalPodAutoscaler, error)

func (*EffectiveHPAController) GetHPAMetrics ¶

func (c *EffectiveHPAController) GetHPAMetrics(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) ([]autoscalingv2.MetricSpec, error)

GetHPAMetrics loop metricSpec in EffectiveHorizontalPodAutoscaler and generate metricSpec for HPA

func (*EffectiveHPAController) GetPredication ¶

func (c *EffectiveHPAController) GetPredication(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) (*predictionapi.TimeSeriesPrediction, error)

func (*EffectiveHPAController) NewHPAObject ¶

func (c *EffectiveHPAController) NewHPAObject(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, substitute *autoscalingapi.Substitute) (*autoscalingv2.HorizontalPodAutoscaler, error)

func (*EffectiveHPAController) NewPredictionObject ¶

func (c *EffectiveHPAController) NewPredictionObject(ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) (*predictionapi.TimeSeriesPrediction, error)

func (*EffectiveHPAController) NewSubstituteObject ¶

func (c *EffectiveHPAController) NewSubstituteObject(ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, scale *autoscalingapiv1.Scale) (*autoscalingapi.Substitute, error)

func (*EffectiveHPAController) Reconcile ¶

func (c *EffectiveHPAController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*EffectiveHPAController) ReconcileHPA ¶

func (c *EffectiveHPAController) ReconcileHPA(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, substitute *autoscalingapi.Substitute) (*autoscalingv2.HorizontalPodAutoscaler, error)

func (*EffectiveHPAController) ReconcilePredication ¶

func (c *EffectiveHPAController) ReconcilePredication(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler) (*predictionapi.TimeSeriesPrediction, error)

func (*EffectiveHPAController) ReconcileSubstitute ¶

func (c *EffectiveHPAController) ReconcileSubstitute(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, scale *autoscalingapiv1.Scale) (*autoscalingapi.Substitute, error)

func (*EffectiveHPAController) SetupWithManager ¶

func (c *EffectiveHPAController) SetupWithManager(mgr ctrl.Manager) error

func (*EffectiveHPAController) UpdateHPAIfNeed ¶

func (c *EffectiveHPAController) UpdateHPAIfNeed(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, hpaExist *autoscalingv2.HorizontalPodAutoscaler, substitute *autoscalingapi.Substitute) (*autoscalingv2.HorizontalPodAutoscaler, error)

func (*EffectiveHPAController) UpdatePredictionIfNeed ¶

func (c *EffectiveHPAController) UpdatePredictionIfNeed(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, predictionExist *predictionapi.TimeSeriesPrediction) (*predictionapi.TimeSeriesPrediction, error)

func (*EffectiveHPAController) UpdateStatus ¶

func (c *EffectiveHPAController) UpdateStatus(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, newStatus *autoscalingapi.EffectiveHorizontalPodAutoscalerStatus)

func (*EffectiveHPAController) UpdateSubstituteIfNeed ¶

func (c *EffectiveHPAController) UpdateSubstituteIfNeed(ctx context.Context, ehpa *autoscalingapi.EffectiveHorizontalPodAutoscaler, substituteExist *autoscalingapi.Substitute, scale *autoscalingapiv1.Scale) (*autoscalingapi.Substitute, error)

type EhpaControllerConfig ¶ added in v0.2.0

type EhpaControllerConfig struct {
	PropagationConfig EhpaControllerPropagationConfig
}

type EhpaControllerPropagationConfig ¶ added in v0.2.0

type EhpaControllerPropagationConfig struct {
	LabelPrefixes      []string
	AnnotationPrefixes []string
	Labels             []string
	Annotations        []string
}

type HPAReplicasController ¶

type HPAReplicasController struct {
	client.Client
	Scheme     *runtime.Scheme
	RestMapper meta.RESTMapper
	Recorder   record.EventRecorder
}

HPAReplicasController is responsible for monitor and export replicas for hpa

func (*HPAReplicasController) Reconcile ¶

func (c *HPAReplicasController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HPAReplicasController) SetupWithManager ¶

func (c *HPAReplicasController) SetupWithManager(mgr ctrl.Manager) error

type SubstituteController ¶

type SubstituteController struct {
	client.Client
	Scheme      *runtime.Scheme
	RestMapper  meta.RESTMapper
	Recorder    record.EventRecorder
	ScaleClient scale.ScalesGetter
}

SubstituteController is responsible for sync labelSelector to Substitute

func (*SubstituteController) Reconcile ¶

func (c *SubstituteController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SubstituteController) SetupWithManager ¶

func (c *SubstituteController) SetupWithManager(mgr ctrl.Manager) error

Source Files ¶

View all Source files

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