operator

type BcsLaunchParam struct {
	// application name
	Name string

	// application namespace
	Namespace string

	// attribute condition, matters the constraint strategy
	AttributeCondition map[string]string

	// env key-values which will be inserted into containers
	Env map[string]string

	// ports that implements with port_name:protocol
	// such as my_port_alpha:http, my_port_beta:tcp
	// port numbers are all generated by container scheduler with cnm HOST
	Ports map[string]string

	// volumes implements the hostPath volumes with name:settings
	Volumes map[string]BcsVolume

	// container images
	Image string

	// instance number to launch
	Instance int
}

type BcsVolume struct {
	ContainerDir string
	HostDir      string
}

type Endpoint struct {
	IP    string
	Ports map[string]int
}

type InstanceFilterFunction func(availableInstance int) (int, error)

type NodeInfo struct {
	IP         string
	Hostname   string
	DiskTotal  float64
	MemTotal   float64
	CPUTotal   float64
	DiskUsed   float64
	MemUsed    float64
	CPUUsed    float64
	DiskLeft   float64
	MemLeft    float64
	CPULeft    float64
	Attributes map[string]string

	Disabled bool
}

type NodeInfoBlock struct {
	DiskTotal            float64
	MemTotal             float64
	CPUTotal             float64
	DiskUsed             float64
	MemUsed              float64
	CPUUsed              float64
	DiskLeft             float64
	MemLeft              float64
	CPULeft              float64
	CPUPerInstance       float64
	MemPerInstance       float64
	CPUPerInstanceOffset float64
	MemPerInstanceOffset float64
	AvailableInstance    int
	// contains filtered or unexported fields
}

type NodeInfoPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Operator interface {
	GetResource(clusterID string) ([]*NodeInfo, error)
	GetServerStatus(clusterID, namespace, name string) (*ServiceInfo, error)
	LaunchServer(clusterID string, param BcsLaunchParam) error
	ScaleServer(clusterID string, namespace, name string, instance int) error
	ReleaseServer(clusterID, namespace, name string) error
}

type ServiceInfo struct {
	Status             ServiceStatus
	Message            string
	RequestInstances   int
	CurrentInstances   int
	AvailableEndpoints []*Endpoint
}

type ServiceStatus int