autoscaling

Documentation

Index

• type Base
  • func (c *Base) DeleteMetricsServices(ctx context.Context, pa *pav1alpha1.PodAutoscaler) error
  • func (c *Base) ReconcileMetric(ctx context.Context, pa *pav1alpha1.PodAutoscaler, metricSN string) error
  • func (c *Base) ReconcileSKS(ctx context.Context, pa *pav1alpha1.PodAutoscaler, ...) (*nv1alpha1.ServerlessService, error)
  • func (c *Base) UpdateStatus(desired *pav1alpha1.PodAutoscaler) (*pav1alpha1.PodAutoscaler, error)

Types

type Base

type Base struct {
	*reconciler.Base
	PALister          listers.PodAutoscalerLister
	ServiceLister     corev1listers.ServiceLister
	SKSLister         nlisters.ServerlessServiceLister
	MetricLister      listers.MetricLister
	ConfigStore       reconciler.ConfigStore
	PSInformerFactory duck.InformerFactory
}

Base implements the core controller logic for autoscaling, given a Reconciler.

func (*Base) DeleteMetricsServices

func (c *Base) DeleteMetricsServices(ctx context.Context, pa *pav1alpha1.PodAutoscaler) error

DeleteMetricsServices removes all metrics services for the current PA. TODO(5900): Remove after 0.12 is cut.

func (*Base) ReconcileMetric

func (c *Base) ReconcileMetric(ctx context.Context, pa *pav1alpha1.PodAutoscaler, metricSN string) error

ReconcileMetric reconciles a metric instance out of the given PodAutoscaler to control metric collection.

func (*Base) ReconcileSKS

func (c *Base) ReconcileSKS(ctx context.Context, pa *pav1alpha1.PodAutoscaler, mode nv1alpha1.ServerlessServiceOperationMode) (*nv1alpha1.ServerlessService, error)

ReconcileSKS reconciles a ServerlessService based on the given PodAutoscaler.

func (*Base) UpdateStatus

func (c *Base) UpdateStatus(desired *pav1alpha1.PodAutoscaler) (*pav1alpha1.PodAutoscaler, error)

UpdateStatus updates the status of the given PodAutoscaler.