Merge pull request #1 from kubeslice-ent/feat-gpr

Feat gpr

go.mod

@@ -1,4 +1,4 @@
-module github.com/kubeslice/apis
+module github.com/kubeslice-ent/apis
 
 go 1.16
 

pkg/controller/v1alpha1/cluster_types.go

@@ -55,64 +55,64 @@ type ClusterSpec struct {
 	NodeIPs []string `json:"nodeIPs,omitempty"`
 	// NetworkInterface is the network interface attached with the cluster.
 	NetworkInterface string `json:"networkInterface,omitempty"`
-	//put in an object
+	// put in an object
 	ClusterProperty ClusterProperty `json:"clusterProperty,omitempty"`
 }
 
 type ClusterProperty struct {
-	//Telemetry contains Telemetry information
+	// Telemetry contains Telemetry information
 	Telemetry Telemetry `json:"telemetry,omitempty"`
-	//GeoLocation contains information regarding Geographical Location of the Cluster
+	// GeoLocation contains information regarding Geographical Location of the Cluster
 	GeoLocation GeoLocation `json:"geoLocation,omitempty"`
-	//Monitoring contains the Kubernetes Monitoring Dashboard
+	// Monitoring contains the Kubernetes Monitoring Dashboard
 	Monitoring Monitoring `json:"monitoring,omitempty"`
 }
 
 // Telemetry defines the field of ClusterSpec
 type Telemetry struct {
-	//Enabled is the enable status of the Telemetry
+	// Enabled is the enable status of the Telemetry
 	Enabled bool `json:"enabled,omitempty"`
-	//TelemetryProvider is the Telemetry Provider information
+	// TelemetryProvider is the Telemetry Provider information
 	TelemetryProvider string `json:"telemetryProvider,omitempty"`
-	//Endpoint is the Telemetry Endpoint
+	// Endpoint is the Telemetry Endpoint
 	Endpoint string `json:"endpoint,omitempty"`
 }
 
 // GeoLocation defines the field of ClusterSpec
 type GeoLocation struct {
-	//CloudProvider is the cloud service provider
+	// CloudProvider is the cloud service provider
 	CloudProvider string `json:"cloudProvider,omitempty"`
-	//CloudRegion is the region of the cloud
+	// CloudRegion is the region of the cloud
 	CloudRegion string `json:"cloudRegion,omitempty"`
-	//Latitude is the latitude of the cluster
+	// Latitude is the latitude of the cluster
 	Latitude string `json:"latitude,omitempty"`
-	//Longitude is the longitude of the cluster
+	// Longitude is the longitude of the cluster
 	Longitude string `json:"longitude,omitempty"`
 }
 
 // Monitoring defines the field of ClusterSpec
 type Monitoring struct {
-	//KubernetesDashboard contains the information regarding Kubernetes Monitoring Dashboard
+	// KubernetesDashboard contains the information regarding Kubernetes Monitoring Dashboard
 	KubernetesDashboard KubernetesDashboard `json:"kubernetesDashboard,omitempty"`
 }
 
 // KubernetesDashboard defines the field of ClusterSpec
 type KubernetesDashboard struct {
-	//Enabled is the enable status of the KubernetesDashboard
+	// Enabled is the enable status of the KubernetesDashboard
 	Enabled bool `json:"enabled,omitempty"`
-	//AccessToken is the Access Token to access the KubernetesDashboard
+	// AccessToken is the Access Token to access the KubernetesDashboard
 	AccessToken string `json:"accessToken,omitempty"`
-	//IngressPrefix is the prefix of ingress gateway for KubernetesDashboard
+	// IngressPrefix is the prefix of ingress gateway for KubernetesDashboard
 	IngressPrefix string `json:"ingressPrefix,omitempty"`
-	//Endpoint is the base endpoint to access the kubernetes dashboard
+	// Endpoint is the base endpoint to access the kubernetes dashboard
 	Endpoint string `json:"endpoint,omitempty"`
 }
 
 // ClusterStatus defines the observed state of Cluster
 type ClusterStatus struct {
 	// SecretName is the name of the secret for the worker cluster.
 	SecretName string `json:"secretName,omitempty"`
-	//CniSubnet is the podip and service ip subnet of CNI
+	// CniSubnet is the podip and service ip subnet of CNI
 	CniSubnet []string `json:"cniSubnet,omitempty"`
 	// Namespaces present in cluster
 	Namespaces []NamespacesConfig `json:"namespaces,omitempty"`
@@ -131,6 +131,34 @@ type ClusterStatus struct {
 
 	// VCPURestriction is the restriction on the cluster disabling the creation of new pods
 	VCPURestriction *VCPURestriction `json:"vCPURestriction,omitempty"`
+	// NodeInventory is the inventory of the nodes in the cluster
+	NodeInventory []NodeInventory `json:"nodeInventory,omitempty"`
+}
+
+type NodeInventory struct {
+	//+kubebuilder:validation:Enum:=cpu;gpu;
+	Type          string        `json:"type,omitempty"`
+	Name          string        `json:"name,omitempty"`
+	GpuProperties GpuProperties `json:"gpuProperties,omitempty"`
+}
+
+type GpuProperties struct {
+	GpuNodeType    string         `json:"gpuNodeType,omitempty"`
+	GpuSharingType string         `json:"gpuSharingType,omitempty"`
+	GpuUtilization GpuUtilization `json:"gpuUtilization,omitempty"`
+}
+
+type GpuUtilization struct {
+	TotalGPUs string     `json:"totalGPUs,omitempty"`
+	Free      string     `json:"free,omitempty"`
+	Allocated string     `json:"allocated,omitempty"`
+	Memory    string     `json:"memory,omitempty"`
+	Reserved  []Reserved `json:"reserved,omitempty"`
+}
+
+type Reserved struct {
+	SliceName       string `json:"sliceName,omitempty"`
+	NumReservedGPUs string `json:"numReservedGPUs,omitempty"`
 }
 
 type VCPURestriction struct {

pkg/operator/v1beta1/groupversion_info.go

@@ -0,0 +1,38 @@
+/*
+ *  Copyright (c) 2022 Avesha, Inc. All rights reserved.
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *  http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+// Package v1beta1 contains API Schema definitions for the mesh v1beta1 API group
+// +kubebuilder:object:generate=true
+// +groupName=networking.kubeslice.io
+package v1beta1
+
+import (
+	"k8s.io/apimachinery/pkg/runtime/schema"
+	"sigs.k8s.io/controller-runtime/pkg/scheme"
+)
+
+var (
+	// GroupVersion is group version used to register these objects
+	GroupVersion = schema.GroupVersion{Group: "networking.kubeslice.io", Version: "v1beta1"}
+
+	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
+	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}
+
+	// AddToScheme adds the types in this group-version to the given scheme.
+	AddToScheme = SchemeBuilder.AddToScheme
+)