mirror of
https://github.com/vmware-tanzu/velero.git
synced 2026-02-09 21:40:17 +00:00
368098b727
Instead of converting the unstructured item to check for the presence of the `kube-aggregator.kubernetes.io/automanaged` label, use this label in the `AppliesTo` to enable the restore logic to select the item. This means that any item that matches the selector will have restore skipped. Also add a new test case to the restore action test to check that label selectors are applied correctly. Signed-off-by: Bridget McErlean <bmcerlean@vmware.com>
52 lines
1.8 KiB
Go
52 lines
1.8 KiB
Go
/*
|
|
Copyright the Velero contributors.
|
|
|
|
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 restore
|
|
|
|
import (
|
|
"github.com/sirupsen/logrus"
|
|
"k8s.io/kube-aggregator/pkg/controllers/autoregister"
|
|
|
|
"github.com/vmware-tanzu/velero/pkg/plugin/velero"
|
|
)
|
|
|
|
type APIServiceAction struct {
|
|
logger logrus.FieldLogger
|
|
}
|
|
|
|
// NewAPIServiceAction returns an APIServiceAction which is a RestoreItemAction plugin
|
|
// that will skip the restore of any APIServices which are managed by Kubernetes. This
|
|
// is determined by looking for the "kube-aggregator.kubernetes.io/automanaged" label on
|
|
// the APIService.
|
|
func NewAPIServiceAction(logger logrus.FieldLogger) *APIServiceAction {
|
|
return &APIServiceAction{logger: logger}
|
|
}
|
|
|
|
func (a *APIServiceAction) AppliesTo() (velero.ResourceSelector, error) {
|
|
return velero.ResourceSelector{
|
|
IncludedResources: []string{"apiservices"},
|
|
LabelSelector: autoregister.AutoRegisterManagedLabel,
|
|
}, nil
|
|
}
|
|
|
|
func (a *APIServiceAction) Execute(input *velero.RestoreItemActionExecuteInput) (*velero.RestoreItemActionExecuteOutput, error) {
|
|
a.logger.Info("Executing APIServiceAction")
|
|
defer a.logger.Info("Done executing APIServiceAction")
|
|
|
|
a.logger.Infof("Skipping restore of APIService as it is managed by Kubernetes")
|
|
return velero.NewRestoreItemActionExecuteOutput(input.Item).WithoutRestore(), nil
|
|
}
|