in internal/testhelpers/resources.go [518:541]
func (cc *TestCaseClient) ExpectContainerCount(ctx context.Context, key types.NamespacedName, count int) error {
var (
got int
deployment = &appsv1.Deployment{}
)
err := RetryUntilSuccess(6, DefaultRetryInterval, func() error {
err := cc.Client.Get(ctx, key, deployment)
if err != nil {
return err
}
got = len(deployment.Spec.Template.Spec.Containers)
if got != count {
return fmt.Errorf("deployment found, got %v, want %v containers", got, count)
}
return nil
})
if err != nil {
return fmt.Errorf("want %v containers, got %v number of containers did not resolve after waiting for reconcile", count, got)
}
return nil
}