Skip to content
Closed
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
35 changes: 11 additions & 24 deletions pkg/resource-handler/controller/etcd/service_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@ func TestBuildHeadlessService(t *testing.T) {
scheme := runtime.NewScheme()
_ = multigresv1alpha1.AddToScheme(scheme)

// NOTE: error path is tested as a part of the reconciliation loop.
tests := map[string]struct {
etcd *multigresv1alpha1.Etcd
scheme *runtime.Scheme
want *corev1.Service
wantErr bool
etcd *multigresv1alpha1.Etcd
scheme *runtime.Scheme
want *corev1.Service
}{
"minimal spec": {
etcd: &multigresv1alpha1.Etcd{
Expand Down Expand Up @@ -151,14 +151,8 @@ func TestBuildHeadlessService(t *testing.T) {
for name, tc := range tests {
t.Run(name, func(t *testing.T) {
got, err := BuildHeadlessService(tc.etcd, tc.scheme)

if (err != nil) != tc.wantErr {
t.Errorf("BuildHeadlessService() error = %v, wantErr %v", err, tc.wantErr)
return
}

if tc.wantErr {
return
if err != nil {
t.Fatalf("BuildHeadlessService() unexpected error: %v", err)
}

if diff := cmp.Diff(tc.want, got); diff != "" {
Expand All @@ -173,10 +167,9 @@ func TestBuildClientService(t *testing.T) {
_ = multigresv1alpha1.AddToScheme(scheme)

tests := map[string]struct {
etcd *multigresv1alpha1.Etcd
scheme *runtime.Scheme
want *corev1.Service
wantErr bool
etcd *multigresv1alpha1.Etcd
scheme *runtime.Scheme
want *corev1.Service
}{
"minimal spec": {
etcd: &multigresv1alpha1.Etcd{
Expand Down Expand Up @@ -293,14 +286,8 @@ func TestBuildClientService(t *testing.T) {
for name, tc := range tests {
t.Run(name, func(t *testing.T) {
got, err := BuildClientService(tc.etcd, tc.scheme)

if (err != nil) != tc.wantErr {
t.Errorf("BuildClientService() error = %v, wantErr %v", err, tc.wantErr)
return
}

if tc.wantErr {
return
if err != nil {
t.Fatalf("BuildClientService() unexpected error: %v", err)
}

if diff := cmp.Diff(tc.want, got); diff != "" {
Expand Down
Loading