kubelatte-ce

1
package leader
2

3
import (
4
	"errors"
5
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/permission"
6
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/utils"
7
	"net/http"
8
)
9

10
func Healthz(_ *http.Request) error {
11
	if utils.IsControllerNeeded("template") && initMgr != nil && initMgr.DoesTemplatesExist() && templateR != nil && !templateR.HealthCheck() {
12
		return errors.New("TemplateController is not initialized")
13
	}
14
	if utils.IsControllerNeeded("trigger") && initMgr != nil && initMgr.DoesTriggersExist() && triggerR != nil && !triggerR.HealthCheck() {
15
		return errors.New("TriggerController is not initialized")
16
	}
17
	if utils.IsControllerNeeded("scope") && initMgr != nil && initMgr.DoesScopesExist() && scopeR != nil && !scopeR.HealthCheck() {
18
		return errors.New("ScopeController is not initialized")
19
	}
20
	return nil
21
}
22

23
func Readyz(_ *http.Request) error {
24
	if !permission.PermissionsSet {
25
		return errors.New("dont have all required permissions")
26
	}
27
	return nil
28
}
29