[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 <[email protected]>

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
+	// The stats related to multicast collected from the Node.
+	Multicast []MulticastStats
+}
+
+// MulticastStats contains the multicast groups that a Pod has joined.
+type MulticastStats struct {
+	// Group is the IP of Multicast Group.
+	Group string
+	// Pods is the list of Pods that has 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"`
+	// List of PodMulticast statistics collected from the Node.
+	Multicast []MulticastStats `json:"multicast,omitempty" protobuf:"bytes,5,rep,name=multicast"`
+}
+
+// MulticastStats contains the multicast groups that a Pod has joined.
+type MulticastStats struct {
+	// Group is the IP of Multicast Group.
+	Group string `json:"group,omitempty" protobuf:"bytes,1,opt,name=group"`
+	// Pods is the list of Pods that has 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{},
+		&MulticastGroupMember{},
+		&MulticastGroupMemberList{},
 	)
 	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
+
+// MulticastGroupMember contains the mapping between Multicast Group and Pods.
+type MulticastGroupMember struct {
+	metav1.TypeMeta
+	metav1.ObjectMeta
+
+	// Group is the IP of Multicast Group.
+	Group string
+	// Pods is the list of Pods that has joined the multicast group.
+	Pods []PodReference
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// MulticastGroupMemberList is a list of MulticastGroupMember.
+type MulticastGroupMemberList struct {
+	metav1.TypeMeta
+	metav1.ListMeta
+
+	// List of MulticastGroupPodsMember.
+	Items []MulticastGroupMember
+}
+
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // NetworkPolicyStats is the statistics of a K8s NetworkPolicy.

pkg/apis/stats/v1alpha1/register.go

@@ -47,6 +47,8 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&AntreaNetworkPolicyStatsList{},
 		&NetworkPolicyStats{},
 		&NetworkPolicyStatsList{},
+		&MulticastGroupMember{},
+		&MulticastGroupMemberList{},
 	)
 	metav1.AddToGroupVersion(scheme, SchemeGroupVersion)
 	return nil

pkg/apis/stats/v1alpha1/types.go

@@ -85,6 +85,34 @@ type NetworkPolicyStats struct {
 	TrafficStats TrafficStats `json:"trafficStats,omitempty" protobuf:"bytes,2,opt,name=trafficStats"`
 }
 
+// +genclient
+// +resourceName=multicastgroupmembers
+// +genclient:readonly
+// +genclient:nonNamespaced
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// MulticastGroupMember contains the mapping between Multicast Group and Pods.
+type MulticastGroupMember struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
+
+	// Group is the IP of Multicast Group.
+	Group string `json:"group,omitempty" protobuf:"bytes,2,opt,name=group"`
+	// Pods is the list of Pods that has joined the multicast group.
+	Pods []PodReference `json:"pods" protobuf:"bytes,3,rep,name=pods"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+// MulticastGroupMemberList is a list of MulticastGroupMember.
+type MulticastGroupMemberList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
+
+	// List of MulticastGroupPodsMember.
+	Items []MulticastGroupMember `json:"items" protobuf:"bytes,2,rep,name=items"`
+}
+
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // NetworkPolicyStatsList is a list of NetworkPolicyStats.
@@ -96,6 +124,14 @@ type NetworkPolicyStatsList struct {
 	Items []NetworkPolicyStats `json:"items" protobuf:"bytes,2,rep,name=items"`
 }
 
+// PodReference represents a Pod Reference.
+type PodReference struct {
+	// The name of this Pod.
+	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
+	// The Namespace of this Pod.
+	Namespace string `json:"namespace,omitempty" protobuf:"bytes,2,opt,name=namespace"`
+}
+
 // TrafficStats contains the traffic stats of a NetworkPolicy.
 type TrafficStats struct {
 	// Packets is the packets count hit by the NetworkPolicy.