Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCmdScale ¶
NewCmdScale returns a cobra command with the appropriate configuration and flags to run scale
func ScaleJob ¶
func ScaleJob(info *resource.Info, jobsClient batchclient.JobsGetter, count uint, preconditions *kubectl.ScalePrecondition, retry, waitForReplicas *kubectl.RetryParams) error
Types ¶
type JobPsuedoScaler ¶
type JobPsuedoScaler struct {
JobsClient batchclient.JobsGetter
}
JobPsuedoScaler is a deprecated scale-similar thing that doesn't obey scale semantics
func (*JobPsuedoScaler) Scale ¶
func (scaler *JobPsuedoScaler) Scale(namespace, name string, newSize uint, preconditions *ScalePrecondition, retry, waitForReplicas *RetryParams) error
Scale updates a Job 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 parallelism to reach desired number, which can be less than requested based on job's current progress.
func (*JobPsuedoScaler) ScaleSimple ¶
func (scaler *JobPsuedoScaler) ScaleSimple(namespace, name string, preconditions *ScalePrecondition, newSize uint) (string, error)
ScaleSimple is responsible for updating job's parallelism. It returns the resourceVersion of the job if the update is successful.
type PreconditionError ¶
PreconditionError is a deprecated error
func (PreconditionError) Error ¶
func (pe PreconditionError) Error() string
type RetryParams ¶
RetryParams is a deprecated retry struct
type ScaleOptions ¶
type ScaleOptions struct {
FilenameOptions resource.FilenameOptions
RecordFlags *genericclioptions.RecordFlags
PrintFlags *genericclioptions.PrintFlags
PrintObj printers.ResourcePrinterFunc
Selector string
All bool
Replicas int
ResourceVersion string
CurrentReplicas int
Timeout time.Duration
Recorder genericclioptions.Recorder
genericclioptions.IOStreams
// contains filtered or unexported fields
}
func NewScaleOptions ¶
func NewScaleOptions(ioStreams genericclioptions.IOStreams) *ScaleOptions
func (*ScaleOptions) RunScale ¶
func (o *ScaleOptions) RunScale() error
RunScale executes the scaling
type ScalePrecondition ¶
ScalePrecondition is a deprecated precondition
Source Files