resource_controller_interface.go

/*
 *  lvcl is a simple program Clustering libvirt servers
 *  Copyright (C) 2020 Adam Prycki (email: adam.prycki@gmail.com)
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License along
 *  with this program; if not, write to the Free Software Foundation, Inc.,
 *  51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */
package main

import "encoding/json"
import "io/ioutil"

const(
	resource_controller_id_libvirt=iota
	resource_controller_id_docker
	resource_controller_id_dummy
	resource_controller_id_generic
	
	resource_state_starting
	resource_state_running
	resource_state_stopping
	resource_state_stopped
	resource_state_paused
	resource_state_migrating
	resource_state_other
	
	resource_state_nuked
	resource_state_reboot
	resource_state_undefine
	
	
	utilization_hw_cores
	utilization_hw_threads
	utilization_hw_numaNodes
	utilization_hw_core_pre_numa
	utilization_hw_mem
	utilization_vpcus
	utilization_vmem
	utilization_mem_total_kb
	utilization_mem_free_kb
	utilization_mem_cached_kb
	utilization_mem_avalible_kb
	utilization_mem_buffers_kb
	utilization_swap_total_kb
	utilization_swap_free_kb
	utilization_swap_cached_kb
	utilization_load_1_100		//load average 1 minutes * 100
	utilization_load_5_100		//load average 5 minutes * 100
	utilization_load_15_100		//load average 15 minutes * 100
	utilization_cpu_time_kernel
	utilization_cpu_time_user
	utilization_cpu_time_io
	utilization_cpu_time_idle


	resouce_failure_unknown

	event_migration

	event_action_libvirt_migration
	)

// generalized HARDWARE resource
// could be number of cores, RAM usage, cpu load etc
type Cluster_utilization struct {
	ResourceController_name	string
	ResourceController_id	int
	Name	string
	Id		int
	Value	uint64
}

// generalized Cluster resource deployed by balance system
type Cluster_resource struct {
	ResourceController_name	string
	ResourceController_id	int
	Name		string
	Id			int
	State		int
	State_name	string
	Util		[]Cluster_utilization
	Strs		map[string]string
	Ints		map[string]int
	Bools		map[string]bool
	Placement	string
	ConfFile	string
}


type ResourceController interface {
	Get_running_resources() *[]Cluster_resource
	Get_utilization() *[]Cluster_utilization
	Start_resource(name string) bool
	Stop_resource(name string) bool
	Nuke_resource(name string) bool
	Migrate_resource(resource_name string, dest_node string) bool
	Clean_resource(name string) bool
	Kill_controller() bool
	Get_controller_health() bool
	Get_live_migration_support() bool
}

func _stateString(i int) string {
	switch i {
	case resource_state_starting:
		return "starting"
	case resource_state_running:
		return "running"
	case resource_state_stopping:
		return "stopping"
	case resource_state_stopped:
		return "stopped"
	case resource_state_paused:
		return "paused "
	case resource_state_migrating:
		return "migrating"
	case resource_state_other:
		return "other  "
	default:
		return "other  "}}


func (c *Cluster_resource)_stateString() string {
	return _stateString( c.State )}

func (c *Cluster_resource)GetStateString() string {
	return _stateString(c.State)}

func (c *Cluster_resource)CtlString() string {
	switch c.ResourceController_id {
		case resource_controller_id_libvirt:
			return "libvirt"
		case resource_controller_id_docker:
			return "docker"
		case resource_controller_id_dummy:
			return "dummy "
		default:
			return "other "}}

func (c *Cluster_utilization)NameString() string {
	switch c.Id {
	case utilization_vpcus:
		return "vCPUs "
	case utilization_hw_cores:
		return "hwCPUs"
	case utilization_hw_mem:
		return "hwMEM "
	case utilization_vmem:
		return "vMEM  "
	default:
		return "other "}}

func (u *Cluster_utilization)UtilAdd(arg *Cluster_utilization) bool {
	// maybe this function shouldn't check for string name
	// less error prone in config and it should be faster
	//if u.Id != arg.Id || u.Name != arg.Name {
	if u.Id != arg.Id { // TODO check for both
		// resources of the wrong type
		return false}
	u.Value += arg.Value
	return true}

func (c *Cluster_resource)SaveToFile(){
	var confser []byte 
	var err error
	c.Placement = ""
	confser, err = json.MarshalIndent(c, "", "	")
	if err != nil {
		lg.err("Can't serislize resource", err)}
	ioutil.WriteFile(c.ConfFile, confser, 0644)}