healthcheck

type API interface {
	Get(c *gin.Context)
	IsLive(c *gin.Context)
	GetStatus(c *gin.Context)
	GetEnginesOrder(c *gin.Context)
	GetParameters(c *gin.Context)
	UpdateParameters(c *gin.Context)
}

type Edge struct {
	From string `json:"from"`
	To   string `json:"to"`
}

type Engine struct {
	Name             string            `json:"name,omitempty"`
	Instances        *int              `json:"instances,omitempty"`
	MinInstances     *int              `json:"min_instances,omitempty"`
	OptimalInstances *int              `json:"optimal_instances,omitempty"`
	QueueLength      *int              `json:"queue_length,omitempty"`
	Time             *datetime.CpsTime `json:"time,omitempty" swaggertype:"integer"`

	IsRunning             bool `json:"is_running"`
	IsQueueOverflown      bool `json:"is_queue_overflown"`
	IsTooFewInstances     bool `json:"is_too_few_instances"`
	IsDiffInstancesConfig bool `json:"is_diff_instances_config"`
}

type Engines struct {
	Graph      Graph             `json:"graph"`
	Parameters map[string]Engine `json:"parameters"`
}

type Graph struct {
	Nodes []string `json:"nodes"`
	Edges []Edge   `json:"edges"`
}

type Info struct {
	Services []Service `json:"services"`
	Engines  Engines   `json:"engines"`

	MaxQueueLength    int `json:"max_queue_length"`
	MaxMessagesLength int `json:"max_messages_length"`

	HasInvalidEnginesOrder bool `json:"has_invalid_engines_order"`
}

type LiveResponse struct {
	Ok bool `json:"ok"`
}

type Service struct {
	Name      string `json:"name"`
	IsRunning bool   `json:"is_running"`
}

type Status struct {
	Services []Service `json:"services"`
	Engines  []Engine  `json:"engines"`

	HasInvalidEnginesOrder bool `json:"has_invalid_engines_order"`
}

type Store interface {
	Load(ctx context.Context)
	GetInfo() Info
	GetStatus() Status
	GetEnginesOrder() Graph
	GetParameters(ctx context.Context) (config.HealthCheckParameters, error)
	UpdateParameters(ctx context.Context, params config.HealthCheckParameters) (config.HealthCheckParameters, error)
}