| /* |
| Copyright 2019 Bloomberg Finance LP. |
| |
| 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 solrbackup |
| |
| import ( |
| "testing" |
| "time" |
| |
| solrv1beta1 "github.com/bloomberg/solr-operator/pkg/apis/solr/v1beta1" |
| "github.com/onsi/gomega" |
| "golang.org/x/net/context" |
| apierrors "k8s.io/apimachinery/pkg/api/errors" |
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" |
| "sigs.k8s.io/controller-runtime/pkg/client" |
| "sigs.k8s.io/controller-runtime/pkg/manager" |
| ) |
| |
| var c client.Client |
| |
| const timeout = time.Second * 5 |
| |
| func TestReconcile(t *testing.T) { |
| g := gomega.NewGomegaWithT(t) |
| instance := &solrv1beta1.SolrBackup{ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: "default"}} |
| |
| // Setup the Manager and Controller. Wrap the Controller Reconcile function so it writes each request to a |
| // channel when it is finished. |
| mgr, err := manager.New(cfg, manager.Options{}) |
| g.Expect(err).NotTo(gomega.HaveOccurred()) |
| c = mgr.GetClient() |
| |
| recFn, _ := SetupTestReconcile(newReconciler(mgr)) |
| g.Expect(add(mgr, recFn)).NotTo(gomega.HaveOccurred()) |
| |
| stopMgr, mgrStopped := StartTestManager(mgr, g) |
| |
| defer func() { |
| close(stopMgr) |
| mgrStopped.Wait() |
| }() |
| |
| // Create the SolrBackup object and expect the Reconcile and Deployment to be created |
| err = c.Create(context.TODO(), instance) |
| // The instance object may not be a valid object because it might be missing some required fields. |
| // Please modify the instance object by adding required fields and then remove the following if statement. |
| if apierrors.IsInvalid(err) { |
| t.Logf("failed to create object, got an invalid object error: %v", err) |
| return |
| } |
| g.Expect(err).NotTo(gomega.HaveOccurred()) |
| defer c.Delete(context.TODO(), instance) |
| |
| } |