Skip to content

K
k3s
Commit 60fc0bf7 authored by Ed Bartosh's avatar Ed Bartosh
Browse files
Options

kubeadm: fix golint warnings in package_validator

Fixed the following golint warnigns: - package_validator.go:68:1: receiver name should not be an underscore, omit the name if it is unused - package_validator.go:89:1: receiver name should be a reflection of its identity; don't use generic names such as "this" or "self" - package_validator.go:96:1: receiver name should be a reflection of its identity; don't use generic names such as "this" or "self" - package_validator.go:119:1: receiver name should be a reflection of its identity; don't use generic names such as "this" or "self"
parent a6ba2ebf
Hide whitespace changes
Inline Side-by-side
Showing with 14 additions and 14 deletions
cmd/kubeadm/app/util/system/package_validator.go
View file @ 60fc0bf7
...@@ -65,7 +65,7 @@ func newDPKG() (packageManager, bool) { ...@@ -65,7 +65,7 @@ func newDPKG() (packageManager, bool) {
// getPackageVersion returns the upstream package version for the package given // getPackageVersion returns the upstream package version for the package given
// the packageName, and an error if no such package exists. // the packageName, and an error if no such package exists.
func (_ dpkg) getPackageVersion(packageName string) (string, error) { func (dpkg) getPackageVersion(packageName string) (string, error) {
output, err := exec.Command("dpkg-query", "--show", "--showformat='${Version}'", packageName).Output() output, err := exec.Command("dpkg-query", "--show", "--showformat='${Version}'", packageName).Output()
if err != nil { if err != nil {
return "", pkgerrors.Wrap(err, "dpkg-query failed") return "", pkgerrors.Wrap(err, "dpkg-query failed")
...@@ -86,23 +86,23 @@ type packageValidator struct { ...@@ -86,23 +86,23 @@ type packageValidator struct {
} }
// Name returns the name of the package validator. // Name returns the name of the package validator.
func (self *packageValidator) Name() string { func (validator *packageValidator) Name() string {
return "package" return "package"
} }
// Validate checks packages and their versions against the spec using the // Validate checks packages and their versions against the spec using the
// package manager on the running machine, and returns an error on any // package manager on the running machine, and returns an error on any
// package/version mismatch. // package/version mismatch.
func (self *packageValidator) Validate(spec SysSpec) (error, error) { func (validator *packageValidator) Validate(spec SysSpec) (error, error) {
if len(spec.PackageSpecs) == 0 { if len(spec.PackageSpecs) == 0 {
return nil, nil return nil, nil
} }
var err error var err error
if self.kernelRelease, err = getKernelRelease(); err != nil { if validator.kernelRelease, err = getKernelRelease(); err != nil {
return nil, err return nil, err
} }
if self.osDistro, err = getOSDistro(); err != nil { if validator.osDistro, err = getOSDistro(); err != nil {
return nil, err return nil, err
} }
...@@ -110,17 +110,17 @@ func (self *packageValidator) Validate(spec SysSpec) (error, error) { ...@@ -110,17 +110,17 @@ func (self *packageValidator) Validate(spec SysSpec) (error, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
specs := applyPackageSpecOverride(spec.PackageSpecs, spec.PackageSpecOverrides, self.osDistro) specs := applyPackageSpecOverride(spec.PackageSpecs, spec.PackageSpecOverrides, validator.osDistro)
return self.validate(specs, manager) return validator.validate(specs, manager)
} }
// Validate checks packages and their versions against the packageSpecs using // Validate checks packages and their versions against the packageSpecs using
// the packageManager, and returns an error on any package/version mismatch. // the packageManager, and returns an error on any package/version mismatch.
func (self *packageValidator) validate(packageSpecs []PackageSpec, manager packageManager) (error, error) { func (validator *packageValidator) validate(packageSpecs []PackageSpec, manager packageManager) (error, error) {
var errs []error var errs []error
for _, spec := range packageSpecs { for _, spec := range packageSpecs {
// Substitute variables in package name. // Substitute variables in package name.
packageName := resolvePackageName(spec.Name, self.kernelRelease) packageName := resolvePackageName(spec.Name, validator.kernelRelease)
nameWithVerRange := fmt.Sprintf("%s (%s)", packageName, spec.VersionRange) nameWithVerRange := fmt.Sprintf("%s (%s)", packageName, spec.VersionRange)
...@@ -129,14 +129,14 @@ func (self *packageValidator) validate(packageSpecs []PackageSpec, manager packa ...@@ -129,14 +129,14 @@ func (self *packageValidator) validate(packageSpecs []PackageSpec, manager packa
if err != nil { if err != nil {
klog.V(1).Infof("Failed to get the version for the package %q: %s\n", packageName, err) klog.V(1).Infof("Failed to get the version for the package %q: %s\n", packageName, err)
errs = append(errs, err) errs = append(errs, err)
self.reporter.Report(nameWithVerRange, "not installed", bad) validator.reporter.Report(nameWithVerRange, "not installed", bad)
continue continue
} }
// Version requirement will not be enforced if version range is // Version requirement will not be enforced if version range is
// not specified in the spec. // not specified in the spec.
if spec.VersionRange == "" { if spec.VersionRange == "" {
self.reporter.Report(packageName, version, good) validator.reporter.Report(packageName, version, good)
continue continue
} }
...@@ -147,15 +147,15 @@ func (self *packageValidator) validate(packageSpecs []PackageSpec, manager packa ...@@ -147,15 +147,15 @@ func (self *packageValidator) validate(packageSpecs []PackageSpec, manager packa
if err != nil { if err != nil {
klog.Errorf("Failed to convert %q to semantic version: %s\n", version, err) klog.Errorf("Failed to convert %q to semantic version: %s\n", version, err)
errs = append(errs, err) errs = append(errs, err)
self.reporter.Report(nameWithVerRange, "internal error", bad) validator.reporter.Report(nameWithVerRange, "internal error", bad)
continue continue
} }
versionRange := semver.MustParseRange(toSemVerRange(spec.VersionRange)) versionRange := semver.MustParseRange(toSemVerRange(spec.VersionRange))
if versionRange(sv) { if versionRange(sv) {
self.reporter.Report(nameWithVerRange, version, good) validator.reporter.Report(nameWithVerRange, version, good)
} else { } else {
errs = append(errs, pkgerrors.Errorf("package \"%s %s\" does not meet the spec \"%s (%s)\"", packageName, sv, packageName, spec.VersionRange)) errs = append(errs, pkgerrors.Errorf("package \"%s %s\" does not meet the spec \"%s (%s)\"", packageName, sv, packageName, spec.VersionRange))
self.reporter.Report(nameWithVerRange, version, bad) validator.reporter.Report(nameWithVerRange, version, bad)
} }
} }
return nil, errors.NewAggregate(errs) return nil, errors.NewAggregate(errs)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment