Merge pull request #568 from mvle/sysched-scoring

Sysched: add the implementation of SySched
kubernetes-sigs · Mar 6, 2024 · cd3e4fb · cd3e4fb
2 parents a49a32e + 4b6ea59
commit cd3e4fb
Show file tree

Hide file tree

Showing 102 changed files with 14,674 additions and 44 deletions.
diff --git a/apis/config/register.go b/apis/config/register.go
@@ -43,6 +43,7 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&PreemptionTolerationArgs{},
 		&TopologicalSortArgs{},
 		&NetworkOverheadArgs{},
+		&SySchedArgs{},
 	)
 	return nil
 }

diff --git a/apis/config/types.go b/apis/config/types.go
@@ -253,3 +253,15 @@ type NetworkOverheadArgs struct {
 	// The NetworkTopology CRD name
 	NetworkTopologyName string
 }
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type SySchedArgs struct {
+	metav1.TypeMeta
+
+	// CR namespace of the default profile for all system calls
+	DefaultProfileNamespace string
+
+	// CR name of the default profile for all system calls
+	DefaultProfileName string
+}
diff --git a/apis/config/v1/defaults.go b/apis/config/v1/defaults.go
@@ -96,6 +96,12 @@ var (
 	DefaultWeightsName = "UserDefined"
 	// DefaultNetworkTopologyName contains the networkTopology CR name to be used by networkAware plugins
 	DefaultNetworkTopologyName = "nt-default"
+
+	// Defaults for SySched
+	// DefaultSySchedProfileNamespace is the namesapce of the default syscall profile CR for SySched plugin
+	DefaultSySchedProfileNamespace = "default"
+	// DefaultSySchedProfileName is the name of the default syscall profile CR for SySched plugin
+	DefaultSySchedProfileName = "all-syscalls"
 )
 
 // SetDefaults_CoschedulingArgs sets the default parameters for Coscheduling plugin.
@@ -233,3 +239,14 @@ func SetDefaults_NetworkOverheadArgs(obj *NetworkOverheadArgs) {
 		obj.NetworkTopologyName = &DefaultNetworkTopologyName
 	}
 }
+
+// SetDefaults_SySchedArgs sets the default parameters for SySchedArgs plugin.
+func SetDefaults_SySchedArgs(obj *SySchedArgs) {
+	if obj.DefaultProfileNamespace == nil {
+		obj.DefaultProfileNamespace = &DefaultSySchedProfileNamespace
+	}
+
+	if obj.DefaultProfileName == nil {
+		obj.DefaultProfileName = &DefaultSySchedProfileName
+	}
+}
diff --git a/apis/config/v1/defaults_test.go b/apis/config/v1/defaults_test.go
@@ -255,6 +255,25 @@ func TestSchedulingDefaults(t *testing.T) {
 				NetworkTopologyName: pointer.StringPtr("nt-latency-costs"),
 			},
 		},
+		{
+			name:   "empty config SySchedArgs",
+			config: &SySchedArgs{},
+			expect: &SySchedArgs{
+				DefaultProfileNamespace: pointer.StringPtr("default"),
+				DefaultProfileName:      pointer.StringPtr("all-syscalls"),
+			},
+		},
+		{
+			name: "set non default SySchedArgs",
+			config: &SySchedArgs{
+				DefaultProfileNamespace: pointer.StringPtr("default"),
+				DefaultProfileName:      pointer.StringPtr("all-syscalls"),
+			},
+			expect: &SySchedArgs{
+				DefaultProfileNamespace: pointer.StringPtr("default"),
+				DefaultProfileName:      pointer.StringPtr("all-syscalls"),
+			},
+		},
 	}
 
 	for _, tc := range tests {

diff --git a/apis/config/v1/register.go b/apis/config/v1/register.go
@@ -45,6 +45,7 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&PreemptionTolerationArgs{},
 		&TopologicalSortArgs{},
 		&NetworkOverheadArgs{},
+		&SySchedArgs{},
 	)
 	return nil
 }

