controllers

package

v0.3.1 Latest Latest Go to latest Published: Jul 24, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KuberController struct {
	Logger *logrus.Logger
}

func (i *KuberController) CheckComponent(ComponentMeta map[string]string) error

func (i *KuberController) RunTask(taskMeta map[string]string, componentMeta map[string]string) error

func (i *KuberController) ValideComponent(ComponentMeta map[string]string) error

func (i *KuberController) ValideTask(TaskMeta map[string]string) error

type PromQLMonitorController struct {
	// contains filtered or unexported fields
}

func NewPromQLMonitorController(logger *logrus.Logger, apiURL string) *PromQLMonitorController

func (p *PromQLMonitorController) CheckMonitoring(config map[string]string) error

CheckMonitoring — по сути alias для RunCheck, или можешь добавить дополнительную логику

func (p *PromQLMonitorController) RunCheck(monitorMeta map[string]string) error

RunCheck выполняет запрос к Prometheus API и анализирует результат

func (p *PromQLMonitorController) ValidateCheck(monitorMeta map[string]string) error

ValidateCheck проверяет корректность параметров запроса PromQL

func (p *PromQLMonitorController) ValidateMonitoring(config map[string]string) error

ValidateMonitoring — здесь можно проверить конфиг мониторинга, например, таймауты, повторные попытки и т.д. Для упрощения — просто возвращаем nil

type PrometheusQueryData struct {
	ResultType string                  `json:"resultType"`
	Result     []PrometheusQueryResult `json:"result"`
}

type PrometheusQueryResponse struct {
	Status string              `json:"status"`
	Data   PrometheusQueryData `json:"data"`
}

type PrometheusQueryResult struct {
	Metric map[string]string `json:"metric"`
	Value  [2]interface{}    `json:"value"` // [ timestamp, value ]
}

type SSHController struct {
	Logger *logrus.Logger
}

func (s *SSHController) CheckComponent(componentMeta map[string]string) error

func (s *SSHController) RunTask(taskMeta map[string]string, componentMeta map[string]string) error

func (s *SSHController) ValideComponent(componentMeta map[string]string) error

func (s *SSHController) ValideTask(taskMeta map[string]string) error