type Scaler … // NewScaler get a scaler for a given resource func NewScaler(scalesGetter scaleclient.ScalesGetter) Scaler { … } type ScalePrecondition … type PreconditionError … func (pe PreconditionError) Error() string { … } type RetryParams … func NewRetryParams(interval, timeout time.Duration) *RetryParams { … } // ScaleCondition is a closure around Scale that facilitates retries via util.wait func ScaleCondition(r Scaler, precondition *ScalePrecondition, namespace, name string, count uint, updatedResourceVersion *string, gvr schema.GroupVersionResource, dryRun bool) wait.ConditionFunc { … } // validateGeneric ensures that the preconditions match. Returns nil if they are valid, otherwise an error func (precondition *ScalePrecondition) validate(scale *autoscalingv1.Scale) error { … } type genericScaler … var _ … // ScaleSimple updates a scale of a given resource. It returns the resourceVersion of the scale if the update was successful. func (s *genericScaler) ScaleSimple(namespace, name string, preconditions *ScalePrecondition, newSize uint, gvr schema.GroupVersionResource, dryRun bool) (updatedResourceVersion string, err error) { … } // Scale updates a scale of a given resource to a new size, with optional precondition check (if preconditions is not nil), // optional retries (if retry is not nil), and then optionally waits for the status to reach desired count. func (s *genericScaler) Scale(namespace, resourceName string, newSize uint, preconditions *ScalePrecondition, retry, waitForReplicas *RetryParams, gvr schema.GroupVersionResource, dryRun bool) error { … } // scaleHasDesiredReplicas returns a condition that will be true if and only if the desired replica // count for a scale (Spec) equals its updated replicas count (Status) func scaleHasDesiredReplicas(sClient scaleclient.ScalesGetter, gr schema.GroupResource, resourceName string, namespace string, desiredReplicas int32) wait.ConditionFunc { … } // WaitForScaleHasDesiredReplicas waits until condition scaleHasDesiredReplicas is satisfied // or returns error when timeout happens func WaitForScaleHasDesiredReplicas(sClient scaleclient.ScalesGetter, gr schema.GroupResource, resourceName string, namespace string, newSize uint, waitForReplicas *RetryParams) error { … }
Codebase Browser
kubernetes