Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ allall: all
# Tip: Run `eval $(minikube docker-env)` before calling make if you're developing on minikube.
#

GOLANGCI_ENABLED=deadcode govet ineffassign staticcheck structcheck typecheck unconvert unparam unused varcheck
GOLANGCI_ENABLED=deadcode gosimple govet ineffassign staticcheck structcheck typecheck unconvert unparam unused varcheck
#GOLANGCI_ENABLED=gocyclo goconst golint maligned errcheck interfacer megacheck
#GOLANGCI_ENABLED+=dupl - disable dupl check

Expand Down
4 changes: 1 addition & 3 deletions pkg/apis/shared/errors.go
Original file line number Diff line number Diff line change
Expand Up @@ -126,9 +126,7 @@ func WithErrors(errs ...error) error {

switch errType := err.(type) {
case MergedErrors:
for _, subError := range errType.errors {
filteredErrs = append(filteredErrs, subError)
}
filteredErrs = append(filteredErrs, errType.errors...)
default:
filteredErrs = append(filteredErrs, err)
}
Expand Down
25 changes: 10 additions & 15 deletions pkg/deployment/pod/affinity.go
Original file line number Diff line number Diff line change
Expand Up @@ -92,37 +92,32 @@ func MergePodAntiAffinity(a, b *core.PodAntiAffinity) {
return
}

for _, rule := range b.PreferredDuringSchedulingIgnoredDuringExecution {
a.PreferredDuringSchedulingIgnoredDuringExecution = append(a.PreferredDuringSchedulingIgnoredDuringExecution, rule)
}
a.PreferredDuringSchedulingIgnoredDuringExecution = append(a.PreferredDuringSchedulingIgnoredDuringExecution,
b.PreferredDuringSchedulingIgnoredDuringExecution...)

for _, rule := range b.RequiredDuringSchedulingIgnoredDuringExecution {
a.RequiredDuringSchedulingIgnoredDuringExecution = append(a.RequiredDuringSchedulingIgnoredDuringExecution, rule)
}
a.RequiredDuringSchedulingIgnoredDuringExecution = append(a.RequiredDuringSchedulingIgnoredDuringExecution,
b.RequiredDuringSchedulingIgnoredDuringExecution...)
}

func MergePodAffinity(a, b *core.PodAffinity) {
if a == nil || b == nil {
return
}

for _, rule := range b.PreferredDuringSchedulingIgnoredDuringExecution {
a.PreferredDuringSchedulingIgnoredDuringExecution = append(a.PreferredDuringSchedulingIgnoredDuringExecution, rule)
}
a.PreferredDuringSchedulingIgnoredDuringExecution = append(a.PreferredDuringSchedulingIgnoredDuringExecution,
b.PreferredDuringSchedulingIgnoredDuringExecution...)

for _, rule := range b.RequiredDuringSchedulingIgnoredDuringExecution {
a.RequiredDuringSchedulingIgnoredDuringExecution = append(a.RequiredDuringSchedulingIgnoredDuringExecution, rule)
}
a.RequiredDuringSchedulingIgnoredDuringExecution = append(a.RequiredDuringSchedulingIgnoredDuringExecution,
b.RequiredDuringSchedulingIgnoredDuringExecution...)
}

func MergeNodeAffinity(a, b *core.NodeAffinity) {
if a == nil || b == nil {
return
}

for _, rule := range b.PreferredDuringSchedulingIgnoredDuringExecution {
a.PreferredDuringSchedulingIgnoredDuringExecution = append(a.PreferredDuringSchedulingIgnoredDuringExecution, rule)
}
a.PreferredDuringSchedulingIgnoredDuringExecution = append(a.PreferredDuringSchedulingIgnoredDuringExecution,
b.PreferredDuringSchedulingIgnoredDuringExecution...)

var newSelectorTerms []core.NodeSelectorTerm

Expand Down
5 changes: 2 additions & 3 deletions pkg/deployment/reconcile/action_bootstrap_update.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@ package reconcile

import (
"context"
"fmt"

api "github.com/arangodb/kube-arangodb/pkg/apis/deployment/v1"
"github.com/rs/zerolog"
Expand Down Expand Up @@ -53,8 +52,8 @@ type actionBootstrapUpdate struct {
func (a actionBootstrapUpdate) Start(ctx context.Context) (bool, error) {
if err := a.actionCtx.WithStatusUpdate(ctx, func(status *api.DeploymentStatus) bool {
if errMessage, ok := a.action.GetParam("error"); ok {
status.Conditions.Update(api.ConditionTypeBootstrapCompleted, true, "Bootstrap failed", fmt.Sprintf("%s", errMessage))
status.Conditions.Update(api.ConditionTypeBootstrapSucceded, false, "Bootstrap failed", fmt.Sprintf("%s", errMessage))
status.Conditions.Update(api.ConditionTypeBootstrapCompleted, true, "Bootstrap failed", errMessage)
status.Conditions.Update(api.ConditionTypeBootstrapSucceded, false, "Bootstrap failed", errMessage)
} else {
status.Conditions.Update(api.ConditionTypeBootstrapCompleted, true, "Bootstrap successful", "The bootstrap process has been completed successfully")
status.Conditions.Update(api.ConditionTypeBootstrapSucceded, true, "Bootstrap successful", "The bootstrap process has been completed successfully")
Expand Down
6 changes: 1 addition & 5 deletions pkg/deployment/reconcile/plan_builder_encryption.go
Original file line number Diff line number Diff line change
Expand Up @@ -176,11 +176,7 @@ func createEncryptionKeyStatusUpdateRequired(log zerolog.Logger, spec api.Deploy

keyHashes := secretKeysToListWithPrefix(keyfolder)

if !util.CompareStringArray(keyHashes, status.Hashes.Encryption.Keys) {
return true
}

return false
return !util.CompareStringArray(keyHashes, status.Hashes.Encryption.Keys)
}

func createEncryptionKeyCleanPlan(ctx context.Context,
Expand Down
16 changes: 3 additions & 13 deletions pkg/deployment/reconcile/plan_builder_jwt.go
Original file line number Diff line number Diff line change
Expand Up @@ -183,10 +183,7 @@ func createJWTStatusUpdateRequired(log zerolog.Logger, apiObject k8sutil.APIObje
}

if len(f.Data) == 0 {
if status.Hashes.JWT.Passive != nil {
return true
}
return false
return status.Hashes.JWT.Passive != nil
}

var keys []string
Expand All @@ -200,20 +197,13 @@ func createJWTStatusUpdateRequired(log zerolog.Logger, apiObject k8sutil.APIObje
}

if len(keys) == 0 {
if status.Hashes.JWT.Passive != nil {
return true
}
return false
return status.Hashes.JWT.Passive != nil
}

sort.Strings(keys)
keys = util.PrefixStringArray(keys, "sha256:")

if !util.CompareStringArray(keys, status.Hashes.JWT.Passive) {
return true
}

return false
return !util.CompareStringArray(keys, status.Hashes.JWT.Passive)
}

func areJWTTokensUpToDate(ctx context.Context, log zerolog.Logger, status api.DeploymentStatus,
Expand Down
5 changes: 1 addition & 4 deletions pkg/util/k8sutil/pair.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,10 +115,7 @@ func (o OptionPairs) Unique() OptionPairs {

func (o OptionPairs) Copy() OptionPairs {
r := make(OptionPairs, len(o))

for id, option := range o {
r[id] = option
}
copy(r, o)

return r
}
Expand Down