Add worker-cpu-affinity configmap key

examples/customization/README.md

@@ -38,6 +38,7 @@ The table below summarizes some of the options. More options (extensions) are av
 | `nginx.org/listen-ports` | N/A | Configures HTTP ports that NGINX will listen on. | `[80]` |
 | `nginx.org/listen-ports-ssl` | N/A | Configures HTTPS ports that NGINX will listen on. | `[443]` |
 | N/A | `worker-processes` | Sets the value of the [worker_processes](http://nginx.org/en/docs/ngx_core_module.html#worker_processes) directive. | `auto` |
+| N/A | `worker-cpu-affinity` | Sets the value of the [worker_cpu_affinity](http://nginx.org/en/docs/ngx_core_module.html#worker_cpu_affinity) directive. | N/A |
 
 ## Using ConfigMaps
 

examples/customization/nginx-config.yaml

@@ -45,3 +45,4 @@ data:
     proxy_temp_path  /var/nginx/proxy_temp;
     charset  koi8-r;
   worker-processes: "1" # default is "auto". Sets the value of the worker_processes directive. See http://nginx.org/en/docs/ngx_core_module.html#worker_processes
+  worker-cpu-affinity: "auto" # No default. Sets the value of the worker_cpu_affinity directive. See http://nginx.org/en/docs/ngx_core_module.html#worker_cpu_affinity

nginx-controller/controller/controller.go

@@ -572,6 +572,9 @@ func (lbc *LoadBalancerController) syncCfgm(task Task) {
 				cfg.MainWorkerProcesses = cfgm.Data["worker-processes"]
 			}
 		}
+		if workerCPUAffinity, exists := cfgm.Data["worker-cpu-affinity"]; exists {
+			cfg.MainWorkerCPUAffinity = workerCPUAffinity
+		}
 	}
 
 	var ingExes []*nginx.IngressEx

nginx-controller/nginx/config.go

@@ -26,6 +26,7 @@ type Config struct {
 	HSTSIncludeSubdomains         bool
 	LBMethod                      string
 	MainWorkerProcesses           string
+	MainWorkerCPUAffinity         string
 
 	// http://nginx.org/en/docs/http/ngx_http_realip_module.html
 	RealIPHeader    string

nginx-controller/nginx/configurator.go

@@ -663,10 +663,11 @@ func (cnf *Configurator) UpdateConfig(config *Config, ingExes []*IngressEx) erro
 		SSLCiphers:                config.MainServerSSLCiphers,
 		SSLDHParam:                config.MainServerSSLDHParam,
 		SSLPreferServerCiphers:    config.MainServerSSLPreferServerCiphers,
-		HTTP2:           config.HTTP2,
-		ServerTokens:    config.ServerTokens,
-		ProxyProtocol:   config.ProxyProtocol,
-		WorkerProcesses: config.MainWorkerProcesses,
+		HTTP2:             config.HTTP2,
+		ServerTokens:      config.ServerTokens,
+		ProxyProtocol:     config.ProxyProtocol,
+		WorkerProcesses:   config.MainWorkerProcesses,
+		WorkerCPUAffinity: config.MainWorkerCPUAffinity,
 	}
 
 	cnf.nginx.UpdateMainConfigFile(mainCfg)

nginx-controller/nginx/nginx.go

@@ -114,6 +114,7 @@ type NginxMainConfig struct {
 	ServerTokens           string
 	ProxyProtocol          bool
 	WorkerProcesses        string
+	WorkerCPUAffinity      string
 }
 
 // NewUpstreamWithDefaultServer creates an upstream with the default server.

nginx-controller/nginx/templates/nginx-plus.tmpl

@@ -1,6 +1,8 @@
 
 user  nginx;
 worker_processes  {{.WorkerProcesses}};
+{{- if .WorkerCPUAffinity}}
+worker_cpu_affinity {{.WorkerCPUAffinity}};{{end}}
 
 daemon off;
 

nginx-controller/nginx/templates/nginx.tmpl

@@ -1,6 +1,8 @@
 
 user  nginx;
 worker_processes  {{.WorkerProcesses}};
+{{- if .WorkerCPUAffinity}}
+worker_cpu_affinity {{.WorkerCPUAffinity}};{{end}}
 
 daemon off;
 

nginx-controller/nginx/templates/templates_test.go

@@ -49,6 +49,7 @@ var mainCfg = nginx.NginxMainConfig{
 	ServerNamesHashMaxSize: "512",
 	ServerTokens:           "off",
 	WorkerProcesses:        "auto",
+	WorkerCPUAffinity:      "auto",
 }
 
 func TestIngressForNGINXPlus(t *testing.T) {