[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

@@ -324,6 +324,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.
+	MulticastStats []MulticastStats
+}
+
+// MulticastStats contains the multicast groups that a Pod has joined.
+type MulticastStats struct {
+	Pod *PodReference
+
+	// List of multicast IPs that the pod has joined.
+	GroupJoinedList []IPAddress
 }
 
 // NetworkPolicyStats contains the information and traffic stats of a NetworkPolicy.

pkg/apis/controlplane/v1beta2/types.go

@@ -325,6 +325,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.
+	MulticastStats []MulticastStats `json:"multicastStats,omitempty" protobuf:"bytes,5,rep,name=multicastStats"`
+}
+
+// MulticastStats contains the multicast groups that a Pod has joined.
+type MulticastStats struct {
+	Pod *PodReference `json:"pod,omitempty" protobuf:"bytes,1,opt,name=pod"`
+
+	// List of multicast IPs that the pod has joined.
+	GroupJoinedList []IPAddress `json:"groupJoinedList,omitempty" protobuf:"bytes,2,rep,name=groupJoinedList"`
 }
 
 // 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.