MINOR: support keyword cpu-set in global section

Signed-off-by: Vincent Gramer <vgramer@haproxy.com>

Author: vgramer

config-parser/parsers/cpu-set.go

@@ -0,0 +1,78 @@
+package parsers
+
+import (
+	"fmt"
+	"slices"
+
+	"github.com/haproxytech/client-native/v6/config-parser/common"
+	"github.com/haproxytech/client-native/v6/config-parser/errors"
+	"github.com/haproxytech/client-native/v6/config-parser/types"
+)
+
+// Supported directives for cpu-set keyword
+var cpuSetSupportedDirectives = []string{ //nolint:gochecknoglobals
+	CPUSetResetDirective,
+	"drop-cpu",
+	"only-cpu",
+	"drop-node",
+	"only-node",
+	"drop-cluster",
+	"only-cluster",
+	"drop-core",
+	"only-core",
+	"drop-thread",
+	"only-thread",
+}
+
+const CPUSetResetDirective = "reset"
+
+type CPUSet struct {
+	data        []types.CPUSet
+	preComments []string // comments that appear before the actual line
+}
+
+func (c *CPUSet) parse(line string, parts []string, comment string) (*types.CPUSet, error) {
+	// Check if we have at least the command (cpu-set) and directive
+	if len(parts) < 2 {
+		return nil, &errors.ParseError{Parser: "CPUSet", Line: line, Message: "Parse error"}
+	}
+
+	// Validate the directive
+	directive := parts[1]
+	if !slices.Contains(cpuSetSupportedDirectives, directive) {
+		return nil, &errors.ParseError{Parser: "CPUSet", Line: line, Message: fmt.Sprintf("Unknown directive %q, supported directives %v", directive, cpuSetSupportedDirectives)}
+	}
+
+	// Handle reset directive (no 'set' parameters)
+	if directive == CPUSetResetDirective {
+		if len(parts) != 2 {
+			return nil, &errors.ParseError{Parser: "CPUSet", Line: line, Message: "cpu-set reset directive does not accept 'set' parameter"}
+		}
+		return &types.CPUSet{Directive: directive, Comment: comment}, nil
+	}
+
+	// Handle other directives (require one parameter)
+	if len(parts) != 3 {
+		return nil, &errors.ParseError{Parser: "CPUSet", Line: line, Message: fmt.Sprintf("cpu-set %s missing 'set' parameter", directive)}
+	}
+
+	return &types.CPUSet{Directive: directive, Set: parts[2], Comment: comment}, nil
+}
+
+func (c *CPUSet) Result() ([]common.ReturnResultLine, error) {
+	if len(c.data) == 0 {
+		return nil, errors.ErrFetch
+	}
+	result := make([]common.ReturnResultLine, len(c.data))
+	for index, cpuSet := range c.data {
+		data := "cpu-set " + cpuSet.Directive
+		if cpuSet.Directive != CPUSetResetDirective { // reset is the only directive that has no 'set' parameter
+			data += " " + cpuSet.Set
+		}
+		result[index] = common.ReturnResultLine{
+			Data:    data,
+			Comment: cpuSet.Comment,
+		}
+	}
+	return result, nil
+}

config-parser/parsers/cpu-set_generated.go

@@ -251,6 +251,7 @@ func (p *configParser) getGlobalParser() *Parsers { //nolint: maintidx
 	addParser(parser, &sequence, &parsers.NbThread{})
 	addParser(parser, &sequence, &parsers.CPUMap{})
 	addParser(parser, &sequence, &parsers.CPUPolicy{})
+	addParser(parser, &sequence, &parsers.CPUSet{})
 	addParser(parser, &sequence, &parsers.Mode{})
 	addParser(parser, &sequence, &parsers.MaxConn{})
 	addParser(parser, &sequence, &simple.Number{Name: "maxconnrate"})

config-parser/section-parsers.go

@@ -29,6 +29,9 @@ global
   cpu-map 2 1
   cpu-map 3 2
   cpu-policy none
+  cpu-set reset
+  cpu-set only-node 0
+  cpu-set drop-core 8-9
   maxconn 5000
   pidfile /var/run/haproxy.pid
   stats socket /var/run/haproxy-runtime-api.1.sock level admin mode 777 expose-fd listeners process 1