Add ingest info to Cluster Stats response (#4407)

Relates: #4341, elastic/elasticsearch#48485

src/Nest/Cluster/ClusterStats/ClusterNodesStats.cs

@@ -1,5 +1,6 @@
 using System.Collections.Generic;
 using System.Runtime.Serialization;
+using Elasticsearch.Net;
 
 namespace Nest
 {
@@ -35,6 +36,9 @@ public class ClusterNodesStats
 
 		[DataMember(Name = "versions")]
 		public IReadOnlyCollection<string> Versions { get; internal set; }
+
+		[DataMember(Name = "ingest")]
+		public ClusterIngestStats Ingest { get; internal set; }
 	}
 
 	public class NodePackagingType
@@ -222,4 +226,30 @@ public class ClusterNodeCount
 		[DataMember(Name = "voting_only")]
 		public int VotingOnly { get; internal set; }
 	}
+
+	[DataContract]
+	public class ClusterIngestStats
+	{
+		[DataMember(Name = "number_of_pipelines")]
+		public int NumberOfPipelines { get; internal set; }
+
+		[DataMember(Name = "processor_stats")]
+		public IReadOnlyDictionary<string, ClusterProcessorStats> ProcessorStats { get; internal set; }
+	}
+
+	[DataContract]
+	public class ClusterProcessorStats
+	{
+		[DataMember(Name ="count")]
+		public long Count { get; set; }
+
+		[DataMember(Name ="current")]
+		public long Current { get; set; }
+
+		[DataMember(Name ="failed")]
+		public long Failed { get; set; }
+
+		[DataMember(Name ="time_in_millis")]
+		public long TimeInMilliseconds { get; set; }
+	}
 }

tests/Tests/Cluster/ClusterStats/ClusterStatsApiTests.cs

@@ -93,6 +93,9 @@ protected void Assert(ClusterNodesStats nodes)
 			nodes.Process.OpenFileDescriptors.Min.Should().NotBe(0);
 
 			nodes.Versions.Should().NotBeEmpty();
+
+			if (Cluster.ClusterConfiguration.Version >= "7.6.0")
+				nodes.Ingest.Should().NotBeNull();
 		}
 
 		protected void Assert(ClusterIndicesStats indices)