mirror of
https://github.com/fluxcd/flux2.git
synced 2025-10-27 20:55:09 +08:00
42607aadc3
This change adds support for running `suspend/resume` on multiple supported resources at the same time. This improves the user experience by converting ``` flux suspend ks operator && \ flux suspend ks database && \ flux suspend ks app ``` to ``` flux suspend ks operator database app ``` This works for all types of resources (Kustomizations, Sources, etc.) since it has been implemented at the `suspend.go` and `resume.go` level. When the `--wait` flag is passed to the `resume` command, then Flux will wait for all resources in parallel within a goroutine each. Each object is only processed once, even if user provided its name more than once. If suspension or resuming fails for one object, it is still carried out for the remaining objects. As a special case, the old behaviour of `resume` is retained, i.e. when only one object name is provided, `resume` waits for the object to become ready even if the `--wait` flag is not provided. In all other cases the `--wait` flag is always considered. closes #3746 closes #3793 Co-Authored-By: Max Jonas Werner <mail@makk.es> Signed-off-by: Rishikesh Nair <alienware505@gmail.com> Signed-off-by: Max Jonas Werner <mail@makk.es>
83 lines
2.5 KiB
Go
83 lines
2.5 KiB
Go
/*
|
|
Copyright 2020 The Flux authors
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package main
|
|
|
|
import (
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
)
|
|
|
|
// Most commands need one or both of the kind (e.g.,
|
|
// `"ImageRepository"`) and a human-palatable name for the kind (e.g.,
|
|
// `"image repository"`), to be interpolated into output. It's
|
|
// convenient to package these up ahead of time, then the command
|
|
// implementation can pick whichever it wants to use.
|
|
type apiType struct {
|
|
kind, humanKind string
|
|
groupVersion schema.GroupVersion
|
|
}
|
|
|
|
// adapter is an interface for a wrapper or alias from which we can
|
|
// get a controller-runtime deserialisable value. This is used so that
|
|
// you can wrap an API type to give it other useful methods, but still
|
|
// use values of the wrapper with `client.Client`, which only deals
|
|
// with types that have been added to the schema.
|
|
type adapter interface {
|
|
asClientObject() client.Object
|
|
}
|
|
|
|
// copyable is an interface for a wrapper or alias from which we can
|
|
// get a deep copied client.Object, required when you e.g. want to
|
|
// calculate a patch.
|
|
type copyable interface {
|
|
deepCopyClientObject() client.Object
|
|
}
|
|
|
|
// listAdapter is the analogue to adapter, but for lists; the
|
|
// controller runtime distinguishes between methods dealing with
|
|
// objects and lists.
|
|
type listAdapter interface {
|
|
asClientList() client.ObjectList
|
|
len() int
|
|
}
|
|
|
|
// universalAdapter is an adapter for any client.Object. Use this if
|
|
// there are no other methods needed.
|
|
type universalAdapter struct {
|
|
obj client.Object
|
|
}
|
|
|
|
func (c universalAdapter) asClientObject() client.Object {
|
|
return c.obj
|
|
}
|
|
|
|
// named is for adapters that have Name and Namespace fields, which
|
|
// are sometimes handy to get hold of. ObjectMeta implements these, so
|
|
// they shouldn't need any extra work.
|
|
type named interface {
|
|
GetName() string
|
|
GetNamespace() string
|
|
GetObjectKind() schema.ObjectKind
|
|
SetName(string)
|
|
SetNamespace(string)
|
|
}
|
|
|
|
func copyName(target, source named) {
|
|
target.SetName(source.GetName())
|
|
target.SetNamespace(source.GetNamespace())
|
|
}
|