聚合Kubernetes活跃探测响应

要实现“聚合Kubernetes活跃探测响应”的解决方法，可以按照以下步骤进行操作：

1. 创建一个自定义Kubernetes控制器，用于监听Pod和Service的创建、更新和删除事件。
2. 在控制器中，使用Kubernetes客户端库（如kubernetes-client-go）获取所有活跃的Pod和Service的列表。
3. 遍历所有的Pod和Service，为每个Pod和Service创建一个活跃探测响应对象。
4. 在活跃探测响应对象中，设置Pod和Service的名称、IP地址和端口号等信息。
5. 将活跃探测响应对象添加到一个列表中。
6. 将列表转换为JSON格式的字符串，并返回给调用者。

下面是一个示例代码，展示了如何实现上述解决方法：

package main

import (
	"encoding/json"
	"log"
	"os"
	"os/signal"
	"syscall"
	"time"

	"github.com/ghodss/yaml"
	v1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/api/errors"
	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/labels"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
)

type ActiveProbeResponse struct {
	Name      string `json:"name"`
	IP        string `json:"ip"`
	Port      int32  `json:"port"`
	Timestamp int64  `json:"timestamp"`
}

func main() {
	// 加载Kubernetes配置文件
	config, err := clientcmd.BuildConfigFromFlags("", "kubeconfig")
	if err != nil {
		log.Fatal(err)
	}

	// 创建Kubernetes客户端
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		log.Fatal(err)
	}

	// 创建一个通道，用于接收中断信号
	stopCh := make(chan struct{})
	signalCh := make(chan os.Signal, 1)
	signal.Notify(signalCh, syscall.SIGINT, syscall.SIGTERM)

	// 启动控制器
	go func() {
		// 监听Pod和Service的事件
		watchPods(clientset, stopCh)
		watchServices(clientset, stopCh)
	}()

	// 等待中断信号
	select {
	case <-signalCh:
		log.Println("Received termination signal, stopping controller...")
		close(stopCh)
	}
}

func watchPods(clientset *kubernetes.Clientset, stopCh <-chan struct{}) {
	for {
		// 创建一个Pod的Watcher
		podWatcher, err := clientset.CoreV1().Pods("").Watch(meta_v1.ListOptions{})
		if err != nil {
			log.Println(err)
			continue
		}

		// 处理Pod事件
		go func() {
			for event := range podWatcher.ResultChan() {
				pod, ok := event.Object.(*v1.Pod)
				if !ok {
					log.Println("Failed to get pod object")
					continue
				}

				// 判断Pod的状态是否为Running
				if pod.Status.Phase != v1.PodRunning {
					continue
				}

				// 创建活跃探测响应对象
				response := &ActiveProbeResponse{
					Name:      pod.Name,
					IP:        pod.Status.PodIP,
					Port:      8080, // 假设Pod上监听的端口号为8080
					Timestamp: time.Now().Unix(),
				}

				// 将活跃探测响应对象转换为JSON格式的字符串
				responseJSON, err := json.Marshal(response)
				if err != nil {
					log.Println(err)
					continue
				}

				log.Println("Active probe response:", string(responseJSON))
				// 处理活跃探测响应...
			}
		}()

		// 等待中断信号或Watcher停止
		select {
		case <-stopCh:
			podWatcher.Stop()
			return
		case <-podWatcher.Done():
			log.Println("Pod watcher stopped, restarting...")
		}
	}
}

func watchServices(clientset *kubernetes.Clientset, stopCh <-chan struct{}) {
	for {
		// 创建一个Service的Watcher
		serviceWatcher, err := clientset.Core