diff --git a/CHANGELOG.md b/CHANGELOG.md index 603841318..6b48fd647 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,8 @@ - Enable by default and promote to Production Ready - JWT Rotation Feature, TLS Rotation Feature - Deprecate K8S < 1.16 - Fix Upgrade procedure to safely evict pods during upgrade +- Fix Panics in Deployments without authentication +- Fix ChaosMonkey mode ## [1.0.8](https://github.com/arangodb/kube-arangodb/tree/1.0.8) (2020-09-10) - Fix Volume rotation on AKS diff --git a/pkg/deployment/context_impl.go b/pkg/deployment/context_impl.go index 6fe1249ab..f1cf0279e 100644 --- a/pkg/deployment/context_impl.go +++ b/pkg/deployment/context_impl.go @@ -570,3 +570,22 @@ func (d *Deployment) SecretsInterface() k8sutil.SecretInterface { func (d *Deployment) GetName() string { return d.apiObject.GetName() } + +func (d *Deployment) GetOwnedPods() ([]v1.Pod, error) { + pods, err := d.GetKubeCli().CoreV1().Pods(d.apiObject.GetNamespace()).List(meta.ListOptions{}) + if err != nil { + return nil, err + } + + podList := make([]v1.Pod, 0, len(pods.Items)) + + for _, p := range pods.Items { + if !d.isOwnerOf(&p) { + continue + } + c := p.DeepCopy() + podList = append(podList, *c) + } + + return podList, nil +} diff --git a/pkg/deployment/deployment.go b/pkg/deployment/deployment.go index f55a38415..75985b7fc 100644 --- a/pkg/deployment/deployment.go +++ b/pkg/deployment/deployment.go @@ -164,10 +164,10 @@ func New(config Config, deps Dependencies, apiObject *api.ArangoDeployment) (*De go d.resources.RunDeploymentHealthLoop(d.stopCh) go d.resources.RunDeploymentShardSyncLoop(d.stopCh) } - //if config.AllowChaos { - // d.chaosMonkey = chaos.NewMonkey(deps.Log, d) - // go d.chaosMonkey.Run(d.stopCh) - //} + if config.AllowChaos { + d.chaosMonkey = chaos.NewMonkey(deps.Log, d) + go d.chaosMonkey.Run(d.stopCh) + } return d, nil }