kubelatte-ce

1
package leader
2

3
import (
4
	controllers2 "gitverse.ru/synapse/kubelatte/pkg/operator/controllers/controllers"
5
	initmanager "gitverse.ru/synapse/kubelatte/pkg/operator/init_manager"
6
	"net/http"
7
	"testing"
8
)
9

10
func Test_readyz(t *testing.T) {
11
	t.Run("err: no required permissions", func(t *testing.T) {
12
		err := Readyz(&http.Request{})
13
		if err == nil {
14
			t.Fatal("Err expected, got nil")
15
		}
16
	})
17
}
18

19
func Test_healthz(t *testing.T) {
20
	var wantErr bool
21

22
	t.Run("No_resources_in_cluster", func(t *testing.T) {
23
		wantErr = false
24

25
		if err := Healthz(nil); (err != nil) != wantErr {
26
			t.Errorf("healthz() error = %v, wantErr %v", err, wantErr)
27
		}
28
	})
29

30
	t.Run("Each_controller_is_not_initialized", func(t *testing.T) {
31
		wantErr = false
32

33
		if err := Healthz(nil); (err != nil) != wantErr {
34
			t.Errorf("healthz() error = %v, wantErr %v", err, wantErr)
35
		}
36
	})
37

38
	t.Run("Each_controller_is_not_started", func(t *testing.T) {
39
		wantErr = true
40

41
		initMgr = initmanager.NewInitManager(nil)
42
		triggerR = &controllers2.TriggerReconciler{}
43
		templateR = &controllers2.TemplateReconciler{}
44
		scopeR = &controllers2.ScopeReconciler{}
45
		if err := Healthz(nil); (err != nil) != wantErr {
46
			t.Errorf("healthz() error = %v, wantErr %v", err, wantErr)
47
		}
48
	})
49
}
50