[Multicast] Add Multicast statistics API and controlplane stats API

This PR adds a field MulticastStats for control-plane API NodeStatsSummary
and field MulticastGroupMember for public statistics API group.

Signed-off-by: ceclinux <src655@gmail.com>

pkg/apis/controlplane/types.go

@@ -340,6 +340,16 @@ type NodeStatsSummary struct {
 	AntreaClusterNetworkPolicies []NetworkPolicyStats
 	// The TrafficStats of Antrea NetworkPolicies collected from the Node.
 	AntreaNetworkPolicies []NetworkPolicyStats
+	// Multicast group information related to multicast collected from the Node.
+	Multicast []MulticastGroupInfo
+}
+
+// MulticastGroupInfo contains the list of Pods that has joined a multicast group, for a given Node.
+type MulticastGroupInfo struct {
+	// Group is the IP of the multicast group.
+	Group string
+	// Pods is the list of Pods that have joined the multicast group.
+	Pods []PodReference
 }
 
 // NetworkPolicyStats contains the information and traffic stats of a NetworkPolicy.

pkg/apis/controlplane/v1beta2/types.go

@@ -342,6 +342,16 @@ type NodeStatsSummary struct {
 	AntreaClusterNetworkPolicies []NetworkPolicyStats `json:"antreaClusterNetworkPolicies,omitempty" protobuf:"bytes,3,rep,name=antreaClusterNetworkPolicies"`
 	// The TrafficStats of Antrea NetworkPolicies collected from the Node.
 	AntreaNetworkPolicies []NetworkPolicyStats `json:"antreaNetworkPolicies,omitempty" protobuf:"bytes,4,rep,name=antreaNetworkPolicies"`
+	// Multicast group information related to multicast collected from the Node.
+	Multicast []MulticastGroupInfo `json:"multicast,omitempty" protobuf:"bytes,5,rep,name=multicast"`
+}
+
+// MulticastGroupInfo contains the list of Pods that has joined a multicast group, for a given Node.
+type MulticastGroupInfo struct {
+	// Group is the IP of the multicast group.
+	Group string `json:"group,omitempty" protobuf:"bytes,1,opt,name=group"`
+	// Pods is the list of Pods that have joined the multicast group.
+	Pods []PodReference `json:"pods,omitempty" protobuf:"bytes,2,rep,name=pods"`
 }
 
 // NetworkPolicyStats contains the information and traffic stats of a NetworkPolicy.

pkg/apis/stats/register.go

@@ -50,6 +50,8 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&AntreaNetworkPolicyStatsList{},
 		&NetworkPolicyStats{},
 		&NetworkPolicyStatsList{},
+		&MulticastGroup{},
+		&MulticastGroupList{},
 	)
 	return nil
 }

pkg/apis/stats/types.go

@@ -65,6 +65,38 @@ type AntreaNetworkPolicyStatsList struct {
 	Items []AntreaNetworkPolicyStats
 }
 
+// PodReference represents a Pod Reference.
+type PodReference struct {
+	// The name of this Pod.
+	Name string
+	// The namespace of this Pod.
+	Namespace string
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// MulticastGroup contains the mapping between Multicast Group and Pods.
+type MulticastGroup struct {
+	metav1.TypeMeta
+	metav1.ObjectMeta
+
+	// Group is the IP of the multicast group.
+	Group string
+	// Pods is the list of Pods that have joined the multicast group.
+	Pods []PodReference
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// MulticastGroupList is a list of MulticastGroup.
+type MulticastGroupList struct {
+	metav1.TypeMeta
+	metav1.ListMeta
+
+	// List of MulticastGroup.
+	Items []MulticastGroup
+}
+
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // NetworkPolicyStats is the statistics of a K8s NetworkPolicy.