add functionality to get /processes

Author: Alex Shchukin

client/nginx.go

@@ -108,6 +108,7 @@ func (internalError *internalError) Wrap(err string) *internalError {
 // https://nginx.org/en/docs/http/ngx_http_api_module.html
 type Stats struct {
 	NginxInfo         NginxInfo
+	Processes         Processes
 	Connections       Connections
 	Slabs             Slabs
 	HTTPRequests      HTTPRequests
@@ -372,6 +373,11 @@ type ResolverResponses struct {
 	Unknown  int64
 }
 
+// Processes represents processes related stats
+type Processes struct {
+	Respawned int64 `json:"respawned"`
+}
+
 // NewNginxClient creates an NginxClient.
 func NewNginxClient(httpClient *http.Client, apiEndpoint string) (*NginxClient, error) {
 	versions, err := getAPIVersions(httpClient, apiEndpoint)
@@ -930,13 +936,18 @@ func determineStreamUpdates(updatedServers []StreamUpstreamServer, nginxServers
 	return
 }
 
-// GetStats gets connection, request, ssl, zone, stream zone, upstream and stream upstream related stats from the NGINX Plus API.
+// GetStats gets process, slab, connection, request, ssl, zone, stream zone, upstream and stream upstream related stats from the NGINX Plus API.
 func (client *NginxClient) GetStats() (*Stats, error) {
 	info, err := client.getNginxInfo()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get stats: %v", err)
 	}
 
+	processes, err := client.getProcesses()
+	if err != nil {
+		return nil, fmt.Errorf("failed to get stats: %v", err)
+	}
+
 	slabs, err := client.getSlabs()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get stats: %v", err)
@@ -994,6 +1005,7 @@ func (client *NginxClient) GetStats() (*Stats, error) {
 
 	return &Stats{
 		NginxInfo:         *info,
+		Processes:         *processes,
 		Slabs:             *slabs,
 		Connections:       *cons,
 		HTTPRequests:      *requests,
@@ -1134,6 +1146,16 @@ func (client *NginxClient) getResolvers() (*Resolvers, error) {
 	return &resolvers, err
 }
 
+func (client *NginxClient) getProcesses() (*Processes, error) {
+	var processes Processes
+	err := client.get("processes", &processes)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get processes: %v", err)
+	}
+
+	return &processes, err
+}
+
 // KeyValPairs are the key-value pairs stored in a zone.
 type KeyValPairs map[string]string