diff --git a/apis/config/v1/types.go b/apis/config/v1/types.go
@@ -251,3 +251,15 @@ type NetworkOverheadArgs struct {
 	// The NetworkTopology CRD name
 	NetworkTopologyName *string `json:"networkTopologyName,omitempty"`
 }
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type SySchedArgs struct {
+	metav1.TypeMeta `json:",inline"`
+
+	// CR namespace of the default profile for all system calls
+	DefaultProfileNamespace *string `json:"defaultProfileNamespace,omitempty"`
+
+	// CR name of the default profile for all system calls
+	DefaultProfileName *string `json:"defaultProfileName,omitempty"`
+}
diff --git a/apis/config/v1/zz_generated.conversion.go b/apis/config/v1/zz_generated.conversion.go
diff --git a/apis/config/v1/zz_generated.deepcopy.go b/apis/config/v1/zz_generated.deepcopy.go
diff --git a/apis/config/v1/zz_generated.defaults.go b/apis/config/v1/zz_generated.defaults.go
diff --git a/apis/config/v1beta3/defaults.go b/apis/config/v1beta3/defaults.go
@@ -96,6 +96,12 @@ var (
 	DefaultWeightsName = "UserDefined"
 	// DefaultNetworkTopologyName contains the networkTopology CR name to be used by networkAware plugins
 	DefaultNetworkTopologyName = "nt-default"
+
+	// Defaults for SySched
+	// DefaultSySchedProfileNamespace is the namesapce of the default syscall profile CR for SySched plugin
+	DefaultSySchedProfileNamespace = "default"
+	// DefaultSySchedProfileName is the name of the default syscall profile CR for SySched plugin
+	DefaultSySchedProfileName = "all-syscalls"
 )
 
 // SetDefaults_CoschedulingArgs sets the default parameters for Coscheduling plugin.
@@ -233,3 +239,14 @@ func SetDefaults_NetworkOverheadArgs(obj *NetworkOverheadArgs) {
 		obj.NetworkTopologyName = &DefaultNetworkTopologyName
 	}
 }
+
+// SetDefaults_SySchedArgs sets the default parameters for SySchedArgs plugin.
+func SetDefaults_SySchedArgs(obj *SySchedArgs) {
+	if obj.DefaultProfileNamespace == nil {
+		obj.DefaultProfileNamespace = &DefaultSySchedProfileNamespace
+	}
+
+	if obj.DefaultProfileName == nil {
+		obj.DefaultProfileName = &DefaultSySchedProfileName
+	}
+}
diff --git a/apis/config/v1beta3/defaults_test.go b/apis/config/v1beta3/defaults_test.go
@@ -255,6 +255,25 @@ func TestSchedulingDefaults(t *testing.T) {
 				NetworkTopologyName: pointer.StringPtr("nt-latency-costs"),
 			},
 		},
+		{
+			name:   "empty config SySchedArgs",
+			config: &SySchedArgs{},
+			expect: &SySchedArgs{
+				DefaultProfileNamespace: pointer.StringPtr("default"),
+				DefaultProfileName:      pointer.StringPtr("all-syscalls"),
+			},
+		},
+		{
+			name: "set non default SySchedArgs",
+			config: &SySchedArgs{
+				DefaultProfileNamespace: pointer.StringPtr("default"),
+				DefaultProfileName:      pointer.StringPtr("all-syscalls"),
+			},
+			expect: &SySchedArgs{
+				DefaultProfileNamespace: pointer.StringPtr("default"),
+				DefaultProfileName:      pointer.StringPtr("all-syscalls"),
+			},
+		},
 	}
 
 	for _, tc := range tests {

diff --git a/apis/config/v1beta3/register.go b/apis/config/v1beta3/register.go
@@ -45,6 +45,7 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&PreemptionTolerationArgs{},
 		&TopologicalSortArgs{},
 		&NetworkOverheadArgs{},
+		&SySchedArgs{},
 	)
 	return nil
 }

diff --git a/apis/config/v1beta3/types.go b/apis/config/v1beta3/types.go
@@ -254,3 +254,15 @@ type NetworkOverheadArgs struct {
 	// The NetworkTopology CRD name
 	NetworkTopologyName *string `json:"networkTopologyName,omitempty"`
 }
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type SySchedArgs struct {
+	metav1.TypeMeta `json:",inline"`
+
+	// CR namespace of the default profile for all system calls
+	DefaultProfileNamespace *string `json:"defaultProfileNamespace,omitempty"`
+
+	// CR name of the default profile for all system calls
+	DefaultProfileName *string `json:"defaultProfileName,omitempty"`
+}
diff --git a/apis/config/v1beta3/zz_generated.conversion.go b/apis/config/v1beta3/zz_generated.conversion.go
diff --git a/apis/config/v1beta3/zz_generated.deepcopy.go b/apis/config/v1beta3/zz_generated.deepcopy.